public class ValueCountRowDataRecordIterator extends ResetRowKindRecordIterator
Constructor and Description |
---|
ValueCountRowDataRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.data.RowData |
next()
Gets the next record from the iterator.
|
nextKeyValue, releaseBatch
public ValueCountRowDataRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator)
public org.apache.flink.table.data.RowData next() throws IOException
RecordReader.RecordIterator
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.