Uses of Package
org.apache.wayang.core.function
-
Classes in org.apache.wayang.core.function used by org.apache.wayang.api.python.function Class Description FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.FunctionDescriptor A function operates on single data units or collections of those.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.applications Class Description FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.basic.function Class Description FunctionDescriptor A function operates on single data units or collections of those.TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.basic.mapping Class Description ExecutionContext While a function is executed on a certainPlatform
, allows access to some information of the context in which the function is being executed.ExtendedFunction Used to enrich regular functions with additional life-cycle methods ofOperator
s.FunctionDescriptor.ExtendedSerializableFunction Extends aFunctionDescriptor.SerializableFunction
to anExtendedFunction
.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.basic.operators Class Description FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.FunctionDescriptor.SerializableBinaryOperator Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableConsumer Decorates the defaultConsumer
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableIntUnaryOperator FunctionDescriptor.SerializableLongUnaryOperator FunctionDescriptor.SerializablePredicate MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.core.api Class Description FunctionDescriptor A function operates on single data units or collections of those. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.core.function Class Description AggregationDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit.ExecutionContext While a function is executed on a certainPlatform
, allows access to some information of the context in which the function is being executed.ExtendedFunction Used to enrich regular functions with additional life-cycle methods ofOperator
s.FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.FunctionDescriptor A function operates on single data units or collections of those.FunctionDescriptor.SerializableBinaryOperator Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableConsumer Decorates the defaultConsumer
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializablePredicate MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.core.optimizer.costs Class Description FunctionDescriptor A function operates on single data units or collections of those.FunctionDescriptor.SerializableToDoubleBiFunction FunctionDescriptor.SerializableToLongBiFunction -
Classes in org.apache.wayang.core.function used by org.apache.wayang.flink.compiler Class Description FunctionDescriptor.ExtendedSerializableFunction Extends aFunctionDescriptor.SerializableFunction
to anExtendedFunction
.FunctionDescriptor.SerializableConsumer Decorates the defaultConsumer
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializablePredicate MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.flink.compiler.criterion Class Description FunctionDescriptor.SerializablePredicate -
Classes in org.apache.wayang.core.function used by org.apache.wayang.flink.execution Class Description ExecutionContext While a function is executed on a certainPlatform
, allows access to some information of the context in which the function is being executed. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.flink.operators Class Description FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.FunctionDescriptor.SerializableConsumer Decorates the defaultConsumer
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableIntUnaryOperator FunctionDescriptor.SerializableLongUnaryOperator FunctionDescriptor.SerializablePredicate MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.genericjdbc.operators Class Description PredicateDescriptor This descriptor pertains to predicates that consume a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.iejoin.operators Class Description TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.java.compiler Class Description FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.java.execution Class Description ExecutionContext While a function is executed on a certainPlatform
, allows access to some information of the context in which the function is being executed. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.java.operators Class Description FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.FunctionDescriptor.SerializableIntUnaryOperator FunctionDescriptor.SerializableLongUnaryOperator FunctionDescriptor.SerializablePredicate MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.jdbc.compiler Class Description PredicateDescriptor This descriptor pertains to predicates that consume a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.jdbc.operators Class Description PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.ml4all.abstraction.plan.wrappers Class Description ExecutionContext While a function is executed on a certainPlatform
, allows access to some information of the context in which the function is being executed.ExtendedFunction Used to enrich regular functions with additional life-cycle methods ofOperator
s.FunctionDescriptor.ExtendedSerializableFunction Extends aFunctionDescriptor.SerializableFunction
to anExtendedFunction
.FunctionDescriptor.SerializableBinaryOperator Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.postgres.operators Class Description PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.profiler.java Class Description FunctionDescriptor.SerializableBinaryOperator Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.profiler.spark Class Description FunctionDescriptor.SerializableBinaryOperator Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializablePredicate -
Classes in org.apache.wayang.core.function used by org.apache.wayang.spark.compiler Class Description FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.FunctionDescriptor.ExtendedSerializableBinaryOperator Extends aFunctionDescriptor.SerializableBinaryOperator
to anExtendedFunction
.FunctionDescriptor.ExtendedSerializableFunction Extends aFunctionDescriptor.SerializableFunction
to anExtendedFunction
.FunctionDescriptor.ExtendedSerializablePredicate MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.spark.execution Class Description ExecutionContext While a function is executed on a certainPlatform
, allows access to some information of the context in which the function is being executed. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.spark.operators Class Description FlatMapDescriptor This descriptor pertains to functions that consume a single data unit and output a group of data units.FunctionDescriptor.SerializableFunction Decorates the defaultFunction
withSerializable
, which is required by some distributed frameworks.FunctionDescriptor.SerializableIntUnaryOperator FunctionDescriptor.SerializableLongUnaryOperator FunctionDescriptor.SerializablePredicate MapPartitionsDescriptor This descriptor pertains to functions that consume and output multiple data quanta.PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.ReduceDescriptor This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..TransformationDescriptor This descriptor pertains to functions that consume a single data unit and output a single data unit. -
Classes in org.apache.wayang.core.function used by org.apache.wayang.sqlite3.operators Class Description PredicateDescriptor This descriptor pertains to predicates that consume a single data unit.