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:

BeamRowToBigtableMutation.ToBigtableRowFn, BeamSetOperatorsTransforms.BeamSqlRow2KvFn, WithFailures.ExceptionAsMapHandler, WithFailures.ThrowableHandler, WordCount.FormatAsTextFn

public abstract class SimpleFunction<InputT,OutputT>
extends InferableFunction<InputT,OutputT>
implements SerializableFunction<InputT,OutputT>

A SerializableFunction which is not a functional interface. Concrete subclasses allow us to infer type information, which in turn aids Coder inference.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleFunction()
protected	SimpleFunction(SerializableFunction<InputT,OutputT> fn)

Method Summary

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface ProcessFunction<InputT,OutputT>

Specified by:

apply in interface SerializableFunction<InputT,OutputT>

Overrides:

apply in class InferableFunction<InputT,OutputT>

fromSerializableFunctionWithOutputType

public static <InputT,OutputT> SimpleFunction<InputT,OutputT> fromSerializableFunctionWithOutputType(SerializableFunction<InputT,OutputT> fn,
                                                                                                     TypeDescriptor<OutputT> outputType)