Package | Description |
---|---|
org.apache.flink.connector.file.src.reader |
Modifier and Type | Class and Description |
---|---|
static class |
TextLineFormat.Reader
The actual reader for the
TextLineFormat . |
Modifier and Type | Method and Description |
---|---|
abstract StreamFormat.Reader<T> |
SimpleStreamFormat.createReader(Configuration config,
FSDataInputStream stream)
Creates a new reader.
|
StreamFormat.Reader<T> |
StreamFormat.createReader(Configuration config,
FSDataInputStream stream,
long fileLen,
long splitEnd)
Creates a new reader to read in this format.
|
StreamFormat.Reader<T> |
SimpleStreamFormat.createReader(Configuration config,
FSDataInputStream stream,
long fileLen,
long splitEnd) |
StreamFormat.Reader<T> |
StreamFormat.restoreReader(Configuration config,
FSDataInputStream stream,
long restoredOffset,
long fileLen,
long splitEnd)
Restores a reader from a checkpointed position.
|
StreamFormat.Reader<T> |
SimpleStreamFormat.restoreReader(Configuration config,
FSDataInputStream stream,
long restoredOffset,
long fileLen,
long splitEnd) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.