Interface | Description |
---|---|
OutputSelector<OUT> |
Interface for defining an OutputSelector for a
SplitStream using
the SingleOutputStreamOperator.split(org.apache.flink.streaming.api.collector.selector.OutputSelector<T>) call. |
Class | Description |
---|---|
CopyingDirectedOutput<OUT> |
Special version of
DirectedOutput that performs a shallow copy of the
StreamRecord to ensure that multi-chaining works correctly. |
DirectedOutput<OUT> |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.