Uses of Class
org.apache.flink.cdc.common.pipeline.RouteMode

Packages that use RouteMode

Package	Description
org.apache.flink.cdc.common.pipeline
org.apache.flink.cdc.common.route
org.apache.flink.cdc.composer.definition
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.operators.schema.regular

Uses of RouteMode in org.apache.flink.cdc.common.pipeline

Fields in org.apache.flink.cdc.common.pipeline with type parameters of type RouteMode

Modifier and Type	Field	Description
static ConfigOption<RouteMode>	PipelineOptions.PIPELINE_ROUTE_MODE

Methods in org.apache.flink.cdc.common.pipeline that return RouteMode

Modifier and Type	Method	Description
static RouteMode	RouteMode.valueOf(String name)	Returns the enum constant of this type with the specified name.
static RouteMode[]	RouteMode.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Uses of RouteMode in org.apache.flink.cdc.common.route

Constructors in org.apache.flink.cdc.common.route with parameters of type RouteMode

Constructor	Description
TableIdRouter(List<RouteRule> routingRules, RouteMode routeMode)

Uses of RouteMode in org.apache.flink.cdc.composer.definition

Methods in org.apache.flink.cdc.composer.definition that return RouteMode

Modifier and Type	Method	Description
RouteMode	PipelineDef.getRouteMode()

Uses of RouteMode in org.apache.flink.cdc.composer.flink.translator

Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type RouteMode

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateDistributed(org.apache.flink.streaming.api.datastream.DataStream<PartitioningEvent> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes, RouteMode routeMode)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes, RouteMode routeMode)

Uses of RouteMode in org.apache.flink.cdc.runtime.operators.schema.common

Fields in org.apache.flink.cdc.runtime.operators.schema.common declared as RouteMode

Modifier and Type	Field	Description
protected RouteMode	SchemaRegistry.routeMode

Constructors in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type RouteMode

Constructor	Description
SchemaRegistry(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, String operatorName, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)

Uses of RouteMode in org.apache.flink.cdc.runtime.operators.schema.distributed

Constructors in org.apache.flink.cdc.runtime.operators.schema.distributed with parameters of type RouteMode

Constructor	Description
SchemaCoordinator(String operatorName, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, java.time.Duration rpcTimeout)
SchemaCoordinator(String operatorName, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorName, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, java.time.Duration rpcTimeout)
SchemaCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorName, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, String timezone)

Uses of RouteMode in org.apache.flink.cdc.runtime.operators.schema.regular

Constructors in org.apache.flink.cdc.runtime.operators.schema.regular with parameters of type RouteMode

Constructor	Description
BatchSchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, MetadataApplier metadataApplier, String timezone)
SchemaCoordinator(String operatorName, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routes, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, java.time.Duration rpcTimeout)
SchemaCoordinator(String operatorName, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, ExecutorService coordinatorExecutor, MetadataApplier metadataApplier, List<RouteRule> routes, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorName, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, java.time.Duration rpcTimeout)
SchemaCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorName, MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, java.time.Duration rpcTimeout)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut, SchemaChangeBehavior schemaChangeBehavior)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, String timezone)
SchemaOperatorFactory(MetadataApplier metadataApplier, List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeout, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode, String timezone)