All Classes and Interfaces

Class	Description
AbstractAlternativeCardinalityPusher	Abstract CardinalityPusher implementation for OperatorAlternatives and subclasses.
AbstractChannelInstance	Template for ChannelInstance implementations.
AbstractReferenceCountable	Implements a template for ReferenceCountable objects.
AbstractTopologicalTraversal<ActivatorType extends AbstractTopologicalTraversal.Activator<ActivationType>,ActivationType extends AbstractTopologicalTraversal.Activation<ActivatorType>>	Encapsulates logic to traverse a WayangPlan in a topological, bottom-up manner.
AbstractTopologicalTraversal.AbortException	Declares that the current traversal should be aborted.
AbstractTopologicalTraversal.Activation<TActivator extends AbstractTopologicalTraversal.Activator<? extends AbstractTopologicalTraversal.Activation<TActivator>>>	Describes a reference to an input of an AbstractTopologicalTraversal.Activator.
AbstractTopologicalTraversal.Activator<TActivation extends AbstractTopologicalTraversal.Activation<? extends AbstractTopologicalTraversal.Activator<TActivation>>>	Wraps a CardinalityEstimator, thereby caching its input CardinalityEstimates and keeping track of its dependent CardinalityEstimators.
Action	This interface represents any piece of code that takes no input and produces no output but may fail.
Actions	Utilities to perform actions.
ActualOperator	Operator free of ambiguities.
Adam
addUniqueID<Input extends Copyable<Input>>	Created by khayyzy on 5/28/16.
AggregateAddCols
AggregateFunction
AggregateGetResult
AggregateKeyExtractor
AggregateOptimizationContext	This OptimizationContext implementation aggregates several OptimizationContexts and exposes their OptimizationContext.OperatorContext in an aggregated manner.
AggregateWrapper<R>
AggregatingCardinalityEstimator	CardinalityEstimator implementation that can have multiple ways of calculating a CardinalityEstimate.
AggregationDescriptor<InputType,OutputType>	This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit.
AmazonS3Source	This source reads a blob file stored in Amazon s3 and outputs the lines as data units.
AmazonS3SourceMapping	Mapping from AmazonS3Source to JavaAmazonS3Source.
Application	This interface represents an application metrics in a Spark cluster.
ApplicationEnd	The ApplicationEnd class represents an application that has ended.
ApplicationStart	The ApplicationStart class implements the Application and SerializableObject interfaces.
ArgMax
AssignWrapper<R>
AssignWrapperLocal<V>
AtomicExecution	An atomic execution describes the smallest work unit considered by Wayang's cost model.
AtomicExecution.KeyOrLoadSerializer	This JsonSerializer stores the given instances via their Configuration key, if any, or else by the LoadProfile that they estimate.
AtomicExecutionGroup	This class groups AtomicExecutions with a common EstimationContext and Platform.
AtomicExecutionGroup.Serializer	JsonSerializer implementation for AtomicExecutionGroups.
Attr
AzureBlobStorageSource	This source reads a blob file stored in Azure Blob Storage and outputs the lines as data units.
AzureBlobStorageSourceMapping	Mapping from AzureBlobStorageSource to JavaAzureBlobStorageSource.
BasicDataUnitType<T>	A basic data unit type is elementary and not constructed from other data unit types.
BatchNorm
BatchNorm2D
BatchNorm3D
Battle<T>	Implementation of a battle between to elements.
BinaryOperation	An operation Expression.
BinaryOperatorAdapter<Type>	Wraps a BinaryOperator as a Function2.
BinaryOperatorProfiler	OperatorProfiler specifically for JavaExecutionOperators with a single InputSlot.
BinaryOperatorProfiler	SparkOperatorProfiler implementation for SparkExecutionOperators with two inputs and one output.
BinaryToUnaryOperator<InputType0,InputType1,OutputType>	This operator has two inputs and a single output.
Bitmask	A mutable bit-mask.
BitSetJoin<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	Created by khayyzy on 5/28/16.
BitSetJoin<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>	Created by khayyzy on 5/28/16.
Breakpoint	Describes when to interrupt the execution of an ExecutionPlan.
BroadcastChannel	Channel that represents a broadcasted value.
build2ListObject<TypeXPivot extends Comparable<TypeXPivot>,TypeXRef extends Comparable<TypeXRef>,Input extends Copyable<Input>>	Created by khayyzy on 5/28/16.
Canonicalizer<T>	This utility maintains canonical sets of objects.
CardinalityBreakpoint	Breakpoint implementation that is based on the CardinalityEstimates of Channels.
CardinalityEstimate	An estimate of cardinality within a WayangPlan expressed as a ProbabilisticIntervalEstimate.
CardinalityEstimationTraversal	CardinalityEstimator that subsumes a DAG of operators, each one providing a local CardinalityEstimator.
CardinalityEstimator	Computes CardinalityEstimates.
CardinalityEstimatorManager	Handles the CardinalityEstimates of a WayangPlan.
CardinalityPusher	Pushes a input CardinalityEstimates through an Operator and yields its output CardinalityEstimates.
CardinalityRepository	Stores cardinalities that have been collected by the CrossPlatformExecutor.
CartesianMapping	Mapping from CartesianOperator to FlinkCartesianOperator.
CartesianMapping	Mapping from CartesianOperator to JavaCartesianOperator.
CartesianMapping	Mapping from CartesianOperator to SparkCartesianOperator.
CartesianOperator<InputType0,InputType1>	This operator returns the cartesian product of elements of input datasets.
Cast
Channel	Models the data movement between to ExecutionTasks.
ChannelConversion	Can convert a given Channel to another Channel.
ChannelConversionGraph	This graph contains a set of ChannelConversions.
ChannelConversionGraph.CostbasedTreeSelectionStrategy	Prefers ChannelConversionGraph.Trees with lower cost.
ChannelConversionGraph.RandomTreeSelectionStrategy	Prefers ChannelConversionGraph.Trees with lower cost.
ChannelConversions	ChannelConversions used by the FlinkPlatform.
ChannelConversions	ChannelConversions for the GiraphPlatform.
ChannelConversions	ChannelConversions for the JavaPlatform.
ChannelConversions	Register for the ChannelConversions supported for this platform.
ChannelConversions	ChannelConversions used by the JavaPlatform.
ChannelConversions	Register for the ChannelConversions supported for this platform.
ChannelConversions	ChannelConversions for the TensorflowPlatform.
ChannelDescriptor	Describes a certain Channel type including further parameters.
ChannelInitializer	Sets up the usage of Channel in an ExecutionPlan for a given Platform.
ChannelInstance	Represents the actual, allocated resource represented by Channel.
ChannelLineageNode	Encapsulates a ChannelInstance in the lazy execution lineage.
CoGroupMapping	Mapping from CoGroupOperator to FlinkCoGroupOperator.
CoGroupMapping	Mapping from JoinOperator to JavaJoinOperator.
CoGroupMapping	Mapping from CoGroupOperator to SparkCoGroupOperator.
CoGroupOperator<InputType0,InputType1,Key>	This operator groups both inputs by some key and then matches groups with the same key.
CollectionChannel	Channel between two JavaExecutionOperators using an intermediate Collection.
CollectionProvider<Value>	Provides a Collection of objects.
CollectionSource<T>	This source takes as input a Java Collection.
CollectionSourceMapping	Mapping from CollectionSource to FlinkCollectionSource.
CollectionSourceMapping	Mapping from CollectionSource to JavaCollectionSource.
CollectionSourceMapping	Mapping from CollectionSource to SparkCollectionSource.
CollectionSourceMapping	Mapping from CollectionSource to TensorflowCollectionSource.
CollectionSplittableIterator<T>
CompiledFunction	Expression implementation that represents a function with a static implementation.
CompositeExecutionResource	ExecutionResource that itself contains ExecutionResources.
CompositeOperator	A composite operator can be decomposed into smaller operators.
Compute<R,V>	Created by zoi on 22/1/15.
ComputeLogisticGradient
ComputePerPartitionWrapper<R,V>
ComputeWrapper<R,V>
Configuration	Describes both the configuration of a WayangContext and Jobs.
ConjunctiveBreakpoint	Breakpoint implementation that disrupts execution if all aggregated Breakpoints request a disruption.
Constant	A constant Expression.
ConstantLoadProfileEstimator	LoadProfileEstimator that estimates a predefined LoadProfile.
ConstantValueProvider<Value>	Used by Configurations to provide some value.
ConsumerDescriptor<T>	Created by bertty on 13-07-17.
ConsumerIteratorAdapter<T>	Utility to expose interfaces that accept a callback as an Iterator.
Context	Provides contextual variables and functions in order to evaluate an Expression.
Conv
Conv2D
Conv3D
Convertor
ConvLSTM2D
Copyable<Self>	Implementing objects must be able to provide copies of themselves.
CostMeasurement	This measurement captures execution costs w.r.t. to Wayang's cost model.
Counter<T>	This utility helps to count elements.
CountMapping	Mapping from CountOperator to FlinkCountOperator.
CountMapping	Mapping from CountOperator to JavaCountOperator.
CountMapping	Mapping from CountOperator to SparkCountOperator.
CountOperator<Type>	This operator returns the count of elements in this stream.
CrossEntropyLoss
CrossPlatformExecutor	Executes a (cross-platform) ExecutionPlan.
CrossProductIterable<T>	Iterates all combinations, i.e., the Cartesian product, of given Iterables.
CsvRowConverter	Based on Calcite's CSV enumerator.
Data<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>	Created by khayyzy on 5/28/16.
Data.Comparator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>	Created by khayyzy on 5/28/16.
DatabaseDescriptor	This class describes a database.
DataComparator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	Created by khayyzy on 5/28/16.
DataGenerators	Utility to create common data generators.
DataGenerators.Generator<T>
DataSetChannel	Describes the situation where one DataSet is operated on, producing a further DataSet.
DataSetType<T>	A data set is an abstraction of the Wayang programming model.
DataUnitGroupType<T>	A grouped data unit type describes just the structure of data units within a grouped dataset.
DataUnitType<T>	The type of data types designate the kind of data that are being passed between operators.
DecisionTreeClassificationMapping	Mapping from DecisionTreeClassificationOperator to SparkDecisionTreeClassificationOperator.
DecisionTreeClassificationModel
DecisionTreeClassificationOperator
DecisionTreeRegressionMapping	Mapping from DecisionTreeRegressionOperator to SparkDecisionTreeRegressionOperator.
DecisionTreeRegressionModel
DecisionTreeRegressionOperator
DefaultCardinalityEstimator	Default implementation of the CardinalityEstimator.
DefaultCardinalityPusher	Default CardinalityPusher implementation.
DefaultChannelConversion	Default implementation of the ChannelConversion.
DefaultContext	Default Context implementation that can be configured.
DefaultEstimatableCost
DefaultEstimatableCost.Factory
DefaultLoadEstimator	Implementation of LoadEstimator that uses a single-point cost function.
DefaultOptimizationContext	This implementation of OptimizationContext represents a direct mapping from OptimizationContext.OperatorContext to executions of the respective Operators.
DisabledMonitor
DiskProfiler	Profiles the reading and writing speed to some directory.
DistinctMapping	Mapping from DistinctOperator to FlinkDistinctOperator.
DistinctMapping	Mapping from DistinctOperator to JavaDistinctOperator.
DistinctMapping	Mapping from DistinctOperator to SparkDistinctOperator.
DistinctOperator<Type>	This operator returns the distinct elements in this dataset.
DLModel
DLModel.Builder
DLTrainingOperator<X,Y>
DLTrainingOperator.Option
DLTrainingOperatorMapping	Mapping from DLTrainingOperator to TensorflowDLTrainingOperator.
DoWhileMapping	Mapping from DoWhileOperator to FlinkDoWhileOperator.
DoWhileMapping	Mapping from LoopOperator to JavaLoopOperator.
DoWhileMapping	Mapping from LoopOperator to SparkLoopOperator.
DoWhileOperator<InputType,ConvergenceType>	This operator has three inputs and two outputs.
DummyFilter<InputType>	Create a that remove the elements null
DummyMap<InputType,OutputType>	Class create a that genereta only null as convertion
DynamicEstimationContext	EstimationContext implementation for DynamicLoadEstimators.
DynamicLoadEstimator	Adjustable LoadProfileEstimator implementation.
DynamicLoadEstimator.SinglePointEstimator
DynamicLoadProfileEstimator	Adjustable LoadProfileEstimator implementation.
DynamicLoadProfileEstimators	Utility to create DynamicLoadProfileEstimators.
DynamicPlugin	This Plugin can be arbitrarily customized.
ElementaryOperator	Indivisible Operator that is not containing other Operators.
EnumerationAlternative	An enumeration alternative is embedded within an EnumerationBranch.
EnumerationBranch	An enumeration branch is the basic unit for enumeration, i.e., translation from a WayangPlan to an ExecutionPlan.
Eq
EstimatableCost	EstimatableCost defines an interface for optimizer cost in terms of methods to estimate a PlanImplementation's cost.
EstimatableCostFactory
EstimationContext	Provides parameters required by LoadProfileEstimators.
EstimationContextProperty	Marks a property of an Operator that is relevant to the estimation process, i.e., should be provided in EstimationContexts.
EvaluationException	This exception signals a failed Expression evaluation.
ExecutionContext	While a function is executed on a certain Platform, allows access to some information of the context in which the function is being executed.
ExecutionLineageNode	Encapsulates AtomicExecutions with a common OptimizationContext.OperatorContext in a lazy execution lineage.
ExecutionLog	Stores execution data have been collected by the CrossPlatformExecutor.
ExecutionOperator	An execution operator is handled by a certain platform.
ExecutionPlan	Represents an executable, cross-platform data flow.
ExecutionPlanMeasurement	This Measurement encapsulates an ExecutionPlan.
ExecutionPlanMeasurement.ChannelNode	Encapsulates a Channel of the ExecutionPlan.
ExecutionPlanMeasurement.Link	A directed link between an ExecutionPlanMeasurement.OperatorNode and a ExecutionPlanMeasurement.ChannelNode (in any order).
ExecutionPlanMeasurement.OperatorNode	Encapsulates a Channel of the ExecutionPlan.
ExecutionResource	Represents a resource allocated for execution that needs to be released manually.
ExecutionResourceTemplate	Implements various functionalities of an ExecutionResource.
ExecutionStage	Resides within a PlatformExecution and represents the minimum execution unit that is controlled by Wayang.
ExecutionStageLoop	This class models the execution equivalent of LoopSubplans.
ExecutionState	Contains a state of the execution of an ExecutionTaskFlow.
ExecutionTask	Serves as an adapter to include ExecutionOperators, which are usually parts of WayangPlans, in ExecutionPlans.
ExecutionTaskFlow	Graph of ExecutionTasks and Channels.
ExecutionTaskFlowCompiler	Creates an ExecutionTaskFlow from a PlanImplementation.
ExecutionTaskFlowCompiler.Activation	Propagates a Channel to its consumers.
Executor	An executor executes ExecutionOperators.
Executor	The Executor interface represents an executor in a Spark cluster.
Executor.Factory	Factory for Executors.
ExecutorAdded	The ExecutorAdded class represents an executor added event in a distributed computing system.
ExecutorRemoved	An event class representing the removal of an executor.
ExecutorTemplate	Implements the ExecutionResource handling as defined by Executor.
ExecutorUpdated	An implementation of the Executor interface that represents an updated executor.
Experiment	An experiment comprises Measurements from one specific Subject execution.
ExplainTreeNode
ExplainUtils
ExplicitCollectionProvider<Value>	CollectionProvider implementation based on a blacklist and a whitelist.
Expression	A mathematical expression that can be evaluated.
ExpressionBuilder	This utility builds Expressions from an input String.
ExtendedBinaryOperatorAdapter<Type>	Implements a Function2 that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function2.call(Object, Object).
ExtendedFlatMapFunctionAdapter<InputType,OutputType>	Implements a FlatMapFunction that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
ExtendedFunction	Used to enrich regular functions with additional life-cycle methods of Operators.
ExtendedFunction<InputType,OutputType>	Implements a Function that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
ExtendedMapFunctionAdapter<InputType,OutputType>	Implements a Function that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
ExtendedMapPartitionsFunctionAdapter<InputType,OutputType>	Wraps a Function as a FlatMapFunction.
ExtendedPredicateAdapater<Type>	Implements a Function that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
extractData<TypeXPivot extends Comparable<TypeXPivot>,TypeXRef extends Comparable<TypeXRef>,Input>	Created by khayyzy on 5/28/16.
extractData<TypeXPivot extends Comparable<TypeXPivot>,TypeXRef extends Comparable<TypeXRef>,Input>	Created by khayyzy on 5/28/16.
FallbackCardinalityEstimator	Assumes with a confidence of 50% that the output cardinality will be somewhere between 1 and the product of all 10*input estimates.
FileChannel	Represents a Channel that is realized via a file/set of files.
FileChannel.Descriptor	ChannelDescriptor for FileChannels.
FileChannels	Utilities for FileChannels.
FileMonitor
FileStorage
FileSystem	Abstraction for accessing a file system.
FileSystems	Tool to work with FileSystems.
FileUtils
FilterMapping	Mapping from FilterOperator to FlinkFilterOperator.
FilterMapping	Mapping from FilterOperator to GenericJdbcFilterOperator.
FilterMapping	Mapping from FilterOperator to JavaFilterOperator.
FilterMapping	Mapping from FilterOperator to PostgresFilterOperator.
FilterMapping	Mapping from FilterOperator to SparkFilterOperator.
FilterMapping	Mapping from FilterOperator to Sqlite3FilterOperator.
FilterOperator<Type>	This operator returns a new dataset after filtering by applying predicateDescriptor.
FilterPredicateImpl
filterUnwantedBlocks<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>	Created by khayyzy on 5/28/16.
FixBreakpoint	Describes when to interrupt the execution of an ExecutionPlan.
FixedSizeCardinalityEstimator	CardinalityEstimator implementation for Operators with a fix-sized output.
FlatMapDescriptor<Input,Output>	This descriptor pertains to functions that consume a single data unit and output a group of data units.
FlatMapFunctionAdapter<InputType,OutputType>	Wraps a Function as a FlatMapFunction.
FlatMapMapping	Mapping from FlatMapOperator to FlinkFlatMapOperator.
FlatMapMapping	Mapping from FlatMapOperator to JavaFlatMapOperator.
FlatMapMapping	Mapping from FlatMapOperator to SparkFlatMapOperator.
FlatMapOperator<InputType,OutputType>	A flatmap operator represents semantics as they are known from frameworks, such as Spark and Flink.
Flink	Register for relevant components of this module.
FlinkBasicPlugin	This Plugin enables to use the basic Wayang Operators on the FlinkPlatform.
FlinkCartesianOperator<InputType0,InputType1>	Flink implementation of the CartesianOperator.
FlinkCoGroupFunction<InputType0,InputType1,OutputType>	Wrapper of of Flink for use in Wayang
FlinkCoGroupOperator<InputType0,InputType1,TypeKey>	Flink implementation of the CoGroupOperator.
FlinkCollectionSink<Type>	Converts DataSetChannel into a CollectionChannel
FlinkCollectionSource<Type>	This is execution operator implements the CollectionSource.
FlinkContextReference	Wraps and manages a Flink ExecutionEnvironment to avoid steady re-creation.
FlinkConversionPlugin	This Plugin provides ChannelConversions from the FlinkPlatform.
FlinkCountOperator<Type>	Flink implementation of the CountOperator.
FlinkDistinctOperator<Type>	Flink implementation of the DistinctOperator.
FlinkDoWhileOperator<InputType,ConvergenceType>	Flink implementation of the DoWhileOperator.
FlinkExecutionContext	ExecutionContext implementation for the FlinkPlatform.
FlinkExecutionOperator	Execution operator for the Flink platform.
FlinkExecutor	Executor implementation for the FlinkPlatform.
FlinkFilterOperator<Type>	Flink implementation of the FilterOperator.
FlinkFlatMapOperator<InputType,OutputType>	Flink implementation of the FlatMapOperator.
FlinkGlobalMaterializedGroupOperator<Type>	Flink implementation of the GlobalMaterializedGroupOperator.
FlinkGlobalReduceOperator<Type>	Flink implementation of the GlobalReduceOperator.
FlinkGraphPlugin	This Plugin enables to use the basic Wayang Operators on the FlinkPlatform.
FlinkGroupByOperator<InputType,KeyType>	Flink implementation of the GroupByOperator.
FlinkIntersectOperator<Type>	Flink implementation of the IntersectOperator.
FlinkJoinOperator<InputType0,InputType1,KeyType>	Flink implementation of the JoinOperator.
FlinkLocalCallbackSink<Type extends Serializable>	Implementation of the LocalCallbackSink operator for the Flink platform.
FlinkLoopOperator<InputType,ConvergenceType>	Flink implementation of the RepeatOperator.
FlinkMapOperator<InputType,OutputType>	Flink implementation of the MapOperator.
FlinkMapPartitionsOperator<InputType,OutputType>	Flink implementation of the MapPartitionsOperator.
FlinkMaterializedGroupByOperator<Type,KeyType>	Flink implementation of the MaterializedGroupByOperator.
FlinkObjectFileSink<Type>	Operator for the FlinkPlatform that creates a sequence file.
FlinkObjectFileSource<Type>	Operator for the FlinkPlatform that creates a sequence file.
FlinkPageRankOperator	Flink implementation of the PageRankOperator.
FlinkPageRankOperator.BuildOutgoingEdgeList	A reduce function that takes a sequence of edges and builds the adjacency list for the vertex where the edges originate.
FlinkPageRankOperator.Dampener	The function that applies the page rank dampening formula.
FlinkPageRankOperator.EpsilonFilter	Filter that filters vertices where the rank difference is below a threshold.
FlinkPageRankOperator.JoinVertexWithEdgesMatch	Join function that distributes a fraction of a vertex's rank to all neighbors.
FlinkPageRankOperator.RankAssigner	A map function that assigns an initial rank to all pages.
FlinkPlatform	Platform for Apache Flink.
FlinkReduceByOperator<InputType,KeyType>	Flink implementation of the ReduceByOperator.
FlinkRepeatExpandedOperator<Type>	Flink implementation of the RepeatOperator.
FlinkRepeatOperator<Type>	Flink implementation of the RepeatOperator.
FlinkSampleOperator<Type>	Flink implementation of the SampleOperator.
FlinkSortOperator<InputType,KeyType>	Flink implementation of the SortOperator.
FlinkTextFileSink<Type>	Implementation of the TextFileSink operator for the Flink platform.
FlinkTextFileSource	Provides a Collection to a Flink job.
FlinkTsvFileSink<Type extends Tuple2<?,?>>	Created by bertty on 31-10-17.
FlinkUnionAllOperator<Type>	Flink implementation of the UnionAllOperator.
FlinkZipWithIdOperator<InputType>	Flink implementation of the MapOperator.
Formats	Formats different general purpose objects.
FullInstrumentationStrategy	Instruments only outbound Channels.
FunctionalCollectionProvider<Value>	CollectionProvider implementation based on a blacklist and a whitelist.
FunctionalKeyValueProvider<Key,Value>	Implementation of KeyValueProvider that uses a Function to provide a value.
FunctionalValueProvider<Value>	Used by Configurations to provide some value.
FunctionCompiler	A compiler translates Wayang functions into executable Flink functions.
FunctionCompiler	A compiler translates Wayang functions into executable Java functions.
FunctionCompiler	Compiles FunctionDescriptors to SQL clauses.
FunctionCompiler	A compiler translates Wayang functions into executable Java functions.
FunctionCompiler.KeyExtractor<T,K>	Spark function for building pair RDDs.
FunctionCompiler.Reducer<Type>	Spark function for aggregating data quanta.
FunctionCompiler.WayangSparkFunction	Describes functions coming from Wayang, designated for Spark.
FunctionDescriptor	A function operates on single data units or collections of those.
FunctionDescriptor.ExtendedSerializableBinaryOperator<Type>	Extends a FunctionDescriptor.SerializableBinaryOperator to an ExtendedFunction.
FunctionDescriptor.ExtendedSerializableConsumer<T>	Extends a FunctionDescriptor.SerializableConsumer to an ExtendedFunction.
FunctionDescriptor.ExtendedSerializableFunction<Input,Output>	Extends a FunctionDescriptor.SerializableFunction to an ExtendedFunction.
FunctionDescriptor.ExtendedSerializablePredicate<T>
FunctionDescriptor.SerializableBiFunction<Input0,Input1,Output>	Decorates the default Function with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableBinaryOperator<Type>	Decorates the default Function with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableConsumer<T>	Decorates the default Consumer with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableFunction<Input,Output>	Decorates the default Function with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableIntUnaryOperator
FunctionDescriptor.SerializableLongUnaryOperator
FunctionDescriptor.SerializablePredicate<T>
FunctionDescriptor.SerializableToDoubleBiFunction<T,U>
FunctionDescriptor.SerializableToLongBiFunction<T,U>
FunctionDescriptor.SerializableToLongFunction<T>
GenericChannelConversions	Register for the ChannelConversions supported for this platform.
GenericJdbc	Register for relevant components of this module.
GenericJdbcConversionsPlugin	This Plugin enables to use some basic Wayang Operators on the GenericJdbcPlatform.
GenericJdbcExecutionOperator
GenericJdbcExecutor	Executor implementation for the GenericJdbcPlatform.
GenericJdbcFilterOperator	GenericJdbc implementation of the FilterOperator.
GenericJdbcPlatform	Platform implementation for GenericJdbc.
GenericJdbcPlugin	This Plugin enables to use some basic Wayang Operators on the GenericJdbcPlatform.
GenericJdbcProjectionOperator	GenericJdbc implementation of the FilterOperator.
GenericJdbcTableSource
GenericSqlToStreamOperator	This Operator converts SqlQueryChannels to StreamChannels.
GeneticOptimizer	Implementation of the genetic optimization technique for finding good LoadProfileEstimators.
GeneticOptimizerApp	This app tries to infer good LoadProfileEstimators for ExecutionOperators using data from an ExecutionLog.
Get
Giraph	Register for relevant components of this module.
GiraphExecutionOperator	ExecutionOperator that can be run by the GiraphExecutor.
GiraphExecutor	Executor for the GiraphPlatform.
GiraphPageRankOperator	PageRank Operator implementation for the GiraphPlatform.
GiraphPlatform	Giraph Platform for Wayang.
GiraphPlugin	This Plugin activates default capabilities of the GiraphPlatform.
GlobalMaterializedGroupMapping	Mapping from GlobalMaterializedGroupOperator to FlinkGlobalMaterializedGroupOperator.
GlobalMaterializedGroupMapping	Mapping from GlobalMaterializedGroupOperator to JavaGlobalMaterializedGroupOperator.
GlobalMaterializedGroupMapping	Mapping from GlobalMaterializedGroupOperator to SparkGlobalMaterializedGroupOperator.
GlobalMaterializedGroupOperator<Type>	This operator groups the elements of a data set into a single data quantum.
GlobalReduceMapping	This mapping detects combinations of the GroupByOperator and ReduceOperator and merges them into a single ReduceByOperator.
GlobalReduceMapping	Mapping from GlobalReduceOperator to FlinkGlobalReduceOperator.
GlobalReduceMapping	Mapping from GlobalReduceOperator to JavaGlobalReduceOperator.
GlobalReduceMapping	Mapping from GlobalReduceOperator to SparkGlobalReduceOperator.
GlobalReduceOperator<Type>	This operator groups the elements of a data set and aggregates the groups.
GoogleCloudStorageSource
GoogleCloudStorageSourceMapping	Mapping from GoogleCloudStorageSource to JavaGoogleClodStorageSource.
GradientDescent
Grep
GroupByMapping	Mapping from GroupByOperator to FlinkGroupByOperator.
GroupByOperator<Input,Key>	This is the auxiliary GroupBy operator, i.e., it behaves differently depending on its context.
GroupKey	Grouping key used in Query 1.
HadoopFileSystem	FileSystem immplementation for the HDFS.
HttpMonitor	TODO: Implement
IEJoin	Provides Plugins that enable usage of the IEJoinOperator and the IESelfJoinOperator.
IEJoinMapping	Mapping from IEJoinOperator to JavaIEJoinOperator.
IEJoinMapping	Mapping from IEJoinOperator to SparkIEJoinOperator.
IEJoinMasterOperator	This operator decides the correct sorting orders for IEJoin
IEJoinMasterOperator.JoinCondition	Created by khayyzy on 5/19/16.
IEJoinOperator<Type0,Type1,Input>	This operator applies inequality join on elements of input datasets.
IESelfJoinMapping	Mapping from IESelfJoinOperator to JavaIESelfJoinOperator.
IESelfJoinMapping	Mapping from IESelfJoinOperator to SparkIESelfJoinOperator.
IESelfJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	This operator applies inequality self join on elements of input datasets.
Individual	Context for the optimization of LoadProfileEstimators.
Input
Input.Type
InputSlot<T>	An input slot declares an input of an Operator.
InstrumentationStrategy	Determines, which Channels in an ExecutionPlan should be instrumented.
IntersectMapping	Mapping from IntersectOperator to FlinkIntersectOperator.
IntersectMapping	Mapping from IntersectOperator to JavaIntersectOperator.
IntersectMapping	Mapping from IntersectOperator to SparkIntersectOperator.
IntersectOperator<Type>	This operator returns the set intersection of elements of input datasets.
IntervalLoadEstimator	Implementation of LoadEstimator that uses a interval-based cost function.
Iterators	Utilities for the work with Iterators.
Java	Register for relevant components of this module.
JavaAmazonS3Source	This is execution operator that implements the AmazonS3Source.
JavaAzureBlobStorageSource	This is execution operator that implements the AzureBlobStorageSource.
JavaBasicPlugin	This Plugin enables to use the basic Wayang Operators on the JavaPlatform.
JavaCartesianOperator<InputType0,InputType1>	Java implementation of the CartesianOperator.
JavaChannelConversionPlugin	This Plugin is a subset of the JavaBasicPlugin and only ships the ChannelConversions.
JavaChannelInstance	Defines execution logic to handle a Channel.
JavaCoGroupOperator<InputType0,InputType1,KeyType>	Java implementation of the CoGroupOperator.
JavaCollectionSource<T>	This is execution operator implements the TextFileSource.
JavaCollectionSourceProfiler	OperatorProfiler for JavaCollectionSources.
JavaCollectOperator<Type>	Converts StreamChannel into a CollectionChannel
JavaCountOperator<Type>	Java implementation of the CountOperator.
JavaCSVTableSource<T>
JavaDistinctOperator<Type>	Java implementation of the DistinctOperator.
JavaDoWhileOperator<InputType,ConvergenceType>	Java implementation of the DoWhileOperator.
JavaExecutionContext	ExecutionContext implementation for the JavaPlatform.
JavaExecutionOperator	Execution operator for the Java platform.
JavaExecutor	Executor implementation for the JavaPlatform.
JavaFilterOperator<Type>	Java implementation of the FilterOperator.
JavaFlatMapOperator<InputType,OutputType>	Java implementation of the FlatMapOperator.
JavaGlobalMaterializedGroupOperator<Type>	Java implementation of the GlobalMaterializedGroupOperator.
JavaGlobalReduceOperator<Type>	Java implementation of the GlobalReduceOperator.
JavaGoogleCloudStorageSource
JavaGraphPlugin	This Plugin enables to use the basic Wayang Operators on the JavaPlatform.
JavaIEJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	Java implementation of the IEJoinOperator.
JavaIESelfJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	Java implementation of the IESelfJoinOperator.
JavaIntersectOperator<Type>	Java implementation of the IntersectOperator.
JavaJoinOperator<InputType0,InputType1,KeyType>	Java implementation of the JoinOperator.
JavaKafkaTopicSink<T>	Implementation fo the KafkaTopicSink for the JavaPlatform.
JavaKafkaTopicSource
JavaLocalCallbackSink<T extends Serializable>	Implementation of the LocalCallbackSink operator for the Java platform.
JavaLoopOperator<InputType,ConvergenceType>	Java implementation of the LoopOperator.
JavaMapOperator<InputType,OutputType>	Java implementation of the MapOperator.
JavaMapPartitionsOperator<InputType,OutputType>	Java implementation of the MapPartitionsOperator.
JavaMaterializedGroupByOperator<Type,KeyType>	Java implementation of the MaterializedGroupByOperator.
JavaObjectFileSink<T>	Operator for the JavaPlatform that creates a sequence file.
JavaObjectFileSink.StreamChunker	Utility to chunk a Stream into portions of fixed size.
JavaObjectFileSource<T>	Operator for the JavaPlatform that creates a sequence file.
JavaPageRankOperator	Java implementation of the PageRankOperator.
JavaParquetSource	This is execution operator implements the ParquetSource.
JavaPlatform	Platform for a single JVM executor based on the Stream library.
JavaRandomSampleOperator<Type>	Java implementation of the JavaRandomSampleOperator.
JavaReduceByOperator<Type,KeyType>	Java implementation of the ReduceByOperator.
JavaRepeatOperator<Type>	Java implementation of the DoWhileOperator.
JavaReservoirSampleOperator<Type>	Java implementation of the JavaReservoirSampleOperator.
JavaSortOperator<Type,Key>	Java implementation of the SortOperator.
JavaTextFileSink<T>	Implementation fo the TextFileSink for the JavaPlatform.
JavaTextFileSource	This is execution operator implements the TextFileSource.
JavaTextFileSourceProfiler	OperatorProfiler for sources.
JavaTsvFileSink<T extends Tuple2<?,?>>	Operator for the JavaPlatform that creates a TSV file.
JavaTsvFileSource<T>	Operator for the JavaPlatform that creates a sequence file.
JavaUnionAllOperator<Type>	Java implementation of the UnionAllOperator.
JdbcExecutionOperator
JdbcExecutor	Executor implementation for the JdbcPlatformTemplate.
JdbcFilterOperator	Template for JDBC-based FilterOperator.
JdbcJoinOperator<KeyType>	PostgreSQL implementation for the JoinOperator.
JdbcPlatformTemplate	Platform implementation for a JDBC-accessible database.
JdbcProjectionOperator	Projects the fields of Records.
JdbcSchema	Implementation of Schema that is backed by a JDBC data source.
JdbcSchema.Factory	Schema factory that creates a JdbcSchema.
JdbcSchema.Foo	Do not use.
JDBCStorage
JdbcTable	Queryable that gets its data from a table within a JDBC connection.
JdbcTableSource	PostgreSQL implementation for the TableSource.
Job	Describes a job that is to be executed using Wayang.
Job	The Job interface represents a job to be executed in a distributed system.
JobEnd	JobEnd class represents a job's end in a system.
JobStart	JobStart class represents a job's start in a system.
JoinFlattenResult	Flattens the result of a join i.e. a Tuple2 of a left and a right Record to a single Record.
JoinKeyExtractor
JoinMapping	Mapping from JoinOperator to FlinkJoinOperator.
JoinMapping	Mapping from JoinOperator to JavaJoinOperator.
JoinMapping	Mapping from JoinOperator to PostgresJoinOperator.
JoinMapping	Mapping from JoinOperator to SparkJoinOperator.
JoinOperator<InputType0,InputType1,Key>	This operator returns the cartesian product of elements of input datasets.
JsonSerializable	This interface prescribes implementing instances to be able to provide itself as a WayangJsonObj.
JsonSerializable.Serializer<T extends JsonSerializable>	A JsonSerializer implementation to serialize JsonSerializables.
JsonSerializables	Utility to deal with JsonSerializables.
JsonSerializer<T>	Alternative to JsonSerializable: Externalizes serialization logic.
JuelUtils	Utilities to deal with JUEL expressions.
JuelUtils.JuelFunction<T>
Junction	Describes the implementation of one OutputSlot to its occupied InputSlots.
KafkaTopicSink<T>	This UnarySink writes all incoming data quanta to a single Kafka topic.
KafkaTopicSinkMapping	Mapping from KafkaTopicSink to JavaKafkaTopicSink.
KafkaTopicSinkMapping	Mapping from KafkaTopicSink to SparkKafkaTopicSink.
KafkaTopicSource	This source reads messages from a Kafka topic and outputs the messages as data units.
KafkaTopicSourceMapping	Mapping from KafkaTopicSource to JavaKafkaTopicSource.
KafkaTopicSourceMapping	Mapping from KafkaTopicSource to SparkKafkaTopicSource.
KeySelectorDistinct<T>	Wrapper for
KeySelectorFunction<T,K>	Wrapper for KeySelector
KeyValueProvider<Key,Value>	Used by Configurations to provide some value.
KeyValueProvider.NoSuchKeyException
KMeansCompute
KMeansConvergeOrMaxIterationsLoop
KMeansMapping	Mapping from KMeansOperator to SparkKMeansOperator.
KMeansModel
KMeansOperator
KMeansStageWithZeros
KMeansUpdate
LatentOperatorPruningStrategy	This PlanEnumerationPruningStrategy follows the idea that we can prune a PlanImplementation, when there is a further one that is (i) better and (ii) has the exact same operators with still-to-be-connected Slots.
LazyExecutionLineageNode	A node wraps a ChannelInstance and keeps track of predecessor nodes.
LazyExecutionLineageNode.Aggregator<T>	Callback interface for traversals of LazyExecutionLineageNodes, thereby accumulating the callback return values.
LazyExecutionLineageNode.CollectingAggregator	LazyExecutionLineageNode.Aggregator implementation that collects all visited LazyExecutionLineageNode contents.
LibSVMTransform
LimitedInputStream	InputStream that is trimmed to a specified size.
Linear
LinearRegressionMapping	Mapping from LinearRegressionOperator to SparkLinearRegressionOperator.
LinearRegressionModel
LinearRegressionOperator
LinearSVCMapping	Mapping from LinearSVCOperator to SparkLinearSVCOperator.
LinearSVCOperator
LineItemTuple	A tuple of the lineitem table.
LineItemTuple.Parser	Parses a LineItemTuple from a given CSV line (double quoted, comma-separated).
List2AttributesObjectSkinny<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>	Created by khayyzy on 5/28/16.
LoadEstimate	An estimate of costs of some executable code expressed as a ProbabilisticIntervalEstimate.
LoadEstimator	Describes the resource utilization of something executable within an EstimationContext, such as an ExecutionOperator or a FunctionDescriptor.
LoadEstimator.SinglePointEstimationFunction	Functional interface for lambda expressions to express single-point load estimation functions.
LoadProfile	Reflects the (estimated) required resources of an Operator or FunctionDescriptor.
LoadProfileEstimator	Estimates the LoadProfile of some executable artifact that takes some input data quanta and produces them.
LoadProfileEstimators	Utilities to deal with LoadProfileEstimators.
LoadProfileToTimeConverter	Calculates a TimeEstimate for a link LoadProfile.
LoadProfileToTimeConverter.ResourceTimeEstimateAggregator
LoadToTimeConverter	Converts a LoadEstimate into a time estimate.
LocalCallbackSink<T>	This sink executes a callback on each received data unit into a Java Collection.
LocalCallbackSinkMapping	Mapping from LocalCallbackSink to FlinkLocalCallbackSink.
LocalCallbackSinkMapping	Mapping from LocalCallbackSink to JavaLocalCallbackSink.
LocalCallbackSinkMapping	Mapping from LocalCallbackSink to SparkLocalCallbackSink.
LocalFileSystem	FileSystem implementation for the local file system.
LocalStage
LogEvaluator	Evaluates a Configuration on a ExecutionLog.
Logging	Provide logging via Logger.
LogicalOperator	An ML4all logical operator
LogicalOperatorWrapper<R,V>
LogicalOperatorWrapperWithModel<R,V>	Logical Operator that uses the [[org.apache.wayang.ml4all.abstraction.plan.ML4allModel]] as input besides the data flowing from its input slot.
LogisticRegressionMapping	Mapping from LogisticRegressionOperator to SparkLogisticRegressionOperator.
LogisticRegressionModel
LogisticRegressionOperator
Loop<R,V>
LoopCheckWrapper<V>
LoopConvergenceWrapper<R,V>
LoopEnumerator	Enumerator for LoopSubplans.
LoopHeadAlternative	Special OperatorAlternative for LoopHeadOperators.
LoopHeadAlternativeCardinalityPusher	CardinalityPusher implementation for LoopHeadAlternatives.
LoopHeadOperator	Head of a LoopSubplan.
LoopHeadOperator.State	LoopHeadOperators can be stateful because they might be executed mulitple times.
LoopImplementation	Describes the enumeration of a LoopSubplan.
LoopIsolator	Goes over a WayangPlan and isolates its loops.
LoopMapping	Mapping from LoopOperator to FlinkLoopOperator.
LoopMapping	Mapping from LoopOperator to JavaLoopOperator.
LoopMapping	Mapping from LoopOperator to SparkLoopOperator.
LoopOperator<InputType,ConvergenceType>	This operator has three inputs and three outputs.
LoopSubplan	Wraps a loop of Operators.
LoopSubplanCardinalityPusher	CardinalityPusher implementation for LoopSubplans.
LruCache<K,V>	Key-value cache with "least recently used" eviction strategy.
Main
Main	Starts a profiling run of Spark.
MapBasedKeyValueProvider<Key,Value>	Implementation of KeyValueProvider that uses a Map to provide a value.
MapFunctionAdapter<InputType,OutputType>	Wraps a Function as a Function.
MapMapping	Mapping from MapOperator to FlinkMapOperator.
MapMapping	Mapping from MapOperator to JavaMapOperator.
MapMapping	Mapping from MapOperator to SparkMapOperator.
MapOperator<InputType,OutputType>	A map operator represents semantics as they are known from frameworks, such as Spark and Flink.
MapPartitionsDescriptor<Input,Output>	This descriptor pertains to functions that consume and output multiple data quanta.
MapPartitionsFunctionAdapter<InputType,OutputType>	Wraps a Function as a FlatMapFunction.
MapPartitionsMapping	Mapping from MapPartitionsOperator to FlinkMapPartitionsOperator.
MapPartitionsMapping	Mapping from MapPartitionsOperator to JavaMapPartitionsOperator.
MapPartitionsMapping	Mapping from MapPartitionsOperator to SparkMapPartitionsOperator.
MapPartitionsOperator<InputType,OutputType>	This operator takes as input potentially multiple input data quanta and outputs multiple input data quanta.
Mapping	A mapping issues a set of PlanTransformations that make up the complete mapping.
Mappings	Register for the components provided in the basic plugin.
Mappings	Register for Mappings for this platform.
Mappings	Register for the Mappings supported for this platform.
Mappings	Register for Mappings for this platform.
Mappings	Mappings for the IEJoinOperator.
Mappings	Register for Mappings for this platform.
Mappings	Register for the Mappings supported for this platform.
Mappings	Register for Mappings for this platform.
Mappings	Register for the Mappings supported for this platform.
Mappings	Register for Mappings for this platform.
MaterializedGroupByMapping	This mapping translates the GroupByOperator into the MaterializedGroupByOperator.
MaterializedGroupByMapping	Mapping from MaterializedGroupByOperator to FlinkMaterializedGroupByOperator.
MaterializedGroupByMapping	Mapping from MaterializedGroupByOperator to JavaMaterializedGroupByOperator.
MaterializedGroupByMapping	Mapping from MaterializedGroupByOperator to SparkMaterializedGroupByOperator.
MaterializedGroupByOperator<Type,Key>	This operator collocates the data units in a data set w.r.t. a key function.
MathExBaseListener	This class provides an empty implementation of MathExListener, which can be extended to create a listener which only needs to handle a subset of the available methods.
MathExBaseVisitor<T>	This class provides an empty implementation of MathExVisitor, which can be extended to create a visitor which only needs to handle a subset of the available methods.
MathExException	This exception signals a failed Expression evaluation.
MathExLexer
MathExListener	This interface defines a complete listener for a parse tree produced by MathExParser.
MathExParser
MathExParser.BinaryOperationContext
MathExParser.ConstantContext
MathExParser.ExpressionContext
MathExParser.FunctionContext
MathExParser.ParensExpressionContext
MathExParser.UnaryOperationContext
MathExParser.VariableContext
MathExVisitor<T>	This interface defines a complete generic visitor for a parse tree produced by MathExParser.
Mean
Measurement	Measurement captures the value of a metric at a specific time
MeasurementDeserializer	Custom deserializer for Measurements Detects actual subclass of serialized instances and then delegates the deserialization to that subtype.
MeasurementSerializer	Custom serializer for Measurements Detects actual subclass of given instances, encodes this class membership, and then delegates serialization to that subtype.
ML4allModel	For keeping global variables to access in the logical operators.
ML4allPlan	Wayang physical plan for ML4all algorithms
Model	A Type that represents a ML model
ModelParser
ModelTransformMapping	Deprecated.
ModelTransformOperator<X,Y>	Deprecated.
Monitor
MSELoss
MultiConditionJoinFuncImpl	Flattens Tuple2<Record, Record> to Record
MultiConditionJoinKeyExtractor
MultiMap<K,V>	Maps keys to multiple values.
myMergeSort<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	Created by khayyzy on 5/28/16.
myMergeSort<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>	Created by khayyzy on 5/28/16.
NamedFunction	Expression implementation that represents a function that is identified via its name.
NestableLoadProfileEstimator	LoadProfileEstimator that can host further LoadProfileEstimators.
NoInstrumentationStrategy	Instruments only outbound Channels.
NoIterationBreakpoint	This Breakpoint implementation always requests a break unless inside of ExecutionStageLoops.
ObjectFileSink<T>	This UnarySink writes all incoming data quanta to a Object file.
ObjectFileSinkMapping	Mapping from ObjectFileSink to FlinkObjectFileSink.
ObjectFileSinkMapping	Mapping from ObjectFileSink to JavaObjectFileSink.
ObjectFileSinkMapping	Mapping from ObjectFileSink to SparkObjectFileSink.
ObjectFileSource<T>	This source reads a text file and outputs the lines as data units.
ObjectFileSourceMapping	Mapping from ObjectFileSource to FlinkObjectFileSource.
ObjectFileSourceMapping	Mapping from ObjectFileSource to JavaObjectFileSource.
ObjectFileSourceMapping	Mapping from ObjectFileSource to SparkObjectFileSource.
OneTimeExecutable	Method wrapper that ensures that it is called only once.
Op
Op.DType
Operator	An operator is any node that within a WayangPlan.
OperatorAlternative	This operator encapsulates operators that are alternative to each other.
OperatorAlternativeCardinalityPusher	CardinalityPusher implementation for OperatorAlternatives.
OperatorBase	Helper class for the implementation of the Operator interface.
OperatorBase.GsonSerializer	Utility to de/serialize Operators.
OperatorContainer	This is not an Operator in its own right.
OperatorContainers	Utilities to deal with OperatorContainers.
OperatorMatch	An operator match correlates an OperatorPattern to an actually matched Operator.
OperatorPattern<T extends Operator>	An operator pattern matches to a class of operator instances.
OperatorProfiler	Allows to instrument an JavaExecutionOperator.
OperatorProfiler.Result	The result of a single profiling run.
OperatorProfilers	Utilities to create OperatorProfiler instances.
OperatorProfilers	Utilities to create SparkOperatorProfiler instances.
Operators	Utility class for Operators.
OptimizationContext	Manages contextual information required during the optimization of a WayangPlan.
OptimizationSpace	Context for the optimization of LoadProfileEstimators.
OptimizationUtils	Utility methods for the optimization process.
Optimizer
Optimizer
Optimizer.ConfigProperties
Optional<T>	Utility similar to Optional.
OutboundInstrumentationStrategy	Instruments only outbound Channels.
OutputFormatConsumer<T>	Wrapper for
OutputSerializer
OutputSlot<T>	An output slot declares an output of an Operator.
PageRankAlgorithm	Basic PageRank implementation.
PageRankAlgorithm.PageRankMasterCompute	Master compute associated with PageRankAlgorithm.
PageRankAlgorithm.PageRankVertexInputFormat	Simple VertexInputFormat that supports PageRankAlgorithm
PageRankAlgorithm.PageRankVertexOutputFormat	Simple VertexOutputFormat that supports PageRankAlgorithm
PageRankAlgorithm.PageRankVertexReader	Simple VertexReader that supports PageRankAlgorithm
PageRankAlgorithm.PageRankWorkerContext	Worker context used with PageRankAlgorithm.
PageRankMapping	This Mapping translates a PageRankOperator into a Subplan of basic Operators.
PageRankMapping	Mapping from PageRankOperator to FlinkPageRankOperator.
PageRankMapping	Maps PageRankOperators to GiraphPageRankOperators.
PageRankMapping	Mapping from PageRankOperator to JavaPageRankOperator.
PageRankMapping	Mapping from PageRankOperator to org.apache.wayang.spark.operators.graph.SparkPageRankOperator .
PageRankMapping.RankInitializer	Creates intial page ranks.
PageRankOperator	Operator for the PageRank algorithm.
PageRankParameters	Parameters for Basic PageRank implementation.
PageRankParameters.PageRankEnum
ParquetSource	This source reads a parquet file and outputs the lines as Record units.
ParquetSourceMapping	Mapping from ParquetSource to JavaParquetSource.
ParquetSourceMapping	Mapping from CollectionSource to SparkCollectionSource.
ParseException	This exception signals a failed Expression evaluation.
PartialExecution	Captures data of a execution of a set of ExecutionOperators.
PartialExecution.Serializer	JsonSerializer implementation for PartialExecutions.
PartialExecutionMeasurement	This Measurement adapts a PartialExecutionMeasurement.
PiEstimation
PlanEnumeration	Represents a collection of PlanImplementations that all implement the same section of a WayangPlan (which is assumed to contain OperatorAlternatives in general).
PlanEnumerationPruningStrategy	A strategy to prune PlanImplementations from a PlanEnumeration.
PlanEnumerator	The plan partitioner recursively dissects a WayangPlan into PlanEnumerations and then assembles them.
PlanEnumerator.EnumerationActivator	An Operator can be activated as soon as all of its inputs are available.
PlanImplementation	Represents a partial execution plan.
PlanMetrics	This class collects metrics for WayangPlans.
PlanTransformation	Looks for a SubplanPattern in a WayangPlan and replaces it with an alternative Operators.
PlanTraversal	Traverse a plan.
PlanTraversal.Callback	A callback can be invoked during a plan traversal on each traversed node.
PlanTraversal.SimpleCallback	A callback can be invoked during a plan traversal on each traversed node.
Platform	A platform describes an execution engine that executes ExecutionOperators.
PlatformExecution	Complete data flow on a single platform, that consists of multiple ExecutionStages.
Platforms
Plugin	A plugin contributes the following components to a WayangContext: Mappings, ChannelConversions, and Configuration properties. In turn, it may require several Platforms for its operation.
Postgres	Register for relevant components of this module.
PostgresConversionsPlugin	This Plugin enables to use some basic Wayang Operators on the PostgresPlatform.
PostgresExecutionOperator
PostgresFilterOperator	PostgreSQL implementation of the FilterOperator.
PostgresJoinOperator<KeyType>	PostgreSQL implementation of the JoinOperator.
PostgresPlatform	Platform implementation for SQLite3.
PostgresPlugin	This Plugin enables to use some basic Wayang Operators on the PostgresPlatform.
PostgresProjectionOperator	PostgreSQL implementation of the FilterOperator.
PostgresTableSource	PostgreSQL implementation for the TableSource.
PredicateAdapter<InputType>	Wraps a Predicate as a Function.
PredicateDescriptor<Input>	This descriptor pertains to predicates that consume a single data unit.
PredictMapping	Mapping from PredictOperator to SparkPredictOperator.
PredictMapping	Mapping from PredictOperator to TensorflowPredictOperator.
PredictOperator<X,Y>
PredictOperators
PrintUtils
ProbabilisticDoubleInterval	An value representation that is capable of expressing uncertainty.
ProbabilisticIntervalEstimate	An estimate that is capable of expressing uncertainty.
ProcessFeeder<Input,Output>
ProcessReceiver<Output>
ProfileDB	This class provides facilities to save and load Experiments.
ProfileDBs	Utilities to work with ProfileDBs.
Profiler	Utility to support finding reasonable LoadProfileEstimators for JavaExecutionOperators.
ProfilingUtils	Utilities to fake Wayang internals etc..
ProjectionDescriptor<Input,Output>	This descriptor pertains to projections.
ProjectionMapping	/** Mapping from MapOperator to GenericJdbcProjectionOperator.
ProjectionMapping	/** Mapping from MapOperator to PostgresProjectionOperator.
ProjectionMapping	Mapping from MapOperator to Sqlite3ProjectionOperator.
ProjectMapFuncImpl
PushExecutorTemplate	Executor implementation that employs a push model, i.e., data quanta are "pushed" through the ExecutionStage.
PythonAPI
PythonProcessCaller
PythonWorkerManager<Input,Output>
PyWayangReduceByOperator<Type,Key>
RandomPruningStrategy	This PlanEnumerationPruningStrategy retains only the best k PlanImplementations.
RddChannel	Describes the situation where one JavaRDD is operated on, producing a further JavaRDD.
ReaderIterator<Output>
Record	A Type that represents a record with a schema, might be replaced with something standard like JPA entity.
RecordType	This is a specific BasicDataUnitType for Records.
ReduceByMapping	This mapping detects combinations of the GroupByOperator and ReduceOperator and merges them into a single ReduceByOperator.
ReduceByMapping	Mapping from ReduceByOperator to FlinkReduceByOperator.
ReduceByMapping	Mapping from ReduceByOperator to JavaReduceByOperator.
ReduceByMapping	Mapping from ReduceByOperator to SparkReduceByOperator.
ReduceByOperator<Type,Key>	This operator groups the elements of a data set and aggregates the groups.
ReduceDescriptor<Type>	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..
ReduceOperator<Type>	This operator is context dependent: after a GroupByOperator, it is meant to be a ReduceByOperator; otherwise, it is a GlobalReduceOperator.
ReduceWrapper<T>
ReferenceCountable	This interface provides a reference-counting scheme, e.g., to manage allocated external resources.
ReflectionUtils	Utilities for reflection code.
ReLU
RepeatMapping	This Mapping translates a RepeatOperator into a Subplan with the LoopOperator.
RepeatMapping	Mapping from RepeatOperator to FlinkRepeatOperator.
RepeatMapping	Mapping from RepeatOperator to JavaRepeatOperator.
RepeatMapping	Mapping from RepeatOperator to SparkRepeatOperator.
RepeatOperator<Type>	This Operator repeats a certain subplan of Operators for a given number of times.
ReplacementSubplanFactory	This factory takes an SubplanMatch and derives a replacement Subplan from it.
ReplacementSubplanFactory.OfSingleOperators<MatchedOperator extends Operator>	Implementation of the ReplacementSubplanFactory that replaces exactly one Operator with exactly one Operator, where both have the exact same InputSlots and OutputSlot in the exact same order.
ReservoirSampler<T>	Utility to do reservoir sampling with competitions over shared space.
Reshape
ReturnTuple	Tuple that is returned by Query 1.
revDataComparator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>
revDataComparator
RrdAccessor	Utility to read from an RRD file.
RunKMeans
RunSGD
S3FileSystem
Sample
SampleMapping	Mapping from SampleOperator to FlinkSampleOperator.
SampleMapping	Mapping from SampleOperator to JavaRandomSampleOperator.
SampleMapping	Mapping from SampleOperator to SparkRandomPartitionSampleOperator.
SampleOperator<Type>	A random sample operator randomly selects its inputs from the input slot and pushes that element to the output slot.
SampleOperator.Methods
Sampler<T>	Interface that describes a sampling algorithm that can give bias towards certain elements..
SanityChecker	This class checks a WayangPlan for several sanity criteria: Subplans must only be used as top-level Operator of OperatorAlternative.Alternative Subplans must contain more than one Operator
ScalaTupleSerializer
SchemaUtils
SerializableObject	The SerializableObject interface is a marker interface that indicates that its implementing classes are serializable.
SGDImpl	This class executes a stochastic gradient descent optimization on Apache Wayang (incubating).
SGDImprovedImpl	This class executes a stochastic gradient descent optimization on Apache Wayang (incubating), just like SGDImpl.
SGDLoop
SGDSample
SGDStageWithZeros
Sigmoid
SimpleEstimationContext	This EstimationContext implementation just stores all required variables without any further logic.
SinglePlatformPruningStrategy	This PlanEnumerationPruningStrategy retains only the best PlanImplementations employing a single Platform only.
SinkProfiler	OperatorProfiler implementation for sinks.
SinkProfiler	SparkOperatorProfiler implementation for SparkExecutionOperators with one input and no outputs.
Slice
Slot<T>	Abstract class for inputs and outputs to operators.
SlotMapping	This mapping can be used to encapsulate subplans by connecting slots (usually against the data flow direction, i.e., outer output slot to inner output slot, inner input slot to outer input slot).
Softmax
SortFilter
SortKeyExtractor
SortMapping	Mapping from SortOperator to FlinkSortOperator.
SortMapping	Mapping from SortOperator to JavaSortOperator.
SortMapping	Mapping from SortOperator to SparkSortOperator.
SortOperator<Type,Key>	This operator sorts the elements in this dataset.
SourceProfiler	OperatorProfiler implementation for sinks.
Spark	Register for relevant components of this module.
SparkBasicPlugin	This Plugin enables to use the basic Wayang Operators on the SparkPlatform.
SparkBernoulliSampleOperator<Type>	Spark implementation of the SparkBernoulliSampleOperator.
SparkBroadcastOperator<Type>	Takes care of creating a Broadcast that can be used later on.
SparkCacheOperator<Type>	Converts an uncached RddChannel into a cached RddChannel.
SparkCartesianOperator<InputType0,InputType1>	Spark implementation of the CartesianOperator.
SparkCoGroupOperator<In0,In1,Key>	Spark implementation of the JoinOperator.
SparkCollectionSource<Type>	Provides a Collection to a Spark job.
SparkCollectionSourceProfiler	SparkOperatorProfiler for the SparkTextFileSource.
SparkCollectOperator<Type>	Converts a RddChannel into a CollectionChannel of the JavaPlatform.
SparkContextReference	Wraps and manages a JavaSparkContext to avoid steady re-creation.
SparkConversionPlugin	This Plugin enables to create RDDs.
SparkCountOperator<Type>	Spark implementation of the CountOperator.
SparkDecisionTreeClassificationOperator
SparkDecisionTreeClassificationOperator.Model
SparkDecisionTreeRegressionOperator
SparkDecisionTreeRegressionOperator.Model
SparkDistinctOperator<Type>	Spark implementation of the DistinctOperator.
SparkDoWhileOperator<InputType,ConvergenceType>	Spark implementation of the DoWhileOperator.
SparkExecutionContext	ExecutionContext implementation for the SparkPlatform.
SparkExecutionOperator	Execution operator for the SparkPlatform.
SparkExecutor	Executor implementation for the SparkPlatform.
SparkFilterOperator<Type>	Spark implementation of the FilterOperator.
SparkFlatMapOperator<InputType,OutputType>	Spark implementation of the FlatMapOperator.
SparkGlobalMaterializedGroupOperator<Type>	Spark implementation of the GlobalMaterializedGroupOperator.
SparkGlobalReduceOperator<Type>	Spark implementation of the GlobalReduceOperator.
SparkGraphPlugin	This Plugin enables to use the basic Wayang Operators on the SparkPlatform.
SparkIEJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input extends Copyable<Input>>	Spark implementation of the IEJoinOperator.
SparkIESelfJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input extends Copyable<Input>>	Spark implementation of the IESelfJoinOperator.
SparkIntersectOperator<Type>	Spark implementation of the JoinOperator.
SparkJoinOperator<InputType0,InputType1,KeyType>	Spark implementation of the JoinOperator.
SparkKafkaTopicSink<T>	Implementation of the KafkaTopicSink operator for the Spark platform.
SparkKafkaTopicSource	Provides a Collection to a Spark job.
SparkKMeansOperator
SparkKMeansOperator.Model
SparkLinearRegressionOperator
SparkLinearRegressionOperator.Model
SparkLinearSVCOperator
SparkLinearSVCOperator.Model
SparkListener	A Spark listener implementation that captures events generated during the Spark job execution and sends them to a Kafka topic for further processing.
SparkLocalCallbackSink<T extends Serializable>	Implementation of the LocalCallbackSink operator for the Spark platform.
SparkLogisticRegressionOperator
SparkLogisticRegressionOperator.Model
SparkLoopOperator<InputType,ConvergenceType>	Spark implementation of the LoopOperator.
SparkMapOperator<InputType,OutputType>	Spark implementation of the MapOperator.
SparkMapPartitionsOperator<InputType,OutputType>	Spark implementation of the MapPartitionsOperator.
SparkMaterializedGroupByOperator<Type,KeyType>	Spark implementation of the MaterializedGroupByOperator.
SparkMLModel<X,Y>
SparkMLPlugin
SparkModelTransformOperator<X,Y>	Deprecated.
SparkObjectFileSink<T>	Operator for the SparkPlatform that creates a sequence file.
SparkObjectFileSource<T>	Operator for the SparkPlatform that creates a sequence file.
SparkOperatorProfiler	Allows to instrument an SparkExecutionOperator.
SparkOperatorProfiler.Result	The result of a single profiling run.
SparkParquetSource	Provides a Collection to a Spark job.
SparkPlatform	Platform for Apache Spark.
SparkPredictOperator<X,Y>
SparkRandomPartitionSampleOperator<Type>	Spark implementation of the SampleOperator.
SparkReduceByOperator<Type,KeyType>	Spark implementation of the ReduceByOperator.
SparkRepeatOperator<Type>	Spark implementation of the RepeatOperator.
SparkShufflePartitionSampleOperator<Type>	Spark implementation of the SparkShufflePartitionSampleOperator.
SparkSortOperator<Type,Key>	Spark implementation of the SortOperator.
SparkSourceProfiler	SparkOperatorProfiler implementation for SparkExecutionOperators with one input and one output.
SparkTextFileSink<T>	Implementation of the TextFileSink operator for the Spark platform.
SparkTextFileSource	Provides a Collection to a Spark job.
SparkTextFileSourceProfiler	SparkOperatorProfiler for the SparkTextFileSource.
SparkTsvFileSink<T extends Tuple2<?,?>>	Operator for the SparkPlatform that creates a TSV file.
SparkTsvFileSource<T>	Operator for the SparkPlatform that creates a sequence file.
SparkUnaryOperatorProfiler	SparkOperatorProfiler implementation for SparkExecutionOperators with one input and one output.
SparkUnionAllOperator<Type>	Spark implementation of the UnionAllOperator.
SparkZipWithIdOperator<InputType>	Spark implementation of the MapOperator.
SparseVector
SqlContext
Sqlite3	Register for relevant components of this module.
Sqlite3ConversionPlugin	This Plugin provides ChannelConversions from the Sqlite3Platform.
Sqlite3FilterOperator	Implementation of the FilterOperator for the Sqlite3Platform.
Sqlite3Platform	Platform implementation for SQLite3.
Sqlite3Plugin	This Plugin enables to use some basic Wayang Operators on the Sqlite3Platform.
Sqlite3ProjectionOperator	Implementation of the JdbcProjectionOperator for the Sqlite3Platform.
Sqlite3TableSource	Implementation of the TableSource for the Sqlite3Platform.
SqlQueryChannel	Implementation of a Channel that is given by a SQL query.
SqlQueryChannel.Descriptor	Describes a specific class of SqlQueryChannels belonging to a certain JdbcPlatformTemplate.
SqlToRddOperator
SqlToStreamOperator	This Operator converts SqlQueryChannels to StreamChannels.
SqlToStreamOperator.ResultSetIterator	Exposes a ResultSet as an Iterator.
Stage	This interface represents a stage in a data processing pipeline.
StageAssignmentTraversal	Builds an ExecutionPlan from a ExecutionTaskFlow.
StageAssignmentTraversal.StageSplittingCriterion	Criterion to futher split StageAssignmentTraversal.InterimStage besides precedence.
StageCompleted	Represents a completed stage in a distributed computing system.
StageExecutorMetrics	The StageExecutorMetrics class implements the Stage and SerializableObject interfaces and represents the metrics associated with a stage executed by an executor.
StageSubmitted	The StageSubmitted class implements the Stage and SerializableObject interfaces to represent a submitted stage in a distributed system.
StopWatch	Utility to create TimeMeasurements for an Experiment.
Storage	Controls how conducted experiments will be persisted and loaded
StreamChannel	Channel between two JavaExecutionOperators using a Stream.
StringUtil
Subject	The subject of an Experiment, e.g., an application or algorithm.
Subplan	A subplan encapsulates connected operators as a single operator.
SubplanCardinalityPusher	CardinalityPusher implementation for Subplans (but not for LoopSubplans!)
SubplanMatch	A subplan match correlates a SubplanPattern with its actually matched .
SubplanPattern	A subplan pattern describes a class of subplans in a WayangPlan.
SVMModel
SwitchForwardCardinalityEstimator	Forwards the CardinalityEstimate of any given InputSlot that is not null.
TableSource	UnarySource that provides the tuples from a database table.
Task	The Task interface represents a task in a distributed computing or data processing system.
Task.TaskStatusForRunning	The TaskStatusForRunning enum represents the possible statuses of a task while it is running.
TaskEnd	Represents the end status of a task execution.
TaskGettingResult	Represents the getting results of a task execution.
TaskMetric	The TaskMetric interface defines the methods used to set and retrieve performance metrics for a given task.
TaskMetric	This class represents the metrics for a task in the Apache Wayang monitoring system.
TaskStart	Represents the start status of a task execution.
TensorChannel
Tensorflow	Register for relevant components of this module.
TensorflowBatchNorm2D<T extends org.tensorflow.types.family.TNumber>
TensorflowBatchNorm3D<T extends org.tensorflow.types.family.TNumber>
TensorflowCollectionSource<Type>	Provides a Collection to a Tensorflow job.
TensorflowCollectOperator<Type>	Converts TensorChannel into a CollectionChannel
TensorflowContextReference
TensorflowConv2D<T extends org.tensorflow.types.family.TNumber>
TensorflowConv3D<T extends org.tensorflow.types.family.TNumber>
TensorflowConversionPlugin	This Plugin is a subset of the TensorflowPlugin and only ships the ChannelConversions.
TensorflowConvLSTM2D<T extends org.tensorflow.types.family.TNumber>
TensorflowConvLSTM2D.Cell<T extends org.tensorflow.types.family.TNumber>
TensorflowDLTrainingOperator
TensorflowExecutionOperator	Execution operator for the TensorflowPlatform.
TensorflowExecutor	Executor implementation for the TensorflowPlatform.
TensorflowLinear<T extends org.tensorflow.types.family.TNumber>
TensorflowModel
TensorflowPlatform	Platform for Tensorflow
TensorflowPlugin	This Plugin enables to use the Wayang Operators on the TensorflowPlatform.
TensorflowPredictOperator
TextFileSink<T>	This UnarySink writes all incoming data quanta to a text file.
TextFileSinkMapping	Mapping from TextFileSink to FlinkTextFileSink.
TextFileSinkMapping	Mapping from TextFileSink to JavaTextFileSink.
TextFileSinkMapping	Mapping from CollectionSource to SparkCollectionSource.
TextFileSource	This source reads a text file and outputs the lines as data units.
TextFileSourceMapping	Mapping from TextFileSource to FlinkTextFileSource.
TextFileSourceMapping	Mapping from TextFileSource to JavaTextFileSource.
TextFileSourceMapping	Mapping from CollectionSource to SparkCollectionSource.
TimeEstimate	An estimate of time (in milliseconds) expressed as a ProbabilisticIntervalEstimate.
TimeMeasurement	A Measurement that captures a certain amount of time in milliseconds.
TimeToCostConverter	This (linear) converter turns TimeEstimates into cost estimates.
TopDownPlanVisitor<Payload,Return>	Visitor (as in the Visitor Pattern) for WayangPlans.
TopKPruningStrategy	This PlanEnumerationPruningStrategy retains only the best k PlanImplementations.
TournamentSampler<T>	Sampling strategy that simulates a tournament between elements.
TPCHQ1WithJavaNative	Main class for the TPC-H app based on Apache Wayang (incubating).
Transform<R,V>
TransformationDescriptor<Input,Output>	This descriptor pertains to functions that consume a single data unit and output a single data unit.
TransformCSV
TransformPerPartitionWrapper<R,V>
TransformWrapper<R,V>
Transpose
Tuple<T0,T1>	A helper data structure to manage two values without creating new classes.
Tuple2<T0,T1>	A type for tuples.
Tuple5<T0,T1,T2,T3,T4>	A type for tuples.
Type
TypeConverter
UnaryOperation	An operation Expression.
UnaryOperatorProfiler	OperatorProfiler specifically for JavaExecutionOperators with a single InputSlot.
UnarySink<T>	Abstract base-class for sinks with a single input.
UnarySource<T>	Abstract base class for sources with a single output.
UnaryToUnaryOperator<InputType,OutputType>	This operator has a single input and a single output.
UnionAllMapping	Mapping from UnionAllOperator to FlinkUnionAllOperator.
UnionAllMapping	Mapping from UnionAllOperator to JavaUnionAllOperator.
UnionAllMapping	Mapping from UnionAllOperator to SparkUnionAllOperator.
UnionAllOperator<Type>	This Operator creates the union (bag semantics) of two .
Update<R,V>
UpdateLocal<R,V>
UpdateLocalWrapper<R,V>
UpdateWrapper<R,V>
Util
ValueProvider<Value>	Used by Configurations to provide some value.
ValueProvider.NotAvailableException
Variable	A variable Expression
Variable	A variable that can be altered by an optimization algorithm.
WayangAggregate
WayangAggregateVisitor
WayangAggregator	Class create a that generate aggregatorWrapper
WayangArrays	Utility for handling arrays.
WayangBasic	Activator for the basic Wayang package.
WayangBasicGraph	Activator for graph operations being executed with Wayang's basic operators.
WayangBasics	Register for plugins in the module.
WayangCollections	Utilities to operate Collections.
WayangContext	This is the entry point for users to work with Wayang.
WayangConvention
WayangConvergenceCriterion<T>	Class create a that generate aggregatorWrapper
WayangCrossJoinVisitor
WayangException	Exception that declares a problem of Wayang.
WayangFileOutputFormat<IT>	Wrapper for FileOutputFormat
WayangFilter
WayangFilterCriterion<T>	Class create a for use inside of the LoopOperators
WayangFilterVisitor
WayangJoin
WayangJoinVisitor
WayangJsonArray	JSONArray is the wrapper for the ArrayNode to enable the easy access to Json data TODO: the java doc is not done because is missing implementation and it performed some modification on the code
WayangJsonObj	JSONObject is the wrapper for the ObjectNode to enable the easy access to the json data TODO: the java doc is not done because is missing implementation and it performed some modification on the code
WayangListValue	Is a Wrapper for used in the criterion of the Loops
WayangMultiConditionJoinVisitor
WayangPlan	A Wayang plan consists of a set of Operators.
WayangProgram
WayangProject
WayangProjectVisitor
WayangRel
WayangRelConverter
WayangRules
WayangSchema
WayangSchemaBuilder
WayangSort
WayangSortRule	Rule that converts LogicalSort to Wayang convention WayangSort
WayangSortVisitor
WayangTable
WayangTableBuilder
WayangTableScan
WayangTableScanVisitor
WayangTableStatistic
WayangValue<T>	Implementation of Value of flink for use in Wayang
WeightsUpdate
WordCount
WordCount
WordCountOnKafkaTopic
WordCountParquet
WordCountWithJavaNativeAPI	Example Apache Wayang (incubating) App that does a word count -- the Hello World of Map/Reduce-like systems.
WrappedFlatMapDescriptor<Input,Output>
WrappedMapPartitionsDescriptor<Input,Output>
WrappedPredicateDescriptor<Input>
WrappedPythonFunction<Input,Output>
WrappedReduceDescriptor<Type>
WrappedTransformationDescriptor<Input,Output>
ZeroLike
ZeroMQMonitor	TODO: Implement
ZipWithIdMapping	Mapping from ZipWithIdOperator to FlinkZipWithIdOperator.
ZipWithIdMapping	Mapping from ZipWithIdMapping to a subplan.
ZipWithIdMapping	Mapping from ZipWithIdOperator to SparkZipWithIdOperator.
ZipWithIdOperator<InputType>	This operators attaches a unique ID to each input data quantum.