IN- The type of the record that can be read with this record reader.
@Internal public final class StreamOneInputProcessor<IN> extends Object implements StreamInputProcessor
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 StreamOneInputProcessor(InputGate inputGates, TypeSerializer<IN> inputSerializer, StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, IOManager ioManager, Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, OneInputStreamOperator<IN,?> streamOperator, TaskIOMetricGroup metrics, WatermarkGauge watermarkGauge, String taskName, OperatorChain<?,?> operatorChain) throws IOException
public boolean processInput() throws Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.