Package | Description |
---|---|
org.apache.flink.connector.file.src.reader | |
org.apache.flink.formats.csv |
Modifier and Type | Class and Description |
---|---|
static class |
TextLineInputFormat.Reader
The actual reader for the
TextLineInputFormat . |
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) |
Modifier and Type | Method and Description |
---|---|
StreamFormat.Reader<T> |
CsvReaderFormat.createReader(Configuration config,
FSDataInputStream stream) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.