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

Interface FnDataReceiver<T>

All Known Subinterfaces:
CloseableFnDataReceiver<T>
All Known Implementing Classes:
BeamFnDataInboundObserver, DecodingFnDataReceiver
public interface FnDataReceiver<T>
A receiver of streamed data.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    accept(T input)