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 KStreamImpl.to operator.
StreamSinkNode takes the following when created:
void writeToTopology(final InternalTopologyBuilder topologyBuilder)|
Note
|
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.