Uses of Class
org.apache.flink.cdc.composer.definition.TransformDef
-
Packages that use TransformDef Package Description org.apache.flink.cdc.composer.definition org.apache.flink.cdc.composer.flink.translator -
-
Uses of TransformDef in org.apache.flink.cdc.composer.definition
Methods in org.apache.flink.cdc.composer.definition that return types with arguments of type TransformDef Modifier and Type Method Description List<TransformDef>PipelineDef. getTransforms() -
Uses of TransformDef in org.apache.flink.cdc.composer.flink.translator
Method parameters in org.apache.flink.cdc.composer.flink.translator with type arguments of type TransformDef Modifier and Type Method Description org.apache.flink.streaming.api.datastream.DataStream<Event>TransformTranslator. translateAsyncPostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, java.time.Duration asyncTransformTimeout, int asyncTransformCapacity, int asyncTransformWorkerThreads, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)org.apache.flink.streaming.api.datastream.DataStream<Event>TransformTranslator. translatePostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)org.apache.flink.streaming.api.datastream.DataStream<Event>TransformTranslator. translatePreTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns)
-