OUT
- The type of elements accepted by the chain, i.e., the input type of the chain's
head operator.@Internal public class OperatorChain<OUT> extends Object
OperatorChain
contains all operators that are executed as one chain within a single
StreamTask
.Constructor and Description |
---|
OperatorChain(StreamTask<OUT,?> containingTask,
StreamOperator<OUT> headOperator,
AccumulatorRegistry.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
broadcastCheckpointBarrier(long id,
long timestamp) |
void |
broadcastCheckpointCancelMarker(long id) |
void |
flushOutputs()
This method should be called before finishing the record emission, to make sure any data
that is still buffered will be sent.
|
StreamOperator<?>[] |
getAllOperators() |
Output<StreamRecord<OUT>> |
getChainEntryPoint() |
RecordWriterOutput<?>[] |
getStreamOutputs() |
void |
releaseOutputs()
This method releases all resources of the record writer output.
|
public OperatorChain(StreamTask<OUT,?> containingTask, StreamOperator<OUT> headOperator, AccumulatorRegistry.Reporter reporter)
public void broadcastCheckpointBarrier(long id, long timestamp) throws IOException
IOException
public void broadcastCheckpointCancelMarker(long id) throws IOException
IOException
public RecordWriterOutput<?>[] getStreamOutputs()
public StreamOperator<?>[] getAllOperators()
public Output<StreamRecord<OUT>> getChainEntryPoint()
public void flushOutputs() throws IOException
IOException
- Thrown, if the buffered data cannot be pushed into the output streams.public void releaseOutputs()
This method should never fail.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.