@Internal public class FilterOperatorBase<T,FT extends FlatMapFunction<T,T>> extends SingleInputOperator<T,T,FT>
FlatMapFunction
input
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
FilterOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name) |
FilterOperatorBase(FT udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name) |
FilterOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<T,T> operatorInfo,
String name) |
Modifier and Type | Method and Description |
---|---|
protected List<T> |
executeOnCollections(List<T> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSemanticProperties, setInput, setInput, setInputs, setSemanticProperties
asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables
createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString
public FilterOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<T,T> operatorInfo, String name)
public FilterOperatorBase(FT udf, UnaryOperatorInformation<T,T> operatorInfo, String name)
protected List<T> executeOnCollections(List<T> inputData, RuntimeContext ctx, ExecutionConfig executionConfig) throws Exception
executeOnCollections
in class SingleInputOperator<T,T,FT extends FlatMapFunction<T,T>>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.