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:

Serializable, HasDisplayData, ProcessFunction<InputT,OutputT>, SerializableFunction<InputT,OutputT>

Direct Known Subclasses:

BeamRowToBigtableMutation.ToBigtableRowFn, BeamSetOperatorsTransforms.BeamSqlRow2KvFn, BigtableWriteSchemaTransformProvider.GetMutationsFromBeamRow, 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	Description
protected	SimpleFunction()
protected	SimpleFunction(SerializableFunction<InputT,OutputT> fn)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleFunction

protected SimpleFunction()

SimpleFunction

protected SimpleFunction(SerializableFunction<InputT,OutputT> fn)

Method Details

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)