Package org.apache.beam.sdk.transforms
Class SimpleFunction<InputT,OutputT>
- java.lang.Object
-
- org.apache.beam.sdk.transforms.InferableFunction<InputT,OutputT>
-
- org.apache.beam.sdk.transforms.SimpleFunction<InputT,OutputT>
-
- All Implemented Interfaces:
java.io.Serializable
,HasDisplayData
,ProcessFunction<InputT,OutputT>
,SerializableFunction<InputT,OutputT>
- Direct Known Subclasses:
WithFailures.ExceptionAsMapHandler
,WithFailures.ThrowableHandler
public abstract class SimpleFunction<InputT,OutputT> extends InferableFunction<InputT,OutputT> implements SerializableFunction<InputT,OutputT>
ASerializableFunction
which is not a functional interface. Concrete subclasses allow us to infer type information, which in turn aidsCoder
inference.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SimpleFunction()
protected
SimpleFunction(SerializableFunction<InputT,OutputT> fn)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description OutputT
apply(InputT input)
Returns the result of invoking this function on the given input.static <InputT,OutputT>
SimpleFunction<InputT,OutputT>fromSerializableFunctionWithOutputType(SerializableFunction<InputT,OutputT> fn, TypeDescriptor<OutputT> outputType)
-
Methods inherited from class org.apache.beam.sdk.transforms.InferableFunction
fromProcessFunctionWithOutputType, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData
-
-
-
-
Constructor Detail
-
SimpleFunction
protected SimpleFunction()
-
SimpleFunction
protected SimpleFunction(SerializableFunction<InputT,OutputT> fn)
-
-
Method Detail
-
apply
public OutputT apply(InputT input)
Description copied from interface:ProcessFunction
Returns the result of invoking this function on the given input.- Specified by:
apply
in interfaceProcessFunction<InputT,OutputT>
- Specified by:
apply
in interfaceSerializableFunction<InputT,OutputT>
- Overrides:
apply
in classInferableFunction<InputT,OutputT>
-
fromSerializableFunctionWithOutputType
public static <InputT,OutputT> SimpleFunction<InputT,OutputT> fromSerializableFunctionWithOutputType(SerializableFunction<InputT,OutputT> fn, TypeDescriptor<OutputT> outputType)
-
-