StreamSinkNode is a StreamsGraphNode that is created exclusively when KStreamImpl is requested to add a StreamSinkNode to a node graph.

In other words, StreamSinkNode represents operator.

StreamSinkNode takes the following when created:

writeToTopology Method

void writeToTopology(final InternalTopologyBuilder topologyBuilder)
writeToTopology is part of the StreamsGraphNode Contract to…​FIXME.

writeToTopology simply requests the given InternalTopologyBuilder to addSink (per ProducedInternal).

writeToTopology creates a new WindowedStreamPartitioner as the StreamPartitioner when no streamPartitioner is specified and the key serializer is a WindowedSerializer.

results matching ""

    No results matching ""