org.apache.beam.sdk.fn.data

Interface CloseableFnDataReceiver<T>

All Superinterfaces:

java.lang.AutoCloseable, FnDataReceiver<T>

All Known Implementing Classes:

BeamFnDataBufferingOutboundObserver

public interface CloseableFnDataReceiver<T>
extends FnDataReceiver<T>, java.lang.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 and Description
void	close() .

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

accept

Method Detail

close

void close()
    throws java.lang.Exception

.

Does nothing if this CloseableFnDataReceiver is already closed.

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception