public class FieldStatsCollector extends Object
Constructor and Description |
---|
FieldStatsCollector(org.apache.flink.table.types.logical.RowType rowType) |
Modifier and Type | Method and Description |
---|---|
void |
collect(org.apache.flink.table.data.RowData row)
Update the statistics with a new row data.
|
FieldStats[] |
extract() |
public FieldStatsCollector(org.apache.flink.table.types.logical.RowType rowType)
public void collect(org.apache.flink.table.data.RowData row)
IMPORTANT: Fields of this row should NOT be reused, as they're directly stored in the collector.
public FieldStats[] extract()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.