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

Class Sink<T>

java.lang.Object

com.google.cloud.dataflow.sdk.util.common.worker.Sink<T>

Type Parameters:

T - the type of the elements written to the sink

Direct Known Subclasses:

AvroByteSink, AvroSink, ShuffleSink, TextSink

public abstract class Sink<T>
extends Object

Abstract base class for Sinks.

A Sink is written to by getting a SinkWriter and adding values to it.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Sink.SinkWriter<ElemT> Writes to a Sink.

Constructor Summary

Constructors

Constructor and Description
Sink()

Method Summary

Modifier and Type	Method and Description
boolean	supportsRestart() Returns whether this Sink can be restarted.
abstract Sink.SinkWriter<T>	writer() Returns a Writer that allows writing to this Sink.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Sink

public Sink()

Method Detail

writer

public abstract Sink.SinkWriter<T> writer()
                                   throws IOException

Returns a Writer that allows writing to this Sink.

Throws:

IOException

supportsRestart

public boolean supportsRestart()

Returns whether this Sink can be restarted.