StatisticsOrRecord

java.lang.Object
- org.apache.iceberg.flink.sink.shuffle.StatisticsOrRecord

All Implemented Interfaces:

java.io.Serializable
```
@Internal
public class StatisticsOrRecord
extends java.lang.Object
implements java.io.Serializable
```
The wrapper class for data statistics and record. It is the only way for data statistics operator to send global data statistics to custom partitioner to distribute data based on statistics
DataStatisticsOrRecord contains either data statistics(globally aggregated) or a record. It is sent from DataStatisticsOperator to partitioner. Once partitioner receives the data statistics, it will use that to decide the coming record should send to which writer subtask. After shuffling, a filter and mapper are required to filter out the data distribution weight, unwrap the object and extract the original record type T.

See Also:

Serialized Form

- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  boolean hasRecord()
  
  org.apache.flink.table.data.RowData record()
  
  java.lang.String toString()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

hasRecord
```
public boolean hasRecord()
```

record

public org.apache.flink.table.data.RowData record()

toString
```
public java.lang.String toString()
```
Overrides:

toString in class java.lang.Object