Uses of Class
org.apache.flink.cdc.common.schema.Selectors
-
Packages that use Selectors Package Description org.apache.flink.cdc.common.schema org.apache.flink.cdc.connectors.kafka.utils org.apache.flink.cdc.runtime.operators.transform -
-
Uses of Selectors in org.apache.flink.cdc.common.schema
Methods in org.apache.flink.cdc.common.schema that return Selectors Modifier and Type Method Description SelectorsSelectors.SelectorsBuilder. build() -
Uses of Selectors in org.apache.flink.cdc.connectors.kafka.utils
Methods in org.apache.flink.cdc.connectors.kafka.utils that return types with arguments of type Selectors Modifier and Type Method Description static Map<Selectors,String>KafkaSinkUtils. parseSelectorsToTopicMap(String mappingRuleString)Parse the mapping text to a map from Selectors to Kafka Topic name. -
Uses of Selectors in org.apache.flink.cdc.runtime.operators.transform
Methods in org.apache.flink.cdc.runtime.operators.transform that return Selectors Modifier and Type Method Description SelectorsPostTransformer. getSelectors()SelectorsPreTransformer. getSelectors()Constructors in org.apache.flink.cdc.runtime.operators.transform with parameters of type Selectors Constructor Description PostTransformer(Selectors selectors, TransformProjection projection, TransformFilter filter, PostTransformConverter postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)PreTransformer(Selectors selectors, TransformProjection projection, TransformFilter filter)
-