org.apache.beam.sdk.transforms

Interface SerializableFunction<InputT,OutputT>

Type Parameters:

InputT - input value type

OutputT - output value type

All Superinterfaces:

ProcessFunction<InputT,OutputT>, java.io.Serializable

All Known Subinterfaces:

ElasticsearchIO.Write.FieldValueExtractFn

All Known Implementing Classes:

AggregationQuery, BeamJoinTransforms.ExtractJoinFields, BeamJoinTransforms.JoinParts2WholeRow, BeamSetOperatorsTransforms.BeamSqlRow2KvFn, FindQuery, JdbcIO.DataSourceProviderFromDataSourceConfiguration, JdbcIO.PoolableDataSourceProvider, PAssert.PCollectionContentsAssert.MatcherCheckerFn, SimpleFunction, WithFailures.ExceptionAsMapHandler, WordCount.FormatAsTextFn

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface SerializableFunction<InputT,OutputT>
extends ProcessFunction<InputT,OutputT>, java.io.Serializable

A function that computes an output value of type OutputT from an input value of type InputT, is Serializable, and does not allow checked exceptions to be declared.

To allow checked exceptions, implement the superinterface ProcessFunction instead. To allow more robust Coder inference, see InferableFunction.

Method Summary

Modifier and Type	Method and Description
OutputT	apply(InputT input) Returns the result of invoking this function on the given input.

Method Detail

apply

OutputT apply(InputT input)

Returns the result of invoking this function on the given input.

Specified by:

apply in interface ProcessFunction<InputT,OutputT>