IN- The type of the record that can be read with this record reader.
This internally uses a
StatusWatermarkValve to keep track of
StreamStatus events, and forwards them to event subscribers once the
StatusWatermarkValve determines the
Watermark from all inputs has advanced, or
StreamStatus needs to be propagated downstream to denote a status change.
Forwarding elements, watermarks, or status status elements must be protected by synchronizing
on the given lock object. This ensures that we don't call methods on a
OneInputStreamOperator concurrently with the timer callback or other things.
|Constructor and Description|
public StreamInputProcessor(InputGate inputGates, TypeSerializer<IN> inputSerializer, StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, IOManager ioManager, Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, OneInputStreamOperator<IN,?> streamOperator, TaskIOMetricGroup metrics, WatermarkGauge watermarkGauge) throws IOException
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.