Class ColumnarNode

java.lang.Object
io.krabka.streams.columnar.ColumnarNode
public final class ColumnarNode extends Object
An opaque handle to a columnar topology node.

Returned by every add* method of ColumnarTopology and accepted as the parent argument of downstream nodes. A handle is only valid within the topology that created it; passing it to another topology throws IllegalArgumentException.

Example

ColumnarNode source = topology.addSource("source", List.of("transactions"), codec);
ColumnarNode filtered = topology.addOperator("large", filter, source);
topology.addSink("sink", "large-transactions", codec, filtered);