@Internal public abstract class AbstractAvroBulkFormat<A,T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit> extends Object implements org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT>
BulkFormat
for Avro records.
NOTE: Copied from Flink.
Modifier and Type | Field and Description |
---|---|
protected org.apache.avro.Schema |
readerSchema |
Modifier | Constructor and Description |
---|---|
protected |
AbstractAvroBulkFormat(org.apache.avro.Schema readerSchema) |
Modifier and Type | Method and Description |
---|---|
protected abstract java.util.function.Function<A,T> |
createConverter() |
org.apache.flink.table.store.format.avro.AbstractAvroBulkFormat.AvroReader |
createReader(org.apache.flink.configuration.Configuration config,
SplitT split) |
protected abstract A |
createReusedAvroRecord() |
boolean |
isSplittable() |
org.apache.flink.table.store.format.avro.AbstractAvroBulkFormat.AvroReader |
restoreReader(org.apache.flink.configuration.Configuration config,
SplitT split) |
protected AbstractAvroBulkFormat(org.apache.avro.Schema readerSchema)
public org.apache.flink.table.store.format.avro.AbstractAvroBulkFormat.AvroReader createReader(org.apache.flink.configuration.Configuration config, SplitT split) throws IOException
createReader
in interface org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>
IOException
public org.apache.flink.table.store.format.avro.AbstractAvroBulkFormat.AvroReader restoreReader(org.apache.flink.configuration.Configuration config, SplitT split) throws IOException
restoreReader
in interface org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>
IOException
public boolean isSplittable()
protected abstract A createReusedAvroRecord()
protected abstract java.util.function.Function<A,T> createConverter()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.