Uses of Package
org.apache.wayang.basic.operators
Packages that use org.apache.wayang.basic.operators
Package
Description
-
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.api.sql.calcite.converterClassDescriptionThis operator returns the cartesian product of elements of input datasets.
-
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.basic.operatorsClassDescriptionThis source reads a blob file stored in Amazon s3 and outputs the lines as data units.This source reads a blob file stored in Azure Blob Storage and outputs the lines as data units.This operator returns the cartesian product of elements of input datasets.This operator groups both inputs by some key and then matches groups with the same key.This source takes as input a Java
Collection.This operator returns the count of elements in this stream.This operator returns the distinct elements in this dataset.This operator has three inputs and two outputs.This operator returns a new dataset after filtering by applying predicateDescriptor.A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator groups the elements of a data set into a single data quantum.This operator groups the elements of a data set and aggregates the groups.This is the auxiliary GroupBy operator, i.e., it behaves differently depending on its context.This operator returns the set intersection of elements of input datasets.This operator returns the cartesian product of elements of input datasets.ThisUnarySinkwrites all incoming data quanta to a single Kafka topic.This source reads messages from a Kafka topic and outputs the messages as data units.This sink executes a callback on each received data unit into a JavaCollection.This operator has three inputs and three outputs.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.This operator collocates the data units in a data set w.r.t. a key function.Deprecated.ThisUnarySinkwrites all incoming data quanta to a Object file.This source reads a text file and outputs the lines as data units.Operatorfor the PageRank algorithm.This source reads a parquet file and outputs the lines asRecordunits.This operator groups the elements of a data set and aggregates the groups.This operator is context dependent: after aGroupByOperator, it is meant to be aReduceByOperator; otherwise, it is aGlobalReduceOperator.A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.This operator sorts the elements in this dataset.UnarySourcethat provides the tuples from a database table.ThisUnarySinkwrites all incoming data quanta to a text file.This source reads a text file and outputs the lines as data units.ThisOperatorcreates the union (bag semantics) of two .This operators attaches a unique ID to each input data quantum. -
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.flink.operatorsClassDescriptionThis operator returns the cartesian product of elements of input datasets.This operator groups both inputs by some key and then matches groups with the same key.This source takes as input a Java
Collection.This operator returns the count of elements in this stream.This operator returns the distinct elements in this dataset.This operator has three inputs and two outputs.This operator returns a new dataset after filtering by applying predicateDescriptor.A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator groups the elements of a data set into a single data quantum.This operator groups the elements of a data set and aggregates the groups.This is the auxiliary GroupBy operator, i.e., it behaves differently depending on its context.This operator returns the set intersection of elements of input datasets.This operator returns the cartesian product of elements of input datasets.This sink executes a callback on each received data unit into a JavaCollection.This operator has three inputs and three outputs.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.This operator collocates the data units in a data set w.r.t. a key function.ThisUnarySinkwrites all incoming data quanta to a Object file.This source reads a text file and outputs the lines as data units.Operatorfor the PageRank algorithm.This operator groups the elements of a data set and aggregates the groups.A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.This operator sorts the elements in this dataset.ThisUnarySinkwrites all incoming data quanta to a text file.This source reads a text file and outputs the lines as data units.ThisOperatorcreates the union (bag semantics) of two .This operators attaches a unique ID to each input data quantum. -
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.genericjdbc.operatorsClassDescriptionThis operator returns a new dataset after filtering by applying predicateDescriptor.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
UnarySourcethat provides the tuples from a database table. -
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.giraph.operators
-
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.java.operatorsClassDescriptionThis source reads a blob file stored in Amazon s3 and outputs the lines as data units.This source reads a blob file stored in Azure Blob Storage and outputs the lines as data units.This operator returns the cartesian product of elements of input datasets.This operator groups both inputs by some key and then matches groups with the same key.This source takes as input a Java
Collection.This operator returns the count of elements in this stream.This operator returns the distinct elements in this dataset.This operator has three inputs and two outputs.This operator returns a new dataset after filtering by applying predicateDescriptor.A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator groups the elements of a data set into a single data quantum.This operator groups the elements of a data set and aggregates the groups.This operator returns the set intersection of elements of input datasets.This operator returns the cartesian product of elements of input datasets.ThisUnarySinkwrites all incoming data quanta to a single Kafka topic.This source reads messages from a Kafka topic and outputs the messages as data units.This sink executes a callback on each received data unit into a JavaCollection.This operator has three inputs and three outputs.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.This operator collocates the data units in a data set w.r.t. a key function.ThisUnarySinkwrites all incoming data quanta to a Object file.This source reads a text file and outputs the lines as data units.This source reads a parquet file and outputs the lines asRecordunits.This operator groups the elements of a data set and aggregates the groups.A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.This operator sorts the elements in this dataset.ThisUnarySinkwrites all incoming data quanta to a text file.This source reads a text file and outputs the lines as data units.ThisOperatorcreates the union (bag semantics) of two . -
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.java.operators.graph
-
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.jdbc.operatorsClassDescriptionThis operator returns a new dataset after filtering by applying predicateDescriptor.This operator returns the cartesian product of elements of input datasets.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
UnarySourcethat provides the tuples from a database table. -
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.ml4all.abstraction.api
-
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.ml4all.algorithms.sgd
-
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.postgres.operatorsClassDescriptionThis operator returns a new dataset after filtering by applying predicateDescriptor.This operator returns the cartesian product of elements of input datasets.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
UnarySourcethat provides the tuples from a database table. -
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.spark.operatorsClassDescriptionThis operator returns the cartesian product of elements of input datasets.This operator groups both inputs by some key and then matches groups with the same key.This source takes as input a Java
Collection.This operator returns the count of elements in this stream.This operator returns the distinct elements in this dataset.This operator has three inputs and two outputs.This operator returns a new dataset after filtering by applying predicateDescriptor.A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator groups the elements of a data set into a single data quantum.This operator groups the elements of a data set and aggregates the groups.This operator returns the set intersection of elements of input datasets.This operator returns the cartesian product of elements of input datasets.ThisUnarySinkwrites all incoming data quanta to a single Kafka topic.This source reads messages from a Kafka topic and outputs the messages as data units.This sink executes a callback on each received data unit into a JavaCollection.This operator has three inputs and three outputs.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.This operator collocates the data units in a data set w.r.t. a key function.ThisUnarySinkwrites all incoming data quanta to a Object file.This source reads a text file and outputs the lines as data units.This source reads a parquet file and outputs the lines asRecordunits.This operator groups the elements of a data set and aggregates the groups.A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.This operator sorts the elements in this dataset.ThisUnarySinkwrites all incoming data quanta to a text file.This source reads a text file and outputs the lines as data units.ThisOperatorcreates the union (bag semantics) of two .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
-
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.sqlite3.operatorsClassDescriptionThis operator returns a new dataset after filtering by applying predicateDescriptor.A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
UnarySourcethat provides the tuples from a database table. -
Classes in org.apache.wayang.basic.operators used by org.apache.wayang.tensorflow.operators