public interface BlockingResultInfo extends IntermediateResultInfo
Modifier and Type | Method and Description |
---|---|
long |
getNumBytesProduced()
Return the num of bytes produced(numBytesProduced) by the producer.
|
long |
getNumBytesProduced(IndexRange partitionIndexRange,
IndexRange subpartitionIndexRange)
Return the aggregated num of bytes according to the index range for partition and
subpartition.
|
void |
recordPartitionInfo(int partitionIndex,
ResultPartitionBytes partitionBytes)
Record the information of the result partition.
|
void |
resetPartitionInfo(int partitionIndex)
Reset the information of the result partition.
|
getNumPartitions, getNumSubpartitions, getResultId, isBroadcast, isPointwise
long getNumBytesProduced()
The difference between numBytesProduced and numBytesOut : numBytesProduced represents the number of bytes actually produced, and numBytesOut represents the number of bytes sent to downstream tasks. In unicast scenarios, these two values should be equal. In broadcast scenarios, numBytesOut should be (N * numBytesProduced), where N refers to the number of subpartitions.
long getNumBytesProduced(IndexRange partitionIndexRange, IndexRange subpartitionIndexRange)
partitionIndexRange
- range of the index of the consumed partition.subpartitionIndexRange
- range of the index of the consumed subpartition.void recordPartitionInfo(int partitionIndex, ResultPartitionBytes partitionBytes)
partitionIndex
- the intermediate result partition indexpartitionBytes
- the ResultPartitionBytes
of the partitionvoid resetPartitionInfo(int partitionIndex)
partitionIndex
- the intermediate result partition indexCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.