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