Toggle navigation
Home
java.lang.Integer to org.apache.flink.streaming.api.StreamEdge
No. of Instances - 19
No. of Commits - 4
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Cascading Type Change (Similar)
List<Integer>
to
List<StreamEdge>
List<Integer>
to
List<StreamEdge>
Rename Variable
getOutputs
to
getOutEdges
Add or Remove Method invocation
createChain(startNode,chainable)
to
createChain(startNode,chainable.getTargetVertex())
nonChainable
to
nonChainable.getTargetVertex()
chainedNames.get(chainable)
to
chainedNames.get(chainable.getTargetVertex())
output
to
output.getTargetVertex()
Update Class Instacne Creation
new Tuple2<Integer,Integer>(current,nonChainable)
to
new Tuple2<Integer,Integer>(current,nonChainable.getTargetVertex())
Rename Method invocation
setOutputs
to
setNonChainedOutputs
Cascading Type Change (Different)
HashMap<Integer,StreamOutput<?>>
to
HashMap<StreamEdge,StreamOutput<?>>