Package | Description |
---|---|
org.apache.flink.streaming.api.collector.selector | |
org.apache.flink.streaming.api.graph |
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 |
---|---|
List<StreamEdge> |
StreamConfig.getChainedOutputs(ClassLoader cl) |
List<StreamEdge> |
StreamNode.getInEdges() |
List<StreamEdge> |
StreamConfig.getInPhysicalEdges(ClassLoader cl) |
List<StreamEdge> |
StreamConfig.getNonChainedOutputs(ClassLoader cl) |
List<StreamEdge> |
StreamNode.getOutEdges() |
List<StreamEdge> |
StreamConfig.getOutEdges(ClassLoader cl) |
List<StreamEdge> |
StreamConfig.getOutEdgesInOrder(ClassLoader cl) |
List<StreamEdge> |
StreamGraph.getStreamEdges(int sourceId,
int targetId) |
Modifier and Type | Method and Description |
---|---|
void |
StreamNode.addInEdge(StreamEdge inEdge) |
void |
StreamNode.addOutEdge(StreamEdge outEdge) |
static boolean |
StreamingJobGraphGenerator.isChainable(StreamEdge edge,
StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
void |
StreamConfig.setChainedOutputs(List<StreamEdge> chainedOutputs) |
void |
StreamConfig.setInPhysicalEdges(List<StreamEdge> inEdges) |
void |
StreamConfig.setNonChainedOutputs(List<StreamEdge> outputvertexIDs) |
void |
StreamConfig.setOutEdges(List<StreamEdge> outEdges) |
void |
StreamConfig.setOutEdgesInOrder(List<StreamEdge> outEdgeList) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.