com.google.cloud.dataflow.sdk.util.common.worker

Interface Sink.SinkWriter<ElemT>

All Superinterfaces:

AutoCloseable

Enclosing class:

Sink<T>

public static interface Sink.SinkWriter<ElemT>
extends AutoCloseable

Writes to a Sink.

Method Summary

Modifier and Type	Method and Description
long	add(ElemT value) Adds a value to the sink.
void	close()

Method Detail

add

long add(ElemT value)
  throws IOException

Adds a value to the sink. Returns the size in bytes of the data written.

Throws:

IOException

close

void close()
    throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException