Uses of Class
org.kepler.spark.operator.Operator

Packages that use Operator

Package	Description
org.kepler.spark.director
org.kepler.spark.operator

Uses of Operator in org.kepler.spark.director

Methods in org.kepler.spark.director with parameters of type Operator

Modifier and Type	Method and Description
protected void	SparkEngine._addSubModelToContract(SingleInputPatternActor pactor, Operator contract) Write the sub-workflow of a SingleInputPatternActor either to a parameter in the Spark job configuration or to a file.

Uses of Operator in org.kepler.spark.operator

Subclasses of Operator in org.kepler.spark.operator

Modifier and Type	Class and Description
class	CoGroupOperator An operator for cogroup.
class	CrossOperator An operator for cross/cartesian/all-pairs.
class	DataSink An operator for writing data.
class	DataSource An operator for reading data.
class	FileDataSink A data sink that writes to files.
class	FileDataSource A data sink that reads from files.
class	JoinOperator An operator for match/join.
class	MapOperator An operator for map.
class	NullSink A data sink that does not write to anything.
class	ReduceOperator An operator for reduce.
class	TokenSink A data sink that writes to Ptolemy tokens.
class	TokenSource An data source that reads Ptolemy tokens.

Methods in org.kepler.spark.operator with parameters of type Operator

Modifier and Type	Method and Description
void	Operator.setInput(int index, Operator output) Set the input operator at an index.
void	Operator.setInput(Operator output) Set the (first) input operator.