FileRecords (Flink : Connectors : Files 2.2.0 API)

java.lang.Object
- org.apache.flink.connector.file.src.impl.FileRecords<T>

All Implemented Interfaces:

org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>
```
@Internal
public final class FileRecords<T>
extends Object
implements org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>
```
A collection of records for one file split.
This is essentially a slim wrapper around the BulkFormat.RecordIterator that only adds information about the current split, or finished splits (to keep knowledge about current split IDs out of the reader formats).

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <T> FileRecords<T>`	`finishedSplit(String splitId)`
`Set<String>`	`finishedSplits()`
`static <T> FileRecords<T>`	`forRecords(String splitId, BulkFormat.RecordIterator<T> recordsForSplit)`
`RecordAndPosition<T>`	`nextRecordFromSplit()`
`String`	`nextSplit()`
`void`	`recycle()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - nextSplit
```
@Nullable
public String nextSplit()
```
    Specified by:
    
    nextSplit in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<T>
  - nextRecordFromSplit
```
@Nullable
public RecordAndPosition<T> nextRecordFromSplit()
```
    Specified by:
    
    nextRecordFromSplit in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<T>
  - recycle
```
public void recycle()
```
    Specified by:
    
    recycle in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<T>
  - finishedSplits
```
public Set<String> finishedSplits()
```
    Specified by:
    
    finishedSplits in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<T>
  - forRecords
```
public static <T> FileRecords<T> forRecords(String splitId,
                                            BulkFormat.RecordIterator<T> recordsForSplit)
```
  - finishedSplit
```
public static <T> FileRecords<T> finishedSplit(String splitId)
```