@PublicEvolving public static interface StreamFormat.Reader<T> extends Closeable
|Modifier and Type||Method and Description|
Closes the reader to release all resources.
Optionally returns the current position of the reader.
Reads the next record.
@Nullable T read() throws IOException
nullwhen the input has reached its end.
void close() throws IOException
@Nullable default CheckpointedPosition getCheckpointedPosition()
The current position of the reader is the position of the next record that will be
returned in a call to
read(). This can be implemented by readers that want to
speed up recovery from a checkpoint.
top-level class comment (section "Checkpointing") for
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.