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.connectors.hive
org.apache.flink.connectors.hive.read
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 and 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 and 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 and 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 and Description
class	FileRecordFormatAdapter<T> Deprecated. Please use StreamFormatAdapter instead.
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 and 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 and 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 and 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 and 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 and 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 and Description
static <T> CompactReader.Factory<T>	CompactBulkReader.factory(BulkFormat<T,FileSourceSplit> format)

Uses of BulkFormat in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive that return BulkFormat

Modifier and Type	Method and Description
protected BulkFormat<RowData,HiveSourceSplit>	HiveSourceBuilder.createDefaultBulkFormat()

Methods in org.apache.flink.connectors.hive with parameters of type BulkFormat

Modifier and Type	Method and Description
<T> HiveSource<T>	HiveSourceBuilder.buildWithBulkFormat(BulkFormat<T,HiveSourceSplit> bulkFormat) Builds HiveSource with custom BulkFormat.

Uses of BulkFormat in org.apache.flink.connectors.hive.read

Classes in org.apache.flink.connectors.hive.read that implement BulkFormat

Modifier and Type	Class and Description
class	HiveBulkFormatAdapter Deprecated. Please use HiveInputFormat.
class	HiveInputFormat A BulkFormat implementation for HiveSource.

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

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

Modifier and Type	Class and 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 and 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 and 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 and 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 and Description
class	AbstractOrcFileInputFormat<T,BatchT,SplitT extends FileSourceSplit> The base for ORC readers for the FileSource.
class	OrcColumnarRowFileInputFormat<BatchT,SplitT extends FileSourceSplit> Deprecated. Please use OrcColumnarRowInputFormat.
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 and Description
BulkFormat<RowData,FileSourceSplit>	OrcFileFormatFactory.OrcBulkDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context sourceContext, DataType producedDataType, int[][] projections)