Uses of Package
org.apache.wayang.basic.operators

Packages that use org.apache.wayang.basic.operators

Package	Description
org.apache.wayang.basic.operators
org.apache.wayang.flink.operators
org.apache.wayang.genericjdbc.operators
org.apache.wayang.giraph.operators
org.apache.wayang.java.operators
org.apache.wayang.java.operators.graph
org.apache.wayang.jdbc.operators
org.apache.wayang.ml4all.abstraction.api
org.apache.wayang.ml4all.algorithms.sgd
org.apache.wayang.postgres.operators
org.apache.wayang.spark.operators
org.apache.wayang.spark.operators.ml
org.apache.wayang.sqlite3.operators
org.apache.wayang.tensorflow.operators

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.basic.operators

Class	Description
CartesianOperator	This operator returns the cartesian product of elements of input datasets.
CoGroupOperator	This operator groups both inputs by some key and then matches groups with the same key.
CollectionSource	This source takes as input a Java Collection.
CountOperator	This operator returns the count of elements in this stream.
DecisionTreeClassificationOperator
DistinctOperator	This operator returns the distinct elements in this dataset.
DLTrainingOperator
DLTrainingOperator.Option
DoWhileOperator	This operator has three inputs and two outputs.
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
FlatMapOperator	A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.
GlobalMaterializedGroupOperator	This operator groups the elements of a data set into a single data quantum.
GlobalReduceOperator	This operator groups the elements of a data set and aggregates the groups.
GroupByOperator	This is the auxiliary GroupBy operator, i.e., it behaves differently depending on its context.
IntersectOperator	This operator returns the set intersection of elements of input datasets.
JoinOperator	This operator returns the cartesian product of elements of input datasets.
KafkaTopicSink	This UnarySink writes all incoming data quanta to a single Kafka topic.
KafkaTopicSource	This source reads messages from a Kafka topic and outputs the messages as data units.
KMeansOperator
LinearRegressionOperator
LocalCallbackSink	This sink executes a callback on each received data unit into a Java Collection.
LoopOperator	This operator has three inputs and three outputs.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
MapPartitionsOperator	This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.
MaterializedGroupByOperator	This operator collocates the data units in a data set w.r.t. a key function.
ModelTransformOperator	Deprecated.
ObjectFileSink	This UnarySink writes all incoming data quanta to a Object file.
ObjectFileSource	This source reads a text file and outputs the lines as data units.
PageRankOperator	Operator for the PageRank algorithm.
PredictOperator
PyWayangReduceByOperator
ReduceByOperator	This operator groups the elements of a data set and aggregates the groups.
ReduceOperator	This operator is context dependent: after a GroupByOperator, it is meant to be a ReduceByOperator; otherwise, it is a GlobalReduceOperator.
RepeatOperator	This Operator repeats a certain subplan of Operators for a given number of times.
SampleOperator	A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.
SampleOperator.Methods
SortOperator	This operator sorts the elements in this dataset.
TableSource	UnarySource that provides the tuples from a database table.
TextFileSink	This UnarySink writes all incoming data quanta to a text file.
TextFileSource	This source reads a text file and outputs the lines as data units.
UnionAllOperator	This Operator creates the union (bag semantics) of two .
ZipWithIdOperator	This operators attaches a unique ID to each input data quantum.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.flink.operators

Class	Description
CartesianOperator	This operator returns the cartesian product of elements of input datasets.
CoGroupOperator	This operator groups both inputs by some key and then matches groups with the same key.
CollectionSource	This source takes as input a Java Collection.
CountOperator	This operator returns the count of elements in this stream.
DistinctOperator	This operator returns the distinct elements in this dataset.
DoWhileOperator	This operator has three inputs and two outputs.
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
FlatMapOperator	A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.
GlobalMaterializedGroupOperator	This operator groups the elements of a data set into a single data quantum.
GlobalReduceOperator	This operator groups the elements of a data set and aggregates the groups.
GroupByOperator	This is the auxiliary GroupBy operator, i.e., it behaves differently depending on its context.
IntersectOperator	This operator returns the set intersection of elements of input datasets.
JoinOperator	This operator returns the cartesian product of elements of input datasets.
LocalCallbackSink	This sink executes a callback on each received data unit into a Java Collection.
LoopOperator	This operator has three inputs and three outputs.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
MapPartitionsOperator	This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.
MaterializedGroupByOperator	This operator collocates the data units in a data set w.r.t. a key function.
ObjectFileSink	This UnarySink writes all incoming data quanta to a Object file.
ObjectFileSource	This source reads a text file and outputs the lines as data units.
PageRankOperator	Operator for the PageRank algorithm.
ReduceByOperator	This operator groups the elements of a data set and aggregates the groups.
RepeatOperator	This Operator repeats a certain subplan of Operators for a given number of times.
SampleOperator	A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.
SortOperator	This operator sorts the elements in this dataset.
TextFileSink	This UnarySink writes all incoming data quanta to a text file.
TextFileSource	This source reads a text file and outputs the lines as data units.
UnionAllOperator	This Operator creates the union (bag semantics) of two .
ZipWithIdOperator	This operators attaches a unique ID to each input data quantum.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.genericjdbc.operators

Class	Description
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
TableSource	UnarySource that provides the tuples from a database table.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.giraph.operators

Class	Description
PageRankOperator	Operator for the PageRank algorithm.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.java.operators

Class	Description
CartesianOperator	This operator returns the cartesian product of elements of input datasets.
CoGroupOperator	This operator groups both inputs by some key and then matches groups with the same key.
CollectionSource	This source takes as input a Java Collection.
CountOperator	This operator returns the count of elements in this stream.
DistinctOperator	This operator returns the distinct elements in this dataset.
DoWhileOperator	This operator has three inputs and two outputs.
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
FlatMapOperator	A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.
GlobalMaterializedGroupOperator	This operator groups the elements of a data set into a single data quantum.
GlobalReduceOperator	This operator groups the elements of a data set and aggregates the groups.
IntersectOperator	This operator returns the set intersection of elements of input datasets.
JoinOperator	This operator returns the cartesian product of elements of input datasets.
KafkaTopicSink	This UnarySink writes all incoming data quanta to a single Kafka topic.
KafkaTopicSource	This source reads messages from a Kafka topic and outputs the messages as data units.
LocalCallbackSink	This sink executes a callback on each received data unit into a Java Collection.
LoopOperator	This operator has three inputs and three outputs.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
MapPartitionsOperator	This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.
MaterializedGroupByOperator	This operator collocates the data units in a data set w.r.t. a key function.
ObjectFileSink	This UnarySink writes all incoming data quanta to a Object file.
ObjectFileSource	This source reads a text file and outputs the lines as data units.
ReduceByOperator	This operator groups the elements of a data set and aggregates the groups.
RepeatOperator	This Operator repeats a certain subplan of Operators for a given number of times.
SampleOperator	A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.
SortOperator	This operator sorts the elements in this dataset.
TextFileSink	This UnarySink writes all incoming data quanta to a text file.
TextFileSource	This source reads a text file and outputs the lines as data units.
UnionAllOperator	This Operator creates the union (bag semantics) of two .

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.java.operators.graph

Class	Description
PageRankOperator	Operator for the PageRank algorithm.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.jdbc.operators

Class	Description
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
JoinOperator	This operator returns the cartesian product of elements of input datasets.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
TableSource	UnarySource that provides the tuples from a database table.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.ml4all.abstraction.api

Class	Description
SampleOperator.Methods

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.ml4all.algorithms.sgd

Class	Description
SampleOperator.Methods

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.postgres.operators

Class	Description
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
JoinOperator	This operator returns the cartesian product of elements of input datasets.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
TableSource	UnarySource that provides the tuples from a database table.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.spark.operators

Class	Description
CartesianOperator	This operator returns the cartesian product of elements of input datasets.
CoGroupOperator	This operator groups both inputs by some key and then matches groups with the same key.
CollectionSource	This source takes as input a Java Collection.
CountOperator	This operator returns the count of elements in this stream.
DistinctOperator	This operator returns the distinct elements in this dataset.
DoWhileOperator	This operator has three inputs and two outputs.
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
FlatMapOperator	A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.
GlobalMaterializedGroupOperator	This operator groups the elements of a data set into a single data quantum.
GlobalReduceOperator	This operator groups the elements of a data set and aggregates the groups.
IntersectOperator	This operator returns the set intersection of elements of input datasets.
JoinOperator	This operator returns the cartesian product of elements of input datasets.
KafkaTopicSink	This UnarySink writes all incoming data quanta to a single Kafka topic.
KafkaTopicSource	This source reads messages from a Kafka topic and outputs the messages as data units.
LocalCallbackSink	This sink executes a callback on each received data unit into a Java Collection.
LoopOperator	This operator has three inputs and three outputs.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
MapPartitionsOperator	This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.
MaterializedGroupByOperator	This operator collocates the data units in a data set w.r.t. a key function.
ObjectFileSink	This UnarySink writes all incoming data quanta to a Object file.
ObjectFileSource	This source reads a text file and outputs the lines as data units.
ReduceByOperator	This operator groups the elements of a data set and aggregates the groups.
RepeatOperator	This Operator repeats a certain subplan of Operators for a given number of times.
SampleOperator	A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.
SortOperator	This operator sorts the elements in this dataset.
TextFileSink	This UnarySink writes all incoming data quanta to a text file.
TextFileSource	This source reads a text file and outputs the lines as data units.
UnionAllOperator	This Operator creates the union (bag semantics) of two .
ZipWithIdOperator	This operators attaches a unique ID to each input data quantum.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.spark.operators.ml

Class	Description
DecisionTreeClassificationOperator
KMeansOperator
LinearRegressionOperator
ModelTransformOperator	Deprecated.
PredictOperator

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.sqlite3.operators

Class	Description
FilterOperator	This operator returns a new dataset after filtering by applying predicateDescriptor.
MapOperator	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
TableSource	UnarySource that provides the tuples from a database table.

Classes in org.apache.wayang.basic.operators used by org.apache.wayang.tensorflow.operators

Class	Description
CollectionSource	This source takes as input a Java Collection.
DLTrainingOperator
DLTrainingOperator.Option
PredictOperator