Modifier and Type | Class and Description |
---|---|
class |
StormStreamSelector<T>
Used by
FlinkTopology to split multiple declared output streams within Flink. |
Modifier and Type | Field and Description |
---|---|
protected OutputSelector<OUT>[] |
DirectedOutput.outputSelectors |
Constructor and Description |
---|
CopyingDirectedOutput(List<OutputSelector<OUT>> outputSelectors,
List<Tuple2<Output<StreamRecord<OUT>>,StreamEdge>> outputs) |
DirectedOutput(List<OutputSelector<OUT>> outputSelectors,
List<Tuple2<Output<StreamRecord<OUT>>,StreamEdge>> outputs) |
Modifier and Type | Method and Description |
---|---|
SplitStream<T> |
DataStream.split(OutputSelector<T> outputSelector)
Operator used for directing tuples to specific named outputs using an
OutputSelector . |
Constructor and Description |
---|
SplitStream(DataStream<OUT> dataStream,
OutputSelector<OUT> outputSelector) |
Modifier and Type | Method and Description |
---|---|
List<OutputSelector<?>> |
StreamNode.getOutputSelectors() |
<T> List<OutputSelector<T>> |
StreamConfig.getOutputSelectors(ClassLoader userCodeClassloader) |
Modifier and Type | Method and Description |
---|---|
<T> void |
StreamGraph.addOutputSelector(Integer vertexID,
OutputSelector<T> outputSelector) |
void |
StreamNode.addOutputSelector(OutputSelector<?> outputSelector) |
Modifier and Type | Method and Description |
---|---|
void |
StreamConfig.setOutputSelectors(List<OutputSelector<?>> outputSelectors) |
Constructor and Description |
---|
StreamNode(StreamExecutionEnvironment env,
Integer id,
String slotSharingGroup,
StreamOperator<?> operator,
String operatorName,
List<OutputSelector<?>> outputSelector,
Class<? extends AbstractInvokable> jobVertexClass) |
Modifier and Type | Method and Description |
---|---|
SplitStream<T> |
DataStream.split(OutputSelector<T> selector)
Operator used for directing tuples to specific named outputs using an
OutputSelector.
|
Modifier and Type | Method and Description |
---|---|
OutputSelector<T> |
SplitTransformation.getOutputSelector()
Returns the
OutputSelector |
Constructor and Description |
---|
SplitTransformation(StreamTransformation<T> input,
OutputSelector<T> outputSelector)
Creates a new
SplitTransformation from the given input and OutputSelector . |
Modifier and Type | Class and Description |
---|---|
static class |
IterateExample.MySelector
OutputSelector testing which tuple needs to be iterated again.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.