org.apache.flink.table.planner.delegation

Interface DialectFactory

All Superinterfaces:

Factory

All Known Implementing Classes:

DefaultDialectFactory, HiveDialectFactory

@Internal
public interface DialectFactory
extends Factory

Factory that creates Parser and ExtendedOperationExecutor.

The Factory.factoryIdentifier() is identified by matching it against TableConfigOptions.TABLE_SQL_DIALECT.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	DialectFactory.Context Context provided when a parser is created.
static class	DialectFactory.DefaultParserContext Default implementation for DialectFactory.Context.
static class	DialectFactory.EmptyOperationExecutor Default implementation for ExtendedOperationExecutor that doesn't extend any operation behavior but forward all operations to the Flink planner.

Method Summary

Modifier and Type	Method and Description
Parser	create(DialectFactory.Context context) Creates a new parser.
default ExtendedOperationExecutor	createExtendedOperationExecutor(DialectFactory.Context context)

Methods inherited from interface org.apache.flink.table.factories.Factory

factoryIdentifier, optionalOptions, requiredOptions

Method Detail

create

Parser create(DialectFactory.Context context)

Creates a new parser.

createExtendedOperationExecutor

default ExtendedOperationExecutor createExtendedOperationExecutor(DialectFactory.Context context)