Package org.apache.beam.sdk.fn.data

Interface CloseableFnDataReceiver<T>

All Superinterfaces:
AutoCloseable, FnDataReceiver<T>
All Known Implementing Classes:
BeamFnDataInboundObserver
public interface CloseableFnDataReceiver<T> extends FnDataReceiver<T>, AutoCloseable
A receiver of streamed data that can be closed.

The close method for a CloseableFnDataReceiver must be idempotent.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    .
    void
    flush()
    Deprecated.
    to be removed once splitting/checkpointing are available in SDKs and rewinding in readers.

    Methods inherited from interface org.apache.beam.sdk.fn.data.FnDataReceiver

    accept