Streaming with Custom Nodes?

[mzlkwsk]

Does anyone know if custom nodes are capable of streaming?

If so how can this be implemented and what are the requirements in the code of the custom nodes?

[qqilihq]

Yes. In the most simple case, you inherit from a class org.knime.core.node.streamable.simple.SimpleStreamableFunctionNodeModel.

For more complex cases, you might need to do more “manual” effort. A good source for example code is always NodePit where you can search for an existing KNIME node which is “streamable”, then click the “Show Source Code” button (in the section “Developers”), which will lead you to the Git repository (if it’s publicly available).

Example: https://nodepit.com/node/org.knime.base.node.preproc.stringmanipulation.StringManipulationNodeFactory#developers

Hope this helps!

[mzlkwsk]

Thanks! That was exactly what I was looking for.