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 checkpointedTask,
CheckpointingMode checkpointMode,
IOManager ioManager,
Configuration taskManagerConfig) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
boolean |
processInput(OneInputStreamOperator<IN,?> streamOperator,
Object lock) |
void |
setMetricGroup(TaskIOMetricGroup metrics)
Sets the metric group for this StreamInputProcessor.
|
public StreamInputProcessor(InputGate[] inputGates, TypeSerializer<IN> inputSerializer, StatefulTask checkpointedTask, CheckpointingMode checkpointMode, IOManager ioManager, Configuration taskManagerConfig) throws IOException
IOException
public boolean processInput(OneInputStreamOperator<IN,?> streamOperator, Object lock) throws Exception
Exception
public void setMetricGroup(TaskIOMetricGroup metrics)
metrics
- metric grouppublic void cleanup() throws IOException
IOException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.