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