Package | Description |
---|---|
org.apache.flink.connector.file.src.impl | |
org.apache.flink.connector.kafka.source.reader |
Modifier and Type | Class and Description |
---|---|
class |
FileSourceReader<T,SplitT extends FileSourceSplit>
A
SourceReader that read records from FileSourceSplit . |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSourceReader<T>
The source reader for Kafka partitions.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.