IN
- The type of the record that can be read with this record reader.@Internal public final class StreamOneInputProcessor<IN> extends Object implements StreamInputProcessor
OneInputStreamTask
.
This internally uses a StatusWatermarkValve
to keep track of Watermark
and
StreamStatus
events, and forwards them to event subscribers once the
StatusWatermarkValve
determines the Watermark
from all inputs has advanced, or
that a 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 |
---|
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) |
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
IOException
public boolean processInput() throws Exception
processInput
in interface StreamInputProcessor
StreamTaskInput
is finished.Exception
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.