org.apache.beam.sdk.fn.data

Interface FnDataReceiver<T>

All Known Subinterfaces:

BeamFnDataBufferingOutboundObserver<T>, CloseableFnDataReceiver<T>

All Known Implementing Classes:

BeamFnDataSizeBasedBufferingOutboundObserver, BeamFnDataTimeBasedBufferingOutboundObserver

public interface FnDataReceiver<T>

A receiver of streamed data.

Method Summary

Modifier and Type	Method and Description
void	accept(T input)

Method Detail

accept

void accept(T input)
     throws java.lang.Exception

Throws:

java.lang.Exception