org.apache.beam.sdk.transforms

Interface SerializableFunction<InputT,OutputT>

Type Parameters:

InputT - input value type

OutputT - output value type

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

ElasticsearchIO.Write.FieldValueExtractFn

All Known Implementing Classes:

BeamAggregationTransforms.AggregationGroupByKeyFn, BeamAggregationTransforms.WindowTimestampFn, BeamJoinTransforms.ExtractJoinFields, BeamJoinTransforms.JoinParts2WholeRow, BeamSetOperatorsTransforms.BeamSqlRow2KvFn, PAssert.PCollectionContentsAssert.MatcherCheckerFn, SimpleFunction

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

A function that computes an output value of type OutputT from an input value of type InputT and is Serializable.

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.