Interface PlannerFactory
-
- All Superinterfaces:
Factory
- All Known Implementing Classes:
DefaultPlannerFactory
,DelegatePlannerFactory
@Internal public interface PlannerFactory extends Factory
Factory that createsPlanner
.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 Description static interface
PlannerFactory.Context
Context used when creating a planner.static class
PlannerFactory.DefaultPlannerContext
Default implementation ofPlannerFactory.Context
.
-
Field Summary
Fields Modifier and Type Field Description static String
DEFAULT_IDENTIFIER
Factory.factoryIdentifier()
for the defaultPlanner
.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Planner
create(PlannerFactory.Context context)
Creates a correspondingPlanner
.-
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 defaultPlanner
.- See Also:
- Constant Field Values
-
-
Method Detail
-
create
Planner create(PlannerFactory.Context context)
Creates a correspondingPlanner
.
-
-