IN
- The type of the record that can be read with this record reader.@Internal public class StreamInputProcessor<IN> extends Object
OneInputStreamTask
.
This also keeps track of Watermark
events and forwards them to event subscribers
once the Watermark
from all inputs advances.
Forwarding elements or watermarks 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 |
---|
StreamInputProcessor(InputGate[] inputGates,
TypeSerializer<IN> inputSerializer,
StatefulTask<?> checkpointListener,
CheckpointingMode checkpointMode,
IOManager ioManager,
boolean enableWatermarkMultiplexing,
Configuration taskManagerConfig) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
boolean |
processInput(OneInputStreamOperator<IN,?> streamOperator,
Object lock) |
void |
setMetricGroup(IOMetricGroup metrics)
Sets the metric group for this StreamInputProcessor.
|
void |
setReporter(AccumulatorRegistry.Reporter reporter) |
public StreamInputProcessor(InputGate[] inputGates, TypeSerializer<IN> inputSerializer, StatefulTask<?> checkpointListener, CheckpointingMode checkpointMode, IOManager ioManager, boolean enableWatermarkMultiplexing, Configuration taskManagerConfig) throws IOException
IOException
public boolean processInput(OneInputStreamOperator<IN,?> streamOperator, Object lock) throws Exception
Exception
public void setReporter(AccumulatorRegistry.Reporter reporter)
public void setMetricGroup(IOMetricGroup metrics)
metrics
- metric grouppublic void cleanup() throws IOException
IOException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.