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>, java.io.Serializable
    All Known Implementing Classes:
    PAssert.MatcherCheckerFn, SimpleFunction, WithFailures.ExceptionAsMapHandler, WithFailures.ThrowableHandler
    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.