org.kepler.spark.operator

Class DataSink

java.lang.Object

org.kepler.spark.operator.Operator

org.kepler.spark.operator.DataSink

Direct Known Subclasses:

FileDataSink, NullSink, TokenSink

public abstract class DataSink
extends Operator

An operator for writing data.

Author:

Daniel Crawl

Field Summary

Fields inherited from class org.kepler.spark.operator.Operator

_configuration, _inputData, _numInstances, _stub

Constructor Summary

Constructors

Constructor and Description
DataSink(int numInputs, java.lang.Object stub, java.lang.String name) Create a new DataSink.

Method Summary

Modifier and Type	Method and Description
void	writeOutput() Write the output to the file.

Methods inherited from class org.kepler.spark.operator.Operator

_getOutput, execute, getParameters, numInputs, setDegreeOfParallelism, setInput, setInput

Methods inherited from class java.lang.Object

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

Constructor Detail

DataSink

public DataSink(int numInputs,
                java.lang.Object stub,
                java.lang.String name)

Create a new DataSink.

Parameters:

numInputs - the number of input operators

stub - the stub for writing the data.

name - the name of the operator.

Method Detail

writeOutput

public void writeOutput()
                 throws java.lang.Exception

Write the output to the file.

Throws:

java.lang.Exception