public class DataFileSink<T> extends BaseCompute<T> implements Collector
Constructor and Description |
---|
DataFileSink() |
Modifier and Type | Method and Description |
---|---|
boolean |
execute(IMessage message)
This method add the received message from the Data File Object into the data objects.
|
DataPartition<java.lang.Object> |
get()
get the collected valued
|
void |
prepare(Config cfg,
TaskContext context)
Prepare the task to be executed
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get, getCollectibleNames
endExecute
public boolean execute(IMessage message)
public void prepare(Config cfg, TaskContext context)
INode
public DataPartition<java.lang.Object> get()
Collector