Uses of Class
org.apache.flink.cdc.composer.definition.RouteDef
-
Packages that use RouteDef Package Description org.apache.flink.cdc.composer.definition org.apache.flink.cdc.composer.flink.translator -
-
Uses of RouteDef in org.apache.flink.cdc.composer.definition
Methods in org.apache.flink.cdc.composer.definition that return types with arguments of type RouteDef Modifier and Type Method Description List<RouteDef>PipelineDef. getRoute()Constructor parameters in org.apache.flink.cdc.composer.definition with type arguments of type RouteDef Constructor Description PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, List<ModelDef> models, Configuration config)PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, Configuration config) -
Uses of RouteDef in org.apache.flink.cdc.composer.flink.translator
Method parameters in org.apache.flink.cdc.composer.flink.translator with type arguments of type RouteDef 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)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)org.apache.flink.streaming.api.datastream.DataStream<Event>SchemaOperatorTranslator. translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes)
-