Package org.apache.flink.orc

Class OrcFileFormatFactory

java.lang.Object

org.apache.flink.orc.OrcFileFormatFactory

All Implemented Interfaces:

org.apache.flink.connector.file.table.factories.BulkReaderFormatFactory, org.apache.flink.connector.file.table.factories.BulkWriterFormatFactory, org.apache.flink.table.factories.DecodingFormatFactory<org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit>>, org.apache.flink.table.factories.EncodingFormatFactory<org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData>>, org.apache.flink.table.factories.Factory, org.apache.flink.table.factories.FormatFactory

public class OrcFileFormatFactory
extends Object
implements org.apache.flink.connector.file.table.factories.BulkReaderFormatFactory, org.apache.flink.connector.file.table.factories.BulkWriterFormatFactory

Orc format factory for file system.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OrcFileFormatFactory.OrcBulkDecodingFormat	OrcBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.

Field Summary

Fields

Modifier and Type	Field	Description
static String	IDENTIFIER

Constructor Summary

Constructors

Constructor	Description
OrcFileFormatFactory()

Method Summary

Modifier and Type	Method	Description
org.apache.flink.connector.file.table.format.BulkDecodingFormat<org.apache.flink.table.data.RowData>	createDecodingFormat(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.configuration.ReadableConfig formatOptions)
org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData>>	createEncodingFormat(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.configuration.ReadableConfig formatOptions)
String	factoryIdentifier()
Set<org.apache.flink.configuration.ConfigOption<?>>	optionalOptions()
Set<org.apache.flink.configuration.ConfigOption<?>>	requiredOptions()

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.table.factories.FormatFactory

forwardOptions

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

Constructor Detail

OrcFileFormatFactory

public OrcFileFormatFactory()

Method Detail

factoryIdentifier

public String factoryIdentifier()

Specified by:

factoryIdentifier in interface org.apache.flink.table.factories.Factory

requiredOptions

public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()

Specified by:

requiredOptions in interface org.apache.flink.table.factories.Factory

optionalOptions

public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()

Specified by:

optionalOptions in interface org.apache.flink.table.factories.Factory

createDecodingFormat

public org.apache.flink.connector.file.table.format.BulkDecodingFormat<org.apache.flink.table.data.RowData> createDecodingFormat(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                                                                                                                 org.apache.flink.configuration.ReadableConfig formatOptions)

Specified by:

createDecodingFormat in interface org.apache.flink.connector.file.table.factories.BulkReaderFormatFactory

Specified by:

createDecodingFormat in interface org.apache.flink.table.factories.DecodingFormatFactory<org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit>>

createEncodingFormat

public org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData>> createEncodingFormat(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                                                                                                                                                                      org.apache.flink.configuration.ReadableConfig formatOptions)

Specified by:

createEncodingFormat in interface org.apache.flink.table.factories.EncodingFormatFactory<org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData>>