org.apache.beam.sdk.fn.data

Interface CloseableFnDataReceiver<T>

All Superinterfaces:

java.lang.AutoCloseable, FnDataReceiver<T>

All Known Subinterfaces:

BeamFnDataBufferingOutboundObserver<T>

All Known Implementing Classes:

BeamFnDataSizeBasedBufferingOutboundObserver, BeamFnDataTimeBasedBufferingOutboundObserver

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() .
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

Method Detail

flush

@Deprecated
void flush()
                throws java.lang.Exception

Deprecated. to be removed once splitting/checkpointing are available in SDKs and rewinding in readers.

Eagerly flushes any data that is buffered in this channel.

Throws:

java.lang.Exception

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