@Internal public class StreamNode extends Object implements Serializable
Constructor and Description |
---|
StreamNode(Integer id,
String slotSharingGroup,
String coLocationGroup,
StreamOperator<?> operator,
String operatorName,
List<OutputSelector<?>> outputSelector,
Class<? extends AbstractInvokable> jobVertexClass) |
StreamNode(Integer id,
String slotSharingGroup,
String coLocationGroup,
StreamOperatorFactory<?> operatorFactory,
String operatorName,
List<OutputSelector<?>> outputSelector,
Class<? extends AbstractInvokable> jobVertexClass) |
@VisibleForTesting public StreamNode(Integer id, @Nullable String slotSharingGroup, @Nullable String coLocationGroup, StreamOperator<?> operator, String operatorName, List<OutputSelector<?>> outputSelector, Class<? extends AbstractInvokable> jobVertexClass)
public StreamNode(Integer id, @Nullable String slotSharingGroup, @Nullable String coLocationGroup, StreamOperatorFactory<?> operatorFactory, 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 ResourceSpec getMinResources()
public ResourceSpec getPreferredResources()
public void setResources(ResourceSpec minResources, ResourceSpec preferredResources)
public long getBufferTimeout()
public void setBufferTimeout(Long bufferTimeout)
@VisibleForTesting public StreamOperator<?> getOperator()
public StreamOperatorFactory<?> getOperatorFactory()
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 OutputFormat<?> getOutputFormat()
public void setOutputFormat(OutputFormat<?> outputFormat)
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–2020 The Apache Software Foundation. All rights reserved.