org.apache.beam.sdk.io.gcp.pubsublite

Interface SerializableStatusFunction<InT,OutT>

All Superinterfaces:

java.io.Serializable

public interface SerializableStatusFunction<InT,OutT>
extends java.io.Serializable

A serializable Function that can throw a StatusException.

Method Summary

Modifier and Type	Method and Description
OutT	apply(InT input)

Method Detail

apply

OutT apply(InT input)
    throws StatusException

Throws:

StatusException