@Internal public class StreamNode extends Object implements Serializable
Constructor and Description |
---|
StreamNode(StreamExecutionEnvironment env,
Integer id,
String slotSharingGroup,
StreamOperator<?> operator,
String operatorName,
List<OutputSelector<?>> outputSelector,
Class<? extends AbstractInvokable> jobVertexClass) |
public StreamNode(StreamExecutionEnvironment env, Integer id, String slotSharingGroup, StreamOperator<?> operator, String operatorName, List<OutputSelector<?>> outputSelector, Class<? extends AbstractInvokable> jobVertexClass)
public void addInEdge(StreamEdge inEdge)
public void addOutEdge(StreamEdge outEdge)
public List<StreamEdge> getOutEdges()
public List<StreamEdge> getInEdges()
public int getId()
public int getParallelism()
public void setParallelism(Integer parallelism)
public Long getBufferTimeout()
public void setBufferTimeout(Long bufferTimeout)
public StreamOperator<?> getOperator()
public void setOperator(StreamOperator<?> operator)
public String getOperatorName()
public List<OutputSelector<?>> getOutputSelectors()
public void addOutputSelector(OutputSelector<?> outputSelector)
public TypeSerializer<?> getTypeSerializerIn1()
public void setSerializerIn1(TypeSerializer<?> typeSerializerIn1)
public TypeSerializer<?> getTypeSerializerIn2()
public void setSerializerIn2(TypeSerializer<?> typeSerializerIn2)
public TypeSerializer<?> getTypeSerializerOut()
public void setSerializerOut(TypeSerializer<?> typeSerializerOut)
public Class<? extends AbstractInvokable> getJobVertexClass()
public InputFormat<?,?> getInputFormat()
public void setInputFormat(InputFormat<?,?> inputFormat)
public void setSlotSharingGroup(String slotSharingGroup)
public String getSlotSharingGroup()
public boolean isSameSlotSharingGroup(StreamNode downstreamVertex)
public KeySelector<?,?> getStatePartitioner1()
public KeySelector<?,?> getStatePartitioner2()
public void setStatePartitioner1(KeySelector<?,?> statePartitioner)
public void setStatePartitioner2(KeySelector<?,?> statePartitioner)
public TypeSerializer<?> getStateKeySerializer()
public void setStateKeySerializer(TypeSerializer<?> stateKeySerializer)
public String getTransformationUID()
public String getUserHash()
public void setUserHash(String userHash)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.