Package org.apache.beam.sdk.transforms

Interface SerializableFunction<InputT,OutputT>

Type Parameters:
InputT - input value type
OutputT - output value type
All Superinterfaces:
ProcessFunction<InputT,OutputT>, Serializable
All Known Subinterfaces:
CheckStopReadingFn, ElasticsearchIO.Write.BooleanFieldValueExtractFn, ElasticsearchIO.Write.FieldValueExtractFn, KuduIO.FormatFunction<T>
All Known Implementing Classes:
AggregationQuery, BeamRowToBigtableMutation.ToBigtableRowFn, BeamSetOperatorsTransforms.BeamSqlRow2KvFn, BigtableReadSchemaTransformProvider.BigtableRowToBeamRow, BigtableWriteSchemaTransformProvider.GetMutationsFromBeamRow, CheckStopReadingFnWrapper, ExternalWrite.ParsePubsubMessageProtoAsPayloadFromWindowedValue, FindQuery, HealthcareIOErrorToTableRow, JdbcIO.DataSourceProviderFromDataSourceConfiguration, JdbcIO.PoolableDataSourceProvider, Neo4jIO.DriverProviderFromDriverConfiguration, PAssert.MatcherCheckerFn, PubsubMessages.DeserializeBytesIntoPubsubMessagePayloadOnly, PubsubMessages.ParsePayloadAsPubsubMessageProto, PubsubMessages.ParsePubsubMessageProtoAsPayload, SimpleFunction, SnowflakeIO.DataSourceProviderFromDataSourceConfiguration, SqsReadSchemaTransformProvider.SqsMessageToBeamRow, WithFailures.ExceptionAsMapHandler, WithFailures.ThrowableHandler, 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>, 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
    Description
    OutputT
    apply(InputT input)
    Returns the result of invoking this function on the given input.