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