edu.iu.dsc.tws.dataset

Class DataSink<T>

java.lang.Object

edu.iu.dsc.tws.dataset.DataSink<T>

Type Parameters:

T -

public class DataSink<T>
extends java.lang.Object

A data sink

Constructor Summary

Constructors

Constructor and Description
DataSink(Config config, DataObjectImpl<T> dataSet)
DataSink(Config config, OutputWriter<T> output)

Method Summary

Modifier and Type	Method and Description
void	add(int partition, T value)
void	persist()

Methods inherited from class java.lang.Object

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

Constructor Detail

DataSink

public DataSink(Config config,
                DataObjectImpl<T> dataSet)

DataSink

public DataSink(Config config,
                OutputWriter<T> output)

Method Detail

add

public void add(int partition,
                T value)

persist

public void persist()