org.apache.flink.streaming.api.graph

Class NonChainedOutput

java.lang.Object

org.apache.flink.streaming.api.graph.NonChainedOutput

All Implemented Interfaces:

Serializable

@Internal
public class NonChainedOutput
extends Object
implements Serializable

Used by operator chain and represents a non-chained output of the corresponding stream operator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NonChainedOutput(boolean supportsUnalignedCheckpoints, int sourceNodeId, int consumerParallelism, int consumerMaxParallelism, long bufferTimeout, boolean isPersistentDataSet, IntermediateDataSetID dataSetId, OutputTag<?> outputTag, StreamPartitioner<?> partitioner, ResultPartitionType partitionType)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getBufferTimeout()
int	getConsumerMaxParallelism()
int	getConsumerParallelism()
IntermediateDataSetID	getDataSetId()
OutputTag<?>	getOutputTag()
StreamPartitioner<?>	getPartitioner()
ResultPartitionType	getPartitionType()
IntermediateDataSetID	getPersistentDataSetId()
int	getSourceNodeId()
int	hashCode()
void	setPartitioner(StreamPartitioner<?> partitioner)
void	setPartitionType(ResultPartitionType partitionType)
boolean	supportsUnalignedCheckpoints()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NonChainedOutput

public NonChainedOutput(boolean supportsUnalignedCheckpoints,
                        int sourceNodeId,
                        int consumerParallelism,
                        int consumerMaxParallelism,
                        long bufferTimeout,
                        boolean isPersistentDataSet,
                        IntermediateDataSetID dataSetId,
                        OutputTag<?> outputTag,
                        StreamPartitioner<?> partitioner,
                        ResultPartitionType partitionType)

Method Detail

supportsUnalignedCheckpoints

public boolean supportsUnalignedCheckpoints()

getSourceNodeId

public int getSourceNodeId()

getConsumerParallelism

public int getConsumerParallelism()

getConsumerMaxParallelism

public int getConsumerMaxParallelism()

getBufferTimeout

public long getBufferTimeout()

getDataSetId

public IntermediateDataSetID getDataSetId()

getPersistentDataSetId

public IntermediateDataSetID getPersistentDataSetId()

getOutputTag

public OutputTag<?> getOutputTag()

setPartitioner

public void setPartitioner(StreamPartitioner<?> partitioner)

setPartitionType

public void setPartitionType(ResultPartitionType partitionType)

getPartitioner

public StreamPartitioner<?> getPartitioner()

getPartitionType

public ResultPartitionType getPartitionType()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object