@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 void setManagedMemoryWeight(int managedMemoryWeight)
public int getManagedMemoryWeight()
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.