InputConsumerTask
class InputConsumerTask(inputFlow: ReservingDeserializingInputFlow, pipelineInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partitioner: InputPartitioner, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter) : Task
Routes @DestinationStreamAffinedMessages by stream to the appropriate channel and @ CheckpointMessages to the state manager.
TODO: Handle other message types.
Constructors
Link copied to clipboard
constructor(inputFlow: ReservingDeserializingInputFlow, pipelineInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, partitioner: InputPartitioner, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter)