org.apache.flink.formats.avro

Class AbstractAvroBulkFormat<A,T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>

java.lang.Object

org.apache.flink.formats.avro.AbstractAvroBulkFormat<A,T,SplitT>

All Implemented Interfaces:

Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT>

@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>

Provides a BulkFormat for Avro records.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.connector.file.src.reader.BulkFormat

org.apache.flink.connector.file.src.reader.BulkFormat.Reader<T>, org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.avro.Schema	readerSchema

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractAvroBulkFormat(org.apache.avro.Schema readerSchema)

Method Summary

Modifier and Type	Method and Description
protected abstract java.util.function.Function<A,T>	createConverter()
org.apache.flink.formats.avro.AbstractAvroBulkFormat.AvroReader	createReader(org.apache.flink.configuration.Configuration config, SplitT split)
protected abstract A	createReusedAvroRecord()
boolean	isSplittable()
org.apache.flink.formats.avro.AbstractAvroBulkFormat.AvroReader	restoreReader(org.apache.flink.configuration.Configuration config, SplitT split)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.connector.file.src.reader.BulkFormat

getProducedType

Field Detail

readerSchema

protected final org.apache.avro.Schema readerSchema

Constructor Detail

AbstractAvroBulkFormat

protected AbstractAvroBulkFormat(org.apache.avro.Schema readerSchema)

Method Detail

createReader

public org.apache.flink.formats.avro.AbstractAvroBulkFormat.AvroReader createReader(org.apache.flink.configuration.Configuration config,
                                                                                    SplitT split)
                                                                             throws IOException

Specified by:

createReader in interface org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>

Throws:

IOException

restoreReader

public org.apache.flink.formats.avro.AbstractAvroBulkFormat.AvroReader restoreReader(org.apache.flink.configuration.Configuration config,
                                                                                     SplitT split)
                                                                              throws IOException

Specified by:

restoreReader in interface org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>

Throws:

IOException

isSplittable

public boolean isSplittable()

Specified by:

isSplittable in interface org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>

createReusedAvroRecord

protected abstract A createReusedAvroRecord()

createConverter

protected abstract java.util.function.Function<A,T> createConverter()