org.apache.flink.table.delegation

Interface PlannerFactory

All Superinterfaces:

Factory

All Known Implementing Classes:

DefaultPlannerFactory, DelegatePlannerFactory

@Internal
public interface PlannerFactory
extends Factory

Factory that creates Planner.

This factory is used with Java's Service Provider Interfaces (SPI) for discovering. A factory is called with a set of normalized properties that describe the desired configuration. Those properties may include execution configurations such as watermark interval, max parallelism etc., table specific initialization configuration such as if the queries should be executed in batch mode.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PlannerFactory.Context Context used when creating a planner.
static class	PlannerFactory.DefaultPlannerContext Default implementation of PlannerFactory.Context.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_IDENTIFIER Factory.factoryIdentifier() for the default Planner.

Method Summary

Modifier and Type	Method and Description
Planner	create(PlannerFactory.Context context) Creates a corresponding Planner.

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

factoryIdentifier, optionalOptions, requiredOptions

Field Detail

DEFAULT_IDENTIFIER

static final String DEFAULT_IDENTIFIER

Factory.factoryIdentifier() for the default Planner.

See Also:

Constant Field Values

Method Detail

create

Planner create(PlannerFactory.Context context)

Creates a corresponding Planner.