Uses of Interface
org.apache.flink.connector.file.src.reader.BulkFormat

Packages that use BulkFormat

Package	Description
org.apache.flink.connector.file.src
org.apache.flink.connector.file.src.impl
org.apache.flink.connector.file.table
org.apache.flink.connector.file.table.stream.compact
org.apache.flink.formats.avro
org.apache.flink.formats.csv
org.apache.flink.formats.parquet
org.apache.flink.orc

Uses of BulkFormat in org.apache.flink.connector.file.src

Fields in org.apache.flink.connector.file.src declared as BulkFormat

Modifier and Type	Field	Description
protected BulkFormat<T,SplitT>	AbstractFileSource.AbstractFileSourceBuilder.readerFormat

Methods in org.apache.flink.connector.file.src with parameters of type BulkFormat

Modifier and Type	Method	Description
static <T> FileSource.FileSourceBuilder<T>	FileSource.forBulkFileFormat(BulkFormat<T,FileSourceSplit> bulkFormat, Path... paths)	Builds a new FileSource using a BulkFormat to read batches of records from files.

Constructors in org.apache.flink.connector.file.src with parameters of type BulkFormat

Constructor	Description
AbstractFileSource(Path[] inputPaths, FileEnumerator.Provider fileEnumerator, FileSplitAssigner.Provider splitAssigner, BulkFormat<T,SplitT> readerFormat, ContinuousEnumerationSettings continuousEnumerationSettings)
AbstractFileSourceBuilder(Path[] inputPaths, BulkFormat<T,SplitT> readerFormat, FileEnumerator.Provider defaultFileEnumerator, FileSplitAssigner.Provider defaultSplitAssigner)

Uses of BulkFormat in org.apache.flink.connector.file.src.impl

Classes in org.apache.flink.connector.file.src.impl that implement BulkFormat

Modifier and Type	Class	Description
class	StreamFormatAdapter<T>	Adapter to turn a StreamFormat into a BulkFormat.

Constructors in org.apache.flink.connector.file.src.impl with parameters of type BulkFormat

Constructor	Description
FileSourceReader(SourceReaderContext readerContext, BulkFormat<T,SplitT> readerFormat, Configuration config)

Uses of BulkFormat in org.apache.flink.connector.file.table

Classes in org.apache.flink.connector.file.table that implement BulkFormat

Modifier and Type	Class	Description
class	DeserializationSchemaAdapter	Adapter to turn a DeserializationSchema into a BulkFormat.
class	LimitableBulkFormat<T,SplitT extends FileSourceSplit>	A BulkFormat that can limit output record number.

Methods in org.apache.flink.connector.file.table that return BulkFormat

Modifier and Type	Method	Description
static <T,SplitT extends FileSourceSplit> BulkFormat<T,SplitT>	LimitableBulkFormat.create(BulkFormat<T,SplitT> format, Long limit)

Methods in org.apache.flink.connector.file.table with parameters of type BulkFormat

Modifier and Type	Method	Description
static <T,SplitT extends FileSourceSplit> BulkFormat<T,SplitT>	LimitableBulkFormat.create(BulkFormat<T,SplitT> format, Long limit)

Constructor parameters in org.apache.flink.connector.file.table with type arguments of type BulkFormat

Constructor	Description
FileSystemTableSource(ObjectIdentifier tableIdentifier, DataType physicalRowDataType, List<String> partitionKeys, ReadableConfig tableOptions, DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat, DecodingFormat<DeserializationSchema<RowData>> deserializationFormat)

Uses of BulkFormat in org.apache.flink.connector.file.table.stream.compact

Methods in org.apache.flink.connector.file.table.stream.compact with parameters of type BulkFormat

Modifier and Type	Method	Description
static <T> CompactReader.Factory<T>	CompactBulkReader.factory(BulkFormat<T,FileSourceSplit> format)

Uses of BulkFormat in org.apache.flink.formats.avro

Classes in org.apache.flink.formats.avro that implement BulkFormat

Modifier and Type	Class	Description
class	AbstractAvroBulkFormat<A,T,SplitT extends FileSourceSplit>	Provides a BulkFormat for Avro records.

Uses of BulkFormat in org.apache.flink.formats.csv

Methods in org.apache.flink.formats.csv that return BulkFormat

Modifier and Type	Method	Description
BulkFormat<RowData,FileSourceSplit>	CsvFileFormatFactory.CsvBulkDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)

Uses of BulkFormat in org.apache.flink.formats.parquet

Classes in org.apache.flink.formats.parquet that implement BulkFormat

Modifier and Type	Class	Description
class	ParquetColumnarRowInputFormat<SplitT extends FileSourceSplit>	A ParquetVectorizedInputFormat to provide RowData iterator.
class	ParquetVectorizedInputFormat<T,SplitT extends FileSourceSplit>	Parquet BulkFormat that reads data from the file to VectorizedColumnBatch in vectorized mode.

Methods in org.apache.flink.formats.parquet that return BulkFormat

Modifier and Type	Method	Description
BulkFormat<RowData,FileSourceSplit>	ParquetFileFormatFactory.ParquetBulkDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context sourceContext, DataType producedDataType, int[][] projections)

Uses of BulkFormat in org.apache.flink.orc

Classes in org.apache.flink.orc that implement BulkFormat

Modifier and Type	Class	Description
class	AbstractOrcFileInputFormat<T,BatchT,SplitT extends FileSourceSplit>	The base for ORC readers for the FileSource.
class	OrcColumnarRowInputFormat<BatchT,SplitT extends FileSourceSplit>	An ORC reader that produces a stream of ColumnarRowData records.

Methods in org.apache.flink.orc that return BulkFormat

Modifier and Type	Method	Description
BulkFormat<RowData,FileSourceSplit>	OrcFileFormatFactory.OrcBulkDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context sourceContext, DataType producedDataType, int[][] projections)