Package | Description |
---|---|
org.apache.flink.streaming.api.graph |
Modifier and Type | Method and Description |
---|---|
StreamEdge |
StreamConfig.SourceInputConfig.getInputEdge() |
Modifier and Type | Method and Description |
---|---|
List<StreamEdge> |
StreamConfig.getChainedOutputs(ClassLoader cl) |
List<StreamEdge> |
StreamNode.getInEdges() |
List<StreamEdge> |
StreamConfig.getInPhysicalEdges(ClassLoader cl) |
List<StreamEdge> |
StreamNode.getOutEdges() |
List<StreamEdge> |
StreamGraph.getStreamEdges(int sourceId) |
List<StreamEdge> |
StreamGraph.getStreamEdges(int sourceId,
int targetId) |
List<StreamEdge> |
StreamGraph.getStreamEdgesOrThrow(int sourceId,
int targetId)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamNode.addInEdge(StreamEdge inEdge) |
void |
StreamNode.addOutEdge(StreamEdge outEdge) |
StreamNode |
StreamGraph.getSourceVertex(StreamEdge edge) |
StreamNode |
StreamGraph.getTargetVertex(StreamEdge edge) |
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) |
Constructor and Description |
---|
SourceInputConfig(StreamEdge inputEdge) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.