public interface OperatorWrapper<T,R> extends Serializable
Modifier and Type | Method and Description |
---|---|
Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
org.apache.flink.api.common.typeinfo.TypeInformation<R> |
getWrappedTypeInfo(org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo) |
org.apache.flink.streaming.api.operators.StreamOperator<R> |
wrap(org.apache.flink.streaming.api.operators.StreamOperatorParameters<R> operatorParameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
<KEY> org.apache.flink.api.java.functions.KeySelector<R,KEY> |
wrapKeySelector(org.apache.flink.api.java.functions.KeySelector<T,KEY> keySelector) |
org.apache.flink.util.OutputTag<R> |
wrapOutputTag(org.apache.flink.util.OutputTag<T> outputTag) |
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<R> |
wrapStreamPartitioner(org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> streamPartitioner) |
org.apache.flink.streaming.api.operators.StreamOperator<R> wrap(org.apache.flink.streaming.api.operators.StreamOperatorParameters<R> operatorParameters, org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory)
Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass(ClassLoader classLoader, org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory)
<KEY> org.apache.flink.api.java.functions.KeySelector<R,KEY> wrapKeySelector(org.apache.flink.api.java.functions.KeySelector<T,KEY> keySelector)
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<R> wrapStreamPartitioner(org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> streamPartitioner)
org.apache.flink.util.OutputTag<R> wrapOutputTag(org.apache.flink.util.OutputTag<T> outputTag)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.