Hierarchy For All Packages

Package Hierarchies:

• org.apache.wayang.api.python,
• org.apache.wayang.api.python.executor,
• org.apache.wayang.api.python.function,
• org.apache.wayang.api.sql.calcite.convention,
• org.apache.wayang.api.sql.calcite.converter,
• org.apache.wayang.api.sql.calcite.jdbc,
• org.apache.wayang.api.sql.calcite.optimizer,
• org.apache.wayang.api.sql.calcite.rel,
• org.apache.wayang.api.sql.calcite.rules,
• org.apache.wayang.api.sql.calcite.schema,
• org.apache.wayang.api.sql.calcite.utils,
• org.apache.wayang.api.sql.context,
• org.apache.wayang.api.sql.sources.fs,
• org.apache.wayang.applications,
• org.apache.wayang.apps.grep,
• org.apache.wayang.apps.sgd,
• org.apache.wayang.apps.terasort,
• org.apache.wayang.apps.tpch,
• org.apache.wayang.apps.tpch.data,
• org.apache.wayang.apps.tpch.data.q1,
• org.apache.wayang.apps.wordcount,
• org.apache.wayang.basic,
• org.apache.wayang.basic.channels,
• org.apache.wayang.basic.data,
• org.apache.wayang.basic.function,
• org.apache.wayang.basic.mapping,
• org.apache.wayang.basic.model,
• org.apache.wayang.basic.model.op,
• org.apache.wayang.basic.model.op.nn,
• org.apache.wayang.basic.model.optimizer,
• org.apache.wayang.basic.operators,
• org.apache.wayang.basic.plugin,
• org.apache.wayang.basic.types,
• org.apache.wayang.commons.util.profiledb,
• org.apache.wayang.commons.util.profiledb.instrumentation,
• org.apache.wayang.commons.util.profiledb.json,
• org.apache.wayang.commons.util.profiledb.model,
• org.apache.wayang.commons.util.profiledb.model.measurement,
• org.apache.wayang.commons.util.profiledb.storage,
• org.apache.wayang.core.api,
• org.apache.wayang.core.api.configuration,
• org.apache.wayang.core.api.exception,
• org.apache.wayang.core.function,
• org.apache.wayang.core.mapping,
• org.apache.wayang.core.mathex,
• org.apache.wayang.core.monitor,
• org.apache.wayang.core.optimizer,
• org.apache.wayang.core.optimizer.cardinality,
• org.apache.wayang.core.optimizer.channels,
• org.apache.wayang.core.optimizer.costs,
• org.apache.wayang.core.optimizer.enumeration,
• org.apache.wayang.core.optimizer.partition,
• org.apache.wayang.core.plan.executionplan,
• org.apache.wayang.core.plan.wayangplan,
• org.apache.wayang.core.plan.wayangplan.traversal,
• org.apache.wayang.core.platform,
• org.apache.wayang.core.platform.lineage,
• org.apache.wayang.core.plugin,
• org.apache.wayang.core.profiling,
• org.apache.wayang.core.types,
• org.apache.wayang.core.util,
• org.apache.wayang.core.util.fs,
• org.apache.wayang.core.util.json,
• org.apache.wayang.core.util.mathex,
• org.apache.wayang.core.util.mathex.exceptions,
• org.apache.wayang.core.util.mathex.model,
• org.apache.wayang.flink,
• org.apache.wayang.flink.channels,
• org.apache.wayang.flink.compiler,
• org.apache.wayang.flink.compiler.criterion,
• org.apache.wayang.flink.execution,
• org.apache.wayang.flink.mapping,
• org.apache.wayang.flink.operators,
• org.apache.wayang.flink.platform,
• org.apache.wayang.flink.plugin,
• org.apache.wayang.genericjdbc,
• org.apache.wayang.genericjdbc.channels,
• org.apache.wayang.genericjdbc.execution,
• org.apache.wayang.genericjdbc.mapping,
• org.apache.wayang.genericjdbc.operators,
• org.apache.wayang.genericjdbc.platform,
• org.apache.wayang.genericjdbc.plugin,
• org.apache.wayang.giraph,
• org.apache.wayang.giraph.Algorithm,
• org.apache.wayang.giraph.channels,
• org.apache.wayang.giraph.execution,
• org.apache.wayang.giraph.mappings,
• org.apache.wayang.giraph.operators,
• org.apache.wayang.giraph.platform,
• org.apache.wayang.giraph.plugin,
• org.apache.wayang.iejoin,
• org.apache.wayang.iejoin.data,
• org.apache.wayang.iejoin.mapping,
• org.apache.wayang.iejoin.mapping.java,
• org.apache.wayang.iejoin.mapping.spark,
• org.apache.wayang.iejoin.operators,
• org.apache.wayang.iejoin.operators.java_helpers,
• org.apache.wayang.iejoin.operators.spark_helpers,
• org.apache.wayang.java,
• org.apache.wayang.java.channels,
• org.apache.wayang.java.compiler,
• org.apache.wayang.java.execution,
• org.apache.wayang.java.mapping,
• org.apache.wayang.java.mapping.graph,
• org.apache.wayang.java.operators,
• org.apache.wayang.java.operators.graph,
• org.apache.wayang.java.platform,
• org.apache.wayang.java.plugin,
• org.apache.wayang.jdbc.channels,
• org.apache.wayang.jdbc.compiler,
• org.apache.wayang.jdbc.execution,
• org.apache.wayang.jdbc.operators,
• org.apache.wayang.jdbc.platform,
• org.apache.wayang.ml4all.abstraction.api,
• org.apache.wayang.ml4all.abstraction.plan,
• org.apache.wayang.ml4all.abstraction.plan.wrappers,
• org.apache.wayang.ml4all.algorithms.kmeans,
• org.apache.wayang.ml4all.algorithms.sgd,
• org.apache.wayang.ml4all.examples,
• org.apache.wayang.ml4all.utils,
• org.apache.wayang.postgres,
• org.apache.wayang.postgres.channels,
• org.apache.wayang.postgres.mapping,
• org.apache.wayang.postgres.operators,
• org.apache.wayang.postgres.platform,
• org.apache.wayang.postgres.plugin,
• org.apache.wayang.profiler.data,
• org.apache.wayang.profiler.hardware,
• org.apache.wayang.profiler.java,
• org.apache.wayang.profiler.log,
• org.apache.wayang.profiler.log.sampling,
• org.apache.wayang.profiler.spark,
• org.apache.wayang.profiler.util,
• org.apache.wayang.spark,
• org.apache.wayang.spark.channels,
• org.apache.wayang.spark.compiler,
• org.apache.wayang.spark.execution,
• org.apache.wayang.spark.mapping,
• org.apache.wayang.spark.mapping.graph,
• org.apache.wayang.spark.mapping.ml,
• org.apache.wayang.spark.model,
• org.apache.wayang.spark.monitoring.interfaces,
• org.apache.wayang.spark.monitoring.metrics,
• org.apache.wayang.spark.operators,
• org.apache.wayang.spark.operators.ml,
• org.apache.wayang.spark.platform,
• org.apache.wayang.spark.plugin,
• org.apache.wayang.sqlite3,
• org.apache.wayang.sqlite3.channels,
• org.apache.wayang.sqlite3.mapping,
• org.apache.wayang.sqlite3.operators,
• org.apache.wayang.sqlite3.platform,
• org.apache.wayang.sqlite3.plugin,
• org.apache.wayang.tensorflow,
• org.apache.wayang.tensorflow.channels,
• org.apache.wayang.tensorflow.execution,
• org.apache.wayang.tensorflow.mapping,
• org.apache.wayang.tensorflow.model,
• org.apache.wayang.tensorflow.operators,
• org.apache.wayang.tensorflow.platform,
• org.apache.wayang.tensorflow.plugin

Class Hierarchy

• java.lang.Object
  • java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
    • java.util.HashMap<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • java.util.LinkedHashMap<K,V> (implements java.util.Map<K,V>)
        • org.apache.wayang.core.util.LruCache<K,V>
      • org.apache.wayang.core.util.MultiMap<K,V>
  • org.antlr.v4.runtime.tree.AbstractParseTreeVisitor<T> (implements org.antlr.v4.runtime.tree.ParseTreeVisitor<T>)
    • org.apache.wayang.core.mathex.MathExBaseVisitor<T> (implements org.apache.wayang.core.mathex.MathExVisitor<T>)
      • org.apache.wayang.core.util.mathex.ExpressionBuilder
  • org.apache.wayang.core.util.AbstractReferenceCountable (implements org.apache.wayang.core.util.ReferenceCountable)
    • org.apache.wayang.core.platform.ExecutionResourceTemplate (implements org.apache.wayang.core.platform.ExecutionResource)
      • org.apache.wayang.core.platform.AbstractChannelInstance (implements org.apache.wayang.core.platform.ChannelInstance)
        • org.apache.wayang.spark.channels.BroadcastChannel.Instance
        • org.apache.wayang.java.channels.CollectionChannel.Instance (implements org.apache.wayang.java.channels.JavaChannelInstance)
        • org.apache.wayang.flink.channels.DataSetChannel.Instance
        • org.apache.wayang.basic.channels.FileChannel.Instance
        • org.apache.wayang.spark.channels.RddChannel.Instance
        • org.apache.wayang.jdbc.channels.SqlQueryChannel.Instance
        • org.apache.wayang.java.channels.StreamChannel.Instance (implements org.apache.wayang.java.channels.JavaChannelInstance)
        • org.apache.wayang.tensorflow.channels.TensorChannel.Instance
      • org.apache.wayang.flink.execution.FlinkContextReference
      • org.apache.wayang.spark.execution.SparkContextReference
      • org.apache.wayang.tensorflow.execution.TensorflowContextReference
    • org.apache.wayang.core.platform.ExecutorTemplate (implements org.apache.wayang.core.platform.Executor)
      • org.apache.wayang.genericjdbc.execution.GenericJdbcExecutor
      • org.apache.wayang.giraph.execution.GiraphExecutor
      • org.apache.wayang.jdbc.execution.JdbcExecutor
      • org.apache.wayang.core.platform.PushExecutorTemplate
        • org.apache.wayang.flink.execution.FlinkExecutor
        • org.apache.wayang.java.execution.JavaExecutor
        • org.apache.wayang.spark.execution.SparkExecutor
      • org.apache.wayang.tensorflow.execution.TensorflowExecutor
  • org.apache.calcite.rel.AbstractRelNode (implements org.apache.calcite.rel.RelNode)
    • org.apache.calcite.rel.BiRel
      • org.apache.calcite.rel.core.Join (implements org.apache.calcite.rel.hint.Hintable)
        • org.apache.wayang.api.sql.calcite.rel.WayangJoin (implements org.apache.wayang.api.sql.calcite.rel.WayangRel)
    • org.apache.calcite.rel.SingleRel
      • org.apache.calcite.rel.core.Aggregate (implements org.apache.calcite.rel.hint.Hintable)
        • org.apache.wayang.api.sql.calcite.rel.WayangAggregate (implements org.apache.wayang.api.sql.calcite.rel.WayangRel)
      • org.apache.calcite.rel.core.Filter (implements org.apache.calcite.rel.hint.Hintable)
        • org.apache.wayang.api.sql.calcite.rel.WayangFilter (implements org.apache.wayang.api.sql.calcite.rel.WayangRel)
      • org.apache.calcite.rel.core.Project (implements org.apache.calcite.rel.hint.Hintable)
        • org.apache.wayang.api.sql.calcite.rel.WayangProject (implements org.apache.wayang.api.sql.calcite.rel.WayangRel)
    • org.apache.calcite.rel.core.TableScan (implements org.apache.calcite.rel.hint.Hintable)
      • org.apache.wayang.api.sql.calcite.rel.WayangTableScan (implements org.apache.wayang.api.sql.calcite.rel.WayangRel)
  • org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
    • org.apache.wayang.flink.compiler.criterion.WayangFilterCriterion<T> (implements org.apache.flink.api.common.functions.FilterFunction<T>)
  • org.apache.calcite.schema.impl.AbstractSchema (implements org.apache.calcite.schema.Schema)
    • org.apache.wayang.api.sql.calcite.schema.WayangSchema
  • org.apache.calcite.schema.impl.AbstractTable (implements org.apache.calcite.schema.Table, org.apache.calcite.schema.Wrapper)
    • org.apache.calcite.adapter.java.AbstractQueryableTable (implements org.apache.calcite.schema.QueryableTable)
      • org.apache.wayang.api.sql.calcite.jdbc.JdbcTable (implements org.apache.calcite.schema.ModifiableTable, org.apache.calcite.schema.ScannableTable, org.apache.calcite.schema.TranslatableTable)
    • org.apache.wayang.api.sql.calcite.schema.WayangTable
  • org.apache.wayang.core.plan.wayangplan.traversal.AbstractTopologicalTraversal<ActivatorType,ActivationType>
    • org.apache.wayang.core.optimizer.enumeration.ExecutionTaskFlowCompiler
  • org.apache.wayang.core.plan.wayangplan.traversal.AbstractTopologicalTraversal.Activation<TActivator>
    • org.apache.wayang.core.optimizer.enumeration.ExecutionTaskFlowCompiler.Activation
  • org.apache.wayang.core.plan.wayangplan.traversal.AbstractTopologicalTraversal.Activator<TActivation>
    • org.apache.wayang.core.optimizer.enumeration.ExecutionTaskFlowCompiler.Activator
  • org.apache.wayang.core.util.Actions
  • org.apache.wayang.iejoin.operators.spark_helpers.addUniqueID<Input> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>)
  • org.apache.wayang.ml4all.abstraction.plan.wrappers.AggregateWrapper<R> (implements org.apache.wayang.core.function.FunctionDescriptor.SerializableBinaryOperator<Type>)
  • org.apache.wayang.core.optimizer.cardinality.AggregatingCardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
  • org.apache.wayang.spark.monitoring.metrics.ApplicationEnd (implements org.apache.wayang.spark.monitoring.interfaces.Application, org.apache.wayang.spark.monitoring.interfaces.SerializableObject)
  • org.apache.wayang.spark.monitoring.metrics.ApplicationStart (implements org.apache.wayang.spark.monitoring.interfaces.Application, org.apache.wayang.spark.monitoring.interfaces.SerializableObject)
  • org.apache.wayang.core.platform.AtomicExecution
  • org.apache.wayang.core.platform.AtomicExecution.KeyOrLoadSerializer (implements org.apache.wayang.core.util.JsonSerializer<T>)
  • org.apache.wayang.core.platform.AtomicExecutionGroup
  • org.apache.wayang.core.platform.AtomicExecutionGroup.Serializer (implements org.apache.wayang.core.util.JsonSerializer<T>)
  • org.apache.wayang.spark.operators.ml.Attr
  • org.apache.wayang.core.util.mathex.model.BinaryOperation (implements org.apache.wayang.core.util.mathex.Expression)
  • org.apache.wayang.spark.compiler.BinaryOperatorAdapter<Type> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>)
  • org.apache.wayang.core.util.Bitmask (implements java.lang.Cloneable, java.lang.Iterable<T>)
  • org.apache.wayang.iejoin.operators.java_helpers.BitSetJoin<Type0,Type1,Input>
  • org.apache.wayang.iejoin.operators.spark_helpers.BitSetJoin<Type0,Type1> (implements org.apache.spark.api.java.function.PairFlatMapFunction<T,K,V>)
  • org.apache.wayang.iejoin.operators.spark_helpers.build2ListObject<TypeXPivot,TypeXRef,Input> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>)
  • org.apache.wayang.core.util.Canonicalizer<T> (implements java.util.Set<E>)
  • org.apache.wayang.core.platform.CardinalityBreakpoint (implements org.apache.wayang.core.platform.Breakpoint)
  • org.apache.wayang.core.optimizer.cardinality.CardinalityEstimationTraversal
  • org.apache.wayang.core.optimizer.cardinality.CardinalityEstimatorManager
  • org.apache.wayang.core.optimizer.cardinality.CardinalityPusher
    • org.apache.wayang.core.optimizer.cardinality.AbstractAlternativeCardinalityPusher
      • org.apache.wayang.core.optimizer.cardinality.LoopHeadAlternativeCardinalityPusher
      • org.apache.wayang.core.optimizer.cardinality.OperatorAlternativeCardinalityPusher
    • org.apache.wayang.core.optimizer.cardinality.DefaultCardinalityPusher
    • org.apache.wayang.core.optimizer.cardinality.LoopSubplanCardinalityPusher
    • org.apache.wayang.core.optimizer.cardinality.SubplanCardinalityPusher
  • org.apache.wayang.core.profiling.CardinalityRepository
  • org.apache.wayang.flink.mapping.CartesianMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.CartesianMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.CartesianMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.plan.executionplan.Channel
    • org.apache.wayang.spark.channels.BroadcastChannel
    • org.apache.wayang.java.channels.CollectionChannel
    • org.apache.wayang.flink.channels.DataSetChannel
    • org.apache.wayang.basic.channels.FileChannel
    • org.apache.wayang.spark.channels.RddChannel
    • org.apache.wayang.jdbc.channels.SqlQueryChannel
    • org.apache.wayang.java.channels.StreamChannel
    • org.apache.wayang.tensorflow.channels.TensorChannel
  • org.apache.wayang.core.optimizer.channels.ChannelConversion
    • org.apache.wayang.core.optimizer.channels.DefaultChannelConversion
  • org.apache.wayang.core.optimizer.channels.ChannelConversionGraph
  • org.apache.wayang.core.optimizer.channels.ChannelConversionGraph.CostbasedTreeSelectionStrategy
  • org.apache.wayang.core.optimizer.channels.ChannelConversionGraph.RandomTreeSelectionStrategy
  • org.apache.wayang.flink.channels.ChannelConversions
  • org.apache.wayang.giraph.channels.ChannelConversions
  • org.apache.wayang.java.channels.ChannelConversions
  • org.apache.wayang.postgres.channels.ChannelConversions
  • org.apache.wayang.spark.channels.ChannelConversions
  • org.apache.wayang.sqlite3.channels.ChannelConversions
  • org.apache.wayang.tensorflow.channels.ChannelConversions
  • org.apache.wayang.core.platform.ChannelDescriptor
    • org.apache.wayang.basic.channels.FileChannel.Descriptor
    • org.apache.wayang.jdbc.channels.SqlQueryChannel.Descriptor
  • org.apache.wayang.flink.mapping.CoGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.CoGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.CoGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.api.configuration.CollectionProvider<Value> (implements java.lang.Iterable<T>)
    • org.apache.wayang.core.api.configuration.ExplicitCollectionProvider<Value>
    • org.apache.wayang.core.api.configuration.FunctionalCollectionProvider<Value>
  • org.apache.wayang.flink.mapping.CollectionSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.CollectionSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.CollectionSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.tensorflow.mapping.CollectionSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.util.mathex.model.CompiledFunction (implements org.apache.wayang.core.util.mathex.Expression)
  • org.apache.wayang.core.api.Configuration (implements java.io.Serializable)
  • org.apache.wayang.core.platform.ConjunctiveBreakpoint (implements org.apache.wayang.core.platform.Breakpoint)
  • org.apache.wayang.core.util.mathex.model.Constant (implements org.apache.wayang.core.util.mathex.Expression)
  • org.apache.wayang.core.optimizer.costs.ConstantLoadProfileEstimator (implements org.apache.wayang.core.optimizer.costs.LoadProfileEstimator)
  • org.apache.wayang.core.util.ConsumerIteratorAdapter<T>
  • org.apache.wayang.tensorflow.model.Convertor
  • org.apache.wayang.core.util.Counter<T> (implements java.lang.Iterable<T>)
  • org.apache.wayang.flink.mapping.CountMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.CountMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.CountMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.platform.CrossPlatformExecutor (implements org.apache.wayang.core.platform.ExecutionState)
  • org.apache.wayang.core.util.CrossProductIterable<T> (implements java.lang.Iterable<T>)
  • org.apache.wayang.api.sql.sources.fs.CsvRowConverter
  • org.apache.wayang.iejoin.data.Data<Type0,Type1> (implements java.lang.Comparable<T>, java.io.Serializable)
  • org.apache.wayang.iejoin.data.Data.Comparator<Type0,Type1> (implements java.util.Comparator<T>, java.io.Serializable)
  • org.apache.wayang.jdbc.execution.DatabaseDescriptor
  • org.apache.wayang.iejoin.operators.java_helpers.DataComparator<Type0,Type1,Input> (implements java.util.Comparator<T>, java.io.Serializable)
  • org.apache.wayang.profiler.data.DataGenerators
  • org.apache.wayang.core.types.DataSetType<T> (implements java.io.Serializable)
  • org.apache.wayang.core.types.DataUnitType<T> (implements java.io.Serializable)
    • org.apache.wayang.core.types.BasicDataUnitType<T> (implements java.io.Serializable)
      • org.apache.wayang.basic.types.RecordType
    • org.apache.wayang.core.types.DataUnitGroupType<T>
  • org.apache.wayang.spark.mapping.ml.DecisionTreeClassificationMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.optimizer.cardinality.DefaultCardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator, java.io.Serializable)
  • org.apache.wayang.core.util.mathex.DefaultContext (implements org.apache.wayang.core.util.mathex.Context)
  • org.apache.wayang.core.optimizer.costs.DefaultEstimatableCost (implements org.apache.wayang.core.optimizer.costs.EstimatableCost)
  • org.apache.wayang.core.optimizer.costs.DefaultEstimatableCost.Factory (implements org.apache.wayang.core.optimizer.costs.EstimatableCostFactory)
  • org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E> (implements org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,V,E>)
    • org.apache.giraph.io.GiraphInputFormat<I,V,E>
      • org.apache.giraph.io.VertexInputFormat<I,V,E>
        • org.apache.giraph.io.formats.GeneratedVertexInputFormat<I,V,E>
          • org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankVertexInputFormat
    • org.apache.giraph.master.MasterCompute (implements org.apache.giraph.master.MasterAggregatorUsage, org.apache.giraph.master.MasterGlobalCommUsage, org.apache.hadoop.io.Writable)
      • org.apache.giraph.master.DefaultMasterCompute
        • org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankMasterCompute
    • org.apache.giraph.io.VertexOutputFormat<I,V,E>
      • org.apache.giraph.io.formats.TextVertexOutputFormat<I,V,E>
        • org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankVertexOutputFormat
    • org.apache.giraph.io.VertexWriter<I,V,E> (implements org.apache.giraph.io.SimpleVertexWriter<I,V,E>)
      • org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankVertexOutputFormat.PageRankVertexWriter
    • org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E> (implements org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerGlobalCommUsage)
      • org.apache.giraph.graph.AbstractComputation<I,V,E,M1,M2> (implements org.apache.giraph.graph.Computation<I,V,E,M1,M2>)
        • org.apache.giraph.graph.BasicComputation<I,V,E,M>
          • org.apache.wayang.giraph.Algorithm.PageRankAlgorithm
      • org.apache.giraph.io.VertexReader<I,V,E>
        • org.apache.giraph.examples.GeneratedVertexReader<I,V,E>
          • org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankVertexReader
      • org.apache.giraph.worker.WorkerContext (implements org.apache.giraph.worker.WorkerIndexUsage<I>, org.apache.hadoop.io.Writable)
        • org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankWorkerContext
  • org.apache.wayang.profiler.hardware.DiskProfiler
  • org.apache.wayang.flink.mapping.DistinctMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.DistinctMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.DistinctMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.model.DLModel (implements org.apache.wayang.basic.model.Model)
    • org.apache.wayang.tensorflow.model.TensorflowModel (implements java.lang.AutoCloseable)
  • org.apache.wayang.basic.operators.DLTrainingOperator.Option
  • org.apache.wayang.tensorflow.mapping.DLTrainingOperatorMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.mapping.DoWhileMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.DoWhileMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.DoWhileMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.compiler.criterion.DummyFilter<InputType> (implements org.apache.flink.api.common.functions.FilterFunction<T>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
  • org.apache.wayang.flink.compiler.criterion.DummyMap<InputType,OutputType> (implements org.apache.flink.api.common.functions.MapFunction<T,O>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
  • org.apache.wayang.profiler.log.DynamicEstimationContext (implements org.apache.wayang.core.optimizer.costs.EstimationContext)
  • org.apache.wayang.profiler.log.DynamicLoadProfileEstimator (implements org.apache.wayang.core.optimizer.costs.LoadProfileEstimator)
  • org.apache.wayang.profiler.log.DynamicLoadProfileEstimators
  • org.apache.wayang.core.plugin.DynamicPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.core.optimizer.partition.EnumerationAlternative
  • org.apache.wayang.core.optimizer.partition.EnumerationBranch
  • org.apache.wayang.core.profiling.ExecutionLog (implements java.lang.AutoCloseable)
  • org.apache.wayang.core.plan.executionplan.ExecutionPlan
  • org.apache.wayang.core.profiling.ExecutionPlanMeasurement.ChannelNode
  • org.apache.wayang.core.profiling.ExecutionPlanMeasurement.Link
  • org.apache.wayang.core.profiling.ExecutionPlanMeasurement.OperatorNode
  • org.apache.wayang.core.plan.executionplan.ExecutionStage
  • org.apache.wayang.core.plan.executionplan.ExecutionStageLoop
  • org.apache.wayang.core.plan.executionplan.ExecutionTask
  • org.apache.wayang.core.optimizer.enumeration.ExecutionTaskFlow
  • org.apache.wayang.spark.monitoring.metrics.ExecutorAdded (implements org.apache.wayang.spark.monitoring.interfaces.Executor, org.apache.wayang.spark.monitoring.interfaces.SerializableObject)
  • org.apache.wayang.spark.monitoring.metrics.ExecutorRemoved (implements org.apache.wayang.spark.monitoring.interfaces.Executor, org.apache.wayang.spark.monitoring.interfaces.SerializableObject)
  • org.apache.wayang.spark.monitoring.metrics.ExecutorUpdated (implements org.apache.wayang.spark.monitoring.interfaces.Executor, org.apache.wayang.spark.monitoring.interfaces.SerializableObject)
  • org.apache.wayang.commons.util.profiledb.model.Experiment
  • org.apache.wayang.core.util.ExplainTreeNode (implements org.apache.wayang.core.util.JsonSerializable)
  • org.apache.wayang.core.util.ExplainUtils
  • org.apache.wayang.spark.compiler.ExtendedBinaryOperatorAdapter<Type> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>)
  • org.apache.wayang.spark.compiler.ExtendedFlatMapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
  • org.apache.wayang.spark.compiler.ExtendedFunction<InputType,OutputType> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.wayang.spark.compiler.ExtendedMapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.wayang.spark.compiler.ExtendedMapPartitionsFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
  • org.apache.wayang.spark.compiler.ExtendedPredicateAdapater<Type> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.wayang.iejoin.operators.java_helpers.extractData<TypeXPivot,TypeXRef,Input>
  • org.apache.wayang.iejoin.operators.spark_helpers.extractData<TypeXPivot,TypeXRef,Input> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.wayang.core.optimizer.cardinality.FallbackCardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
  • org.apache.wayang.spark.channels.FileChannels
  • org.apache.wayang.core.util.fs.FileSystems
  • org.apache.wayang.core.util.fs.FileUtils
  • org.apache.wayang.flink.mapping.FilterMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.genericjdbc.mapping.FilterMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.FilterMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.postgres.mapping.FilterMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.FilterMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.sqlite3.mapping.FilterMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.iejoin.operators.spark_helpers.filterUnwantedBlocks<Type0,Type1> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.wayang.core.platform.FixBreakpoint (implements org.apache.wayang.core.platform.Breakpoint)
  • org.apache.wayang.core.optimizer.cardinality.FixedSizeCardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
  • org.apache.wayang.spark.compiler.FlatMapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
  • org.apache.wayang.flink.mapping.FlatMapMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.FlatMapMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.FlatMapMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.Flink
  • org.apache.wayang.flink.plugin.FlinkBasicPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.flink.compiler.FlinkCoGroupFunction<InputType0,InputType1,OutputType> (implements org.apache.flink.api.common.functions.CoGroupFunction<IN1,IN2,O>)
  • org.apache.wayang.flink.plugin.FlinkConversionPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.flink.execution.FlinkExecutionContext (implements org.apache.wayang.core.function.ExecutionContext, java.io.Serializable)
  • org.apache.wayang.flink.plugin.FlinkGraphPlugin
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.BuildOutgoingEdgeList (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.Dampener (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.EpsilonFilter (implements org.apache.flink.api.common.functions.FilterFunction<T>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.JoinVertexWithEdgesMatch (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
  • org.apache.wayang.flink.operators.FlinkPageRankOperator.RankAssigner (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
  • org.apache.wayang.core.util.Formats
  • org.apache.wayang.core.profiling.FullInstrumentationStrategy (implements org.apache.wayang.core.profiling.InstrumentationStrategy)
  • org.apache.wayang.flink.compiler.FunctionCompiler
  • org.apache.wayang.java.compiler.FunctionCompiler
  • org.apache.wayang.jdbc.compiler.FunctionCompiler
  • org.apache.wayang.spark.compiler.FunctionCompiler
  • org.apache.wayang.spark.compiler.FunctionCompiler.KeyExtractor<T,K> (implements org.apache.wayang.spark.compiler.FunctionCompiler.WayangSparkFunction, org.apache.spark.api.java.function.PairFunction<T,K,V>)
  • org.apache.wayang.spark.compiler.FunctionCompiler.Reducer<Type> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>, org.apache.wayang.spark.compiler.FunctionCompiler.WayangSparkFunction)
  • org.apache.wayang.core.function.FunctionDescriptor (implements java.io.Serializable)
    • org.apache.wayang.core.function.AggregationDescriptor<InputType,OutputType>
    • org.apache.wayang.core.function.ConsumerDescriptor<T>
    • org.apache.wayang.core.function.FlatMapDescriptor<Input,Output>
      • org.apache.wayang.api.python.function.WrappedFlatMapDescriptor<Input,Output>
    • org.apache.wayang.core.function.MapPartitionsDescriptor<Input,Output>
      • org.apache.wayang.api.python.function.WrappedMapPartitionsDescriptor<Input,Output>
    • org.apache.wayang.core.function.PredicateDescriptor<Input>
      • org.apache.wayang.api.python.function.WrappedPredicateDescriptor<Input>
    • org.apache.wayang.core.function.ReduceDescriptor<Type>
      • org.apache.wayang.api.python.function.WrappedReduceDescriptor<Type>
    • org.apache.wayang.core.function.TransformationDescriptor<Input,Output> (implements java.io.Serializable)
      • org.apache.wayang.basic.function.ProjectionDescriptor<Input,Output>
      • org.apache.wayang.api.python.function.WrappedTransformationDescriptor<Input,Output>
  • org.apache.wayang.genericjdbc.channels.GenericChannelConversions
  • org.apache.wayang.genericjdbc.GenericJdbc
  • org.apache.wayang.genericjdbc.plugin.GenericJdbcConversionsPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.genericjdbc.plugin.GenericJdbcPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.profiler.log.GeneticOptimizer
  • org.apache.wayang.profiler.log.GeneticOptimizerApp
  • org.apache.wayang.giraph.Giraph
  • org.apache.wayang.giraph.plugin.GiraphPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.flink.mapping.GlobalMaterializedGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.GlobalMaterializedGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.GlobalMaterializedGroupMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.mapping.GlobalReduceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.mapping.GlobalReduceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.GlobalReduceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.GlobalReduceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.apps.grep.Grep (implements java.io.Serializable)
  • org.apache.wayang.flink.mapping.GroupByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.apps.tpch.data.q1.GroupKey (implements java.io.Serializable)
  • org.apache.wayang.core.util.fs.HadoopFileSystem (implements org.apache.wayang.core.util.fs.FileSystem)
  • org.apache.wayang.iejoin.IEJoin
  • org.apache.wayang.iejoin.mapping.java.IEJoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.iejoin.mapping.spark.IEJoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.iejoin.operators.IEJoinMasterOperator
  • org.apache.wayang.iejoin.mapping.java.IESelfJoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.iejoin.mapping.spark.IESelfJoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.profiler.log.Individual
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.wayang.core.util.LimitedInputStream
  • org.apache.wayang.flink.mapping.IntersectMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.IntersectMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.IntersectMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.util.Iterators
  • org.apache.wayang.java.Java
  • org.apache.wayang.java.plugin.JavaBasicPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.java.plugin.JavaChannelConversionPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.java.execution.JavaExecutionContext (implements org.apache.wayang.core.function.ExecutionContext)
  • org.apache.wayang.java.plugin.JavaGraphPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.java.operators.JavaObjectFileSink.StreamChunker
  • org.apache.wayang.api.sql.calcite.jdbc.JdbcSchema (implements org.apache.calcite.schema.Schema)
  • org.apache.wayang.api.sql.calcite.jdbc.JdbcSchema.Factory (implements org.apache.calcite.schema.SchemaFactory)
  • org.apache.wayang.spark.monitoring.metrics.JobEnd (implements org.apache.wayang.spark.monitoring.interfaces.Job, org.apache.wayang.spark.monitoring.interfaces.SerializableObject)
  • org.apache.wayang.spark.monitoring.metrics.JobStart (implements org.apache.wayang.spark.monitoring.interfaces.Job, org.apache.wayang.spark.monitoring.interfaces.SerializableObject)
  • org.apache.wayang.flink.mapping.JoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.JoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.postgres.mapping.JoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.JoinMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.util.JsonSerializable.Serializer<T> (implements org.apache.wayang.core.util.JsonSerializer<T>)
  • org.apache.wayang.core.util.JsonSerializables
  • org.apache.wayang.core.util.JuelUtils
  • org.apache.wayang.core.util.JuelUtils.JuelFunction<T>
  • org.apache.wayang.core.platform.Junction
  • org.apache.wayang.java.mapping.KafkaTopicSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.KafkaTopicSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.operators.KafkaTopicSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
  • org.apache.wayang.java.mapping.KafkaTopicSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.KafkaTopicSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.compiler.KeySelectorDistinct<T> (implements org.apache.flink.api.java.functions.KeySelector<IN,KEY>, java.io.Serializable)
  • org.apache.wayang.flink.compiler.KeySelectorFunction<T,K> (implements org.apache.flink.api.java.functions.KeySelector<IN,KEY>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, java.io.Serializable)
  • org.apache.wayang.core.api.configuration.KeyValueProvider<Key,Value>
    • org.apache.wayang.core.api.configuration.FunctionalKeyValueProvider<Key,Value>
    • org.apache.wayang.core.api.configuration.MapBasedKeyValueProvider<Key,Value>
  • org.apache.wayang.spark.mapping.ml.KMeansMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.optimizer.enumeration.LatentOperatorPruningStrategy (implements org.apache.wayang.core.optimizer.enumeration.PlanEnumerationPruningStrategy)
  • org.apache.wayang.core.platform.lineage.LazyExecutionLineageNode
    • org.apache.wayang.core.platform.lineage.ChannelLineageNode
    • org.apache.wayang.core.platform.lineage.ExecutionLineageNode
  • org.apache.wayang.core.platform.lineage.LazyExecutionLineageNode.CollectingAggregator (implements org.apache.wayang.core.platform.lineage.LazyExecutionLineageNode.Aggregator<T>)
  • org.apache.wayang.spark.mapping.ml.LinearRegressionMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.apps.tpch.data.LineItemTuple (implements java.io.Serializable)
  • org.apache.wayang.apps.tpch.data.LineItemTuple.Parser
  • org.apache.wayang.iejoin.operators.spark_helpers.List2AttributesObjectSkinny<Type0,Type1> (implements java.io.Serializable)
  • org.apache.flink.types.ListValue<V> (implements java.util.List<E>, org.apache.flink.types.Value)
    • org.apache.wayang.flink.compiler.criterion.WayangListValue
  • org.apache.wayang.core.optimizer.costs.LoadEstimator
    • org.apache.wayang.core.optimizer.costs.DefaultLoadEstimator
    • org.apache.wayang.profiler.log.DynamicLoadEstimator
    • org.apache.wayang.core.optimizer.costs.IntervalLoadEstimator
  • org.apache.wayang.core.optimizer.costs.LoadProfile (implements org.apache.wayang.core.util.JsonSerializable, java.io.Serializable)
  • org.apache.wayang.core.optimizer.costs.LoadProfileEstimators
  • org.apache.wayang.core.optimizer.costs.LoadProfileToTimeConverter
  • org.apache.wayang.core.optimizer.costs.LoadToTimeConverter
  • org.apache.wayang.flink.mapping.LocalCallbackSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.LocalCallbackSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.LocalCallbackSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.util.fs.LocalFileSystem (implements org.apache.wayang.core.util.fs.FileSystem)
  • org.apache.wayang.profiler.log.LogEvaluator
  • org.apache.wayang.ml4all.abstraction.api.LogicalOperator (implements java.io.Serializable)
    • org.apache.wayang.ml4all.abstraction.api.Compute<R,V>
      • org.apache.wayang.ml4all.algorithms.sgd.ComputeLogisticGradient
      • org.apache.wayang.ml4all.algorithms.kmeans.KMeansCompute
    • org.apache.wayang.ml4all.abstraction.api.LocalStage
      • org.apache.wayang.ml4all.algorithms.kmeans.KMeansStageWithZeros
      • org.apache.wayang.ml4all.algorithms.sgd.SGDStageWithZeros
    • org.apache.wayang.ml4all.abstraction.api.Loop<R,V>
      • org.apache.wayang.ml4all.algorithms.kmeans.KMeansConvergeOrMaxIterationsLoop
      • org.apache.wayang.ml4all.algorithms.sgd.SGDLoop
    • org.apache.wayang.ml4all.abstraction.api.Sample
      • org.apache.wayang.ml4all.algorithms.sgd.SGDSample
    • org.apache.wayang.ml4all.abstraction.api.Transform<R,V>
      • org.apache.wayang.ml4all.algorithms.sgd.LibSVMTransform
      • org.apache.wayang.ml4all.algorithms.kmeans.TransformCSV
    • org.apache.wayang.ml4all.abstraction.api.Update<R,V>
      • org.apache.wayang.ml4all.algorithms.kmeans.KMeansUpdate
    • org.apache.wayang.ml4all.abstraction.api.UpdateLocal<R,V>
      • org.apache.wayang.ml4all.algorithms.sgd.WeightsUpdate
  • org.apache.wayang.ml4all.abstraction.plan.wrappers.LogicalOperatorWrapper<R,V> (implements org.apache.wayang.core.function.FunctionDescriptor.SerializableFunction<Input,Output>)
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.TransformPerPartitionWrapper<R,V>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.TransformWrapper<R,V>
  • org.apache.wayang.ml4all.abstraction.plan.wrappers.LogicalOperatorWrapperWithModel<R,V> (implements org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableFunction<Input,Output>)
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.AssignWrapper<R>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.AssignWrapperLocal<V>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.ComputePerPartitionWrapper<R,V>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.ComputeWrapper<R,V>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.LoopCheckWrapper<V>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.LoopConvergenceWrapper<R,V>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.UpdateLocalWrapper<R,V>
    • org.apache.wayang.ml4all.abstraction.plan.wrappers.UpdateWrapper<R,V>
  • org.apache.wayang.core.optimizer.enumeration.LoopImplementation
  • org.apache.wayang.core.optimizer.enumeration.LoopImplementation.IterationImplementation
  • org.apache.wayang.flink.mapping.LoopMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.LoopMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.LoopMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.apps.wordcount.Main
  • org.apache.wayang.profiler.spark.Main
  • org.apache.wayang.spark.compiler.MapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.wayang.flink.mapping.MapMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.MapMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.MapMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.compiler.MapPartitionsFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
  • org.apache.wayang.flink.mapping.MapPartitionsMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.MapPartitionsMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.MapPartitionsMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.mapping.Mappings
  • org.apache.wayang.flink.mapping.Mappings
  • org.apache.wayang.genericjdbc.mapping.Mappings
  • org.apache.wayang.giraph.mappings.Mappings
  • org.apache.wayang.iejoin.mapping.Mappings
  • org.apache.wayang.java.mapping.Mappings
  • org.apache.wayang.postgres.mapping.Mappings
  • org.apache.wayang.spark.mapping.Mappings
  • org.apache.wayang.sqlite3.mapping.Mappings
  • org.apache.wayang.tensorflow.mapping.Mappings
  • org.apache.wayang.basic.mapping.MaterializedGroupByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.mapping.MaterializedGroupByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.MaterializedGroupByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.MaterializedGroupByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.mathex.MathExBaseListener (implements org.apache.wayang.core.mathex.MathExListener)
  • org.apache.wayang.commons.util.profiledb.model.Measurement
    • org.apache.wayang.core.profiling.CostMeasurement
    • org.apache.wayang.core.profiling.ExecutionPlanMeasurement
    • org.apache.wayang.core.profiling.PartialExecutionMeasurement
    • org.apache.wayang.core.plan.wayangplan.PlanMetrics
    • org.apache.wayang.commons.util.profiledb.model.measurement.TimeMeasurement
  • org.apache.wayang.commons.util.profiledb.json.MeasurementDeserializer (implements com.google.gson.JsonDeserializer<T>)
  • org.apache.wayang.commons.util.profiledb.json.MeasurementSerializer (implements com.google.gson.JsonSerializer<T>)
  • org.apache.wayang.ml4all.abstraction.plan.ML4allModel (implements java.io.Serializable)
  • org.apache.wayang.ml4all.abstraction.plan.ML4allPlan
  • org.apache.wayang.api.sql.calcite.utils.ModelParser
  • org.apache.wayang.spark.mapping.ml.ModelTransformMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.monitor.Monitor
    • org.apache.wayang.core.monitor.DisabledMonitor
    • org.apache.wayang.core.monitor.FileMonitor
    • org.apache.wayang.core.monitor.HttpMonitor
    • org.apache.wayang.core.monitor.ZeroMQMonitor
  • org.apache.wayang.iejoin.operators.java_helpers.myMergeSort<Type0,Type1,Input>
  • org.apache.wayang.iejoin.operators.spark_helpers.myMergeSort<Type0,Type1>
  • org.apache.wayang.core.util.mathex.model.NamedFunction (implements org.apache.wayang.core.util.mathex.Expression)
  • org.apache.wayang.core.optimizer.costs.NestableLoadProfileEstimator (implements org.apache.wayang.core.optimizer.costs.LoadProfileEstimator)
  • org.apache.wayang.core.profiling.NoInstrumentationStrategy (implements org.apache.wayang.core.profiling.InstrumentationStrategy)
  • org.apache.wayang.core.platform.NoIterationBreakpoint (implements org.apache.wayang.core.platform.Breakpoint)
  • org.apache.wayang.flink.mapping.ObjectFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.ObjectFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.ObjectFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.operators.ObjectFileSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
  • org.apache.wayang.flink.mapping.ObjectFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.ObjectFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.ObjectFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.util.OneTimeExecutable
    • org.apache.wayang.core.api.Job
    • org.apache.wayang.core.optimizer.enumeration.LoopEnumerator
    • org.apache.wayang.core.plan.wayangplan.LoopIsolator
    • org.apache.wayang.core.platform.PushExecutorTemplate.StageExecution
    • org.apache.wayang.core.optimizer.enumeration.StageAssignmentTraversal
  • org.apache.wayang.basic.model.op.Op (implements java.io.Serializable)
    • org.apache.wayang.basic.model.op.ArgMax
    • org.apache.wayang.basic.model.op.Cast
    • org.apache.wayang.basic.model.op.nn.CrossEntropyLoss
    • org.apache.wayang.basic.model.op.Eq
    • org.apache.wayang.basic.model.op.Input
    • org.apache.wayang.basic.model.op.nn.Linear
    • org.apache.wayang.basic.model.op.Mean
    • org.apache.wayang.basic.model.op.nn.ReLU
    • org.apache.wayang.basic.model.op.nn.Sigmoid
    • org.apache.wayang.basic.model.op.nn.Softmax
  • org.apache.wayang.core.plan.wayangplan.OperatorAlternative.Alternative (implements org.apache.wayang.core.plan.wayangplan.OperatorContainer, java.io.Serializable)
  • org.apache.wayang.core.plan.wayangplan.OperatorBase (implements org.apache.wayang.core.plan.wayangplan.Operator, java.io.Serializable)
    • org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator<InputType0,InputType1,OutputType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.basic.operators.CartesianOperator<InputType0,InputType1>
        • org.apache.wayang.flink.operators.FlinkCartesianOperator<InputType0,InputType1> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaCartesianOperator<InputType0,InputType1> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkCartesianOperator<InputType0,InputType1> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.CoGroupOperator<InputType0,InputType1,Key>
        • org.apache.wayang.flink.operators.FlinkCoGroupOperator<InputType0,InputType1,TypeKey> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaCoGroupOperator<InputType0,InputType1,KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkCoGroupOperator<In0,In1,Key> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.DecisionTreeClassificationOperator
        • org.apache.wayang.spark.operators.ml.SparkDecisionTreeClassificationOperator (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.DLTrainingOperator<X,Y>
        • org.apache.wayang.tensorflow.operators.TensorflowDLTrainingOperator (implements org.apache.wayang.tensorflow.operators.TensorflowExecutionOperator)
      • org.apache.wayang.iejoin.operators.IEJoinOperator<Type0,Type1,Input>
        • org.apache.wayang.iejoin.operators.JavaIEJoinOperator<Type0,Type1,Input> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.iejoin.operators.SparkIEJoinOperator<Type0,Type1,Input> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.IntersectOperator<Type>
        • org.apache.wayang.flink.operators.FlinkIntersectOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaIntersectOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkIntersectOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.JoinOperator<InputType0,InputType1,Key>
        • org.apache.wayang.flink.operators.FlinkJoinOperator<InputType0,InputType1,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaJoinOperator<InputType0,InputType1,KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.jdbc.operators.JdbcJoinOperator<KeyType> (implements org.apache.wayang.jdbc.operators.JdbcExecutionOperator)
          • org.apache.wayang.postgres.operators.PostgresJoinOperator<KeyType> (implements org.apache.wayang.postgres.operators.PostgresExecutionOperator)
        • org.apache.wayang.spark.operators.SparkJoinOperator<InputType0,InputType1,KeyType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.LinearRegressionOperator
        • org.apache.wayang.spark.operators.ml.SparkLinearRegressionOperator (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ModelTransformOperator<X,Y>
        • org.apache.wayang.spark.operators.ml.SparkModelTransformOperator<X,Y> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.PredictOperator<X,Y>
        • org.apache.wayang.spark.operators.ml.SparkPredictOperator<X,Y> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
        • org.apache.wayang.tensorflow.operators.TensorflowPredictOperator (implements org.apache.wayang.tensorflow.operators.TensorflowExecutionOperator)
      • org.apache.wayang.basic.operators.UnionAllOperator<Type>
        • org.apache.wayang.flink.operators.FlinkUnionAllOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaUnionAllOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkUnionAllOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • org.apache.wayang.basic.operators.DoWhileOperator<InputType,ConvergenceType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator, org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
      • org.apache.wayang.flink.operators.FlinkDoWhileOperator<InputType,ConvergenceType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.java.operators.JavaDoWhileOperator<InputType,ConvergenceType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.spark.operators.SparkDoWhileOperator<InputType,ConvergenceType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • org.apache.wayang.basic.operators.LoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator, org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
      • org.apache.wayang.flink.operators.FlinkLoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.java.operators.JavaLoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.spark.operators.SparkLoopOperator<InputType,ConvergenceType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.OperatorAlternative (implements org.apache.wayang.core.plan.wayangplan.CompositeOperator, java.io.Serializable)
      • org.apache.wayang.core.plan.wayangplan.LoopHeadAlternative (implements org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
    • org.apache.wayang.core.mapping.OperatorPattern<T>
    • org.apache.wayang.basic.operators.RepeatOperator<Type> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator, org.apache.wayang.core.plan.wayangplan.LoopHeadOperator)
      • org.apache.wayang.flink.operators.FlinkRepeatExpandedOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.flink.operators.FlinkRepeatOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.java.operators.JavaRepeatOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.spark.operators.SparkRepeatOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.Subplan (implements org.apache.wayang.core.plan.wayangplan.ActualOperator, org.apache.wayang.core.plan.wayangplan.CompositeOperator, org.apache.wayang.core.plan.wayangplan.OperatorContainer)
      • org.apache.wayang.core.plan.wayangplan.LoopSubplan
    • org.apache.wayang.core.mapping.SubplanPattern
    • org.apache.wayang.core.plan.wayangplan.UnarySink<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.flink.operators.FlinkTsvFileSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.java.operators.JavaTsvFileSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.basic.operators.KafkaTopicSink<T> (implements java.io.Serializable)
        • org.apache.wayang.java.operators.JavaKafkaTopicSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkKafkaTopicSink<T> (implements java.io.Serializable, org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.LocalCallbackSink<T>
        • org.apache.wayang.flink.operators.FlinkLocalCallbackSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaLocalCallbackSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkLocalCallbackSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ObjectFileSink<T>
        • org.apache.wayang.flink.operators.FlinkObjectFileSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaObjectFileSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkObjectFileSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkTsvFileSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.TextFileSink<T>
        • org.apache.wayang.flink.operators.FlinkTextFileSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaTextFileSink<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkTextFileSink<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.UnarySource<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.basic.operators.CollectionSource<T> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
        • org.apache.wayang.flink.operators.FlinkCollectionSource<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaCollectionSource<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkCollectionSource<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
        • org.apache.wayang.tensorflow.operators.TensorflowCollectionSource<Type> (implements org.apache.wayang.tensorflow.operators.TensorflowExecutionOperator)
      • org.apache.wayang.api.sql.sources.fs.JavaCSVTableSource<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.java.operators.JavaTsvFileSource<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.basic.operators.KafkaTopicSource
        • org.apache.wayang.java.operators.JavaKafkaTopicSource (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkKafkaTopicSource (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ObjectFileSource<T>
        • org.apache.wayang.flink.operators.FlinkObjectFileSource<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaObjectFileSource<T> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkObjectFileSource<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkTsvFileSource<T> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.TableSource
        • org.apache.wayang.jdbc.operators.JdbcTableSource (implements org.apache.wayang.jdbc.operators.JdbcExecutionOperator)
          • org.apache.wayang.genericjdbc.operators.GenericJdbcTableSource (implements org.apache.wayang.genericjdbc.operators.GenericJdbcExecutionOperator)
          • org.apache.wayang.postgres.operators.PostgresTableSource (implements org.apache.wayang.postgres.operators.PostgresExecutionOperator)
          • org.apache.wayang.sqlite3.operators.Sqlite3TableSource
      • org.apache.wayang.basic.operators.TextFileSource
        • org.apache.wayang.flink.operators.FlinkTextFileSource (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaTextFileSource (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkTextFileSource (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
    • org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator<InputType,OutputType> (implements org.apache.wayang.core.plan.wayangplan.ElementaryOperator)
      • org.apache.wayang.basic.operators.CountOperator<Type>
        • org.apache.wayang.flink.operators.FlinkCountOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaCountOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkCountOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.DistinctOperator<Type>
        • org.apache.wayang.flink.operators.FlinkDistinctOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaDistinctOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkDistinctOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.FilterOperator<Type>
        • org.apache.wayang.flink.operators.FlinkFilterOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaFilterOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.jdbc.operators.JdbcFilterOperator (implements org.apache.wayang.jdbc.operators.JdbcExecutionOperator)
          • org.apache.wayang.genericjdbc.operators.GenericJdbcFilterOperator (implements org.apache.wayang.genericjdbc.operators.GenericJdbcExecutionOperator)
          • org.apache.wayang.postgres.operators.PostgresFilterOperator (implements org.apache.wayang.postgres.operators.PostgresExecutionOperator)
          • org.apache.wayang.sqlite3.operators.Sqlite3FilterOperator
        • org.apache.wayang.spark.operators.SparkFilterOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.FlatMapOperator<InputType,OutputType>
        • org.apache.wayang.flink.operators.FlinkFlatMapOperator<InputType,OutputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaFlatMapOperator<InputType,OutputType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkFlatMapOperator<InputType,OutputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.flink.operators.FlinkCollectionSink<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.genericjdbc.operators.GenericSqlToStreamOperator (implements org.apache.wayang.java.operators.JavaExecutionOperator, org.apache.wayang.core.util.JsonSerializable)
      • org.apache.wayang.basic.operators.GlobalMaterializedGroupOperator<Type>
        • org.apache.wayang.flink.operators.FlinkGlobalMaterializedGroupOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaGlobalMaterializedGroupOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkGlobalMaterializedGroupOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.GlobalReduceOperator<Type>
        • org.apache.wayang.flink.operators.FlinkGlobalReduceOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaGlobalReduceOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkGlobalReduceOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.GroupByOperator<Input,Key>
        • org.apache.wayang.flink.operators.FlinkGroupByOperator<InputType,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
      • org.apache.wayang.iejoin.operators.IESelfJoinOperator<Type0,Type1,Input>
        • org.apache.wayang.iejoin.operators.JavaIESelfJoinOperator<Type0,Type1,Input> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.iejoin.operators.SparkIESelfJoinOperator<Type0,Type1,Input> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.java.operators.JavaCollectOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.basic.operators.KMeansOperator
        • org.apache.wayang.spark.operators.ml.SparkKMeansOperator (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.MapOperator<InputType,OutputType>
        • org.apache.wayang.flink.operators.FlinkMapOperator<InputType,OutputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaMapOperator<InputType,OutputType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.jdbc.operators.JdbcProjectionOperator (implements org.apache.wayang.jdbc.operators.JdbcExecutionOperator)
          • org.apache.wayang.genericjdbc.operators.GenericJdbcProjectionOperator (implements org.apache.wayang.genericjdbc.operators.GenericJdbcExecutionOperator)
          • org.apache.wayang.postgres.operators.PostgresProjectionOperator (implements org.apache.wayang.postgres.operators.PostgresExecutionOperator)
          • org.apache.wayang.sqlite3.operators.Sqlite3ProjectionOperator
        • org.apache.wayang.spark.operators.SparkMapOperator<InputType,OutputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.MapPartitionsOperator<InputType,OutputType>
        • org.apache.wayang.flink.operators.FlinkMapPartitionsOperator<InputType,OutputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaMapPartitionsOperator<InputType,OutputType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkMapPartitionsOperator<InputType,OutputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.MaterializedGroupByOperator<Type,Key>
        • org.apache.wayang.flink.operators.FlinkMaterializedGroupByOperator<Type,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaMaterializedGroupByOperator<Type,KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkMaterializedGroupByOperator<Type,KeyType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.PageRankOperator
        • org.apache.wayang.flink.operators.FlinkPageRankOperator (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.giraph.operators.GiraphPageRankOperator (implements org.apache.wayang.giraph.operators.GiraphExecutionOperator)
        • org.apache.wayang.java.operators.graph.JavaPageRankOperator (implements org.apache.wayang.java.operators.JavaExecutionOperator)
      • org.apache.wayang.basic.operators.PyWayangReduceByOperator<Type,Key>
      • org.apache.wayang.basic.operators.ReduceByOperator<Type,Key>
        • org.apache.wayang.flink.operators.FlinkReduceByOperator<InputType,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaReduceByOperator<Type,KeyType> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkReduceByOperator<Type,KeyType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.ReduceOperator<Type>
      • org.apache.wayang.basic.operators.SampleOperator<Type>
        • org.apache.wayang.flink.operators.FlinkSampleOperator<Type> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaRandomSampleOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.java.operators.JavaReservoirSampleOperator<Type> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkBernoulliSampleOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
        • org.apache.wayang.spark.operators.SparkRandomPartitionSampleOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
        • org.apache.wayang.spark.operators.SparkShufflePartitionSampleOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.basic.operators.SortOperator<Type,Key>
        • org.apache.wayang.flink.operators.FlinkSortOperator<InputType,KeyType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.java.operators.JavaSortOperator<Type,Key> (implements org.apache.wayang.java.operators.JavaExecutionOperator)
        • org.apache.wayang.spark.operators.SparkSortOperator<Type,Key> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkBroadcastOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkCacheOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.spark.operators.SparkCollectOperator<Type> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.jdbc.operators.SqlToRddOperator (implements org.apache.wayang.core.util.JsonSerializable, org.apache.wayang.spark.operators.SparkExecutionOperator)
      • org.apache.wayang.jdbc.operators.SqlToStreamOperator (implements org.apache.wayang.java.operators.JavaExecutionOperator, org.apache.wayang.core.util.JsonSerializable)
      • org.apache.wayang.tensorflow.operators.TensorflowCollectOperator<Type> (implements org.apache.wayang.tensorflow.operators.TensorflowExecutionOperator)
      • org.apache.wayang.basic.operators.ZipWithIdOperator<InputType>
        • org.apache.wayang.flink.operators.FlinkZipWithIdOperator<InputType> (implements org.apache.wayang.flink.operators.FlinkExecutionOperator)
        • org.apache.wayang.spark.operators.SparkZipWithIdOperator<InputType> (implements org.apache.wayang.spark.operators.SparkExecutionOperator)
  • org.apache.wayang.core.plan.wayangplan.OperatorBase.GsonSerializer (implements com.google.gson.JsonDeserializer<T>, com.google.gson.JsonSerializer<T>)
  • org.apache.wayang.core.plan.wayangplan.OperatorContainers (implements java.io.Serializable)
  • org.apache.wayang.core.mapping.OperatorMatch
  • org.apache.wayang.profiler.java.OperatorProfiler
    • org.apache.wayang.profiler.java.BinaryOperatorProfiler
    • org.apache.wayang.profiler.java.SinkProfiler
    • org.apache.wayang.profiler.java.SourceProfiler
      • org.apache.wayang.profiler.java.JavaCollectionSourceProfiler
      • org.apache.wayang.profiler.java.JavaTextFileSourceProfiler
    • org.apache.wayang.profiler.java.UnaryOperatorProfiler
  • org.apache.wayang.profiler.java.OperatorProfiler.Result
  • org.apache.wayang.profiler.java.OperatorProfilers
  • org.apache.wayang.profiler.spark.OperatorProfilers
  • org.apache.wayang.core.plan.wayangplan.Operators
  • org.apache.wayang.core.optimizer.OptimizationContext
    • org.apache.wayang.core.optimizer.AggregateOptimizationContext
    • org.apache.wayang.core.optimizer.DefaultOptimizationContext
  • org.apache.wayang.core.optimizer.OptimizationContext.LoopContext
  • org.apache.wayang.core.optimizer.OptimizationContext.OperatorContext (implements org.apache.wayang.core.optimizer.costs.EstimationContext)
  • org.apache.wayang.profiler.log.OptimizationSpace
  • org.apache.wayang.core.optimizer.OptimizationUtils
  • org.apache.wayang.api.sql.calcite.optimizer.Optimizer
  • org.apache.wayang.basic.model.optimizer.Optimizer
    • org.apache.wayang.basic.model.optimizer.Adam
    • org.apache.wayang.basic.model.optimizer.GradientDescent
  • org.apache.wayang.api.sql.calcite.optimizer.Optimizer.ConfigProperties
  • org.apache.wayang.core.util.Optional<T>
  • org.apache.wayang.core.profiling.OutboundInstrumentationStrategy (implements org.apache.wayang.core.profiling.InstrumentationStrategy)
  • org.apache.wayang.flink.compiler.OutputFormatConsumer<T> (implements org.apache.flink.api.common.io.OutputFormat<IT>, java.io.Serializable)
  • org.apache.wayang.applications.OutputSerializer (implements org.apache.wayang.core.function.FunctionDescriptor.SerializableFunction<Input,Output>)
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • java.io.FilterOutputStream
      • org.apache.wayang.flink.compiler.WayangFileOutputFormat.BlockBasedOutput
  • org.apache.wayang.basic.mapping.PageRankMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.mapping.PageRankMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.giraph.mappings.PageRankMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.graph.PageRankMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.graph.PageRankMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.mapping.PageRankMapping.RankInitializer (implements org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableFunction<Input,Output>)
  • org.apache.wayang.giraph.Algorithm.PageRankParameters
  • org.apache.wayang.core.platform.PartialExecution
  • org.apache.wayang.core.platform.PartialExecution.Serializer (implements org.apache.wayang.core.util.JsonSerializer<T>)
  • org.apache.wayang.core.optimizer.enumeration.PlanEnumeration
  • org.apache.wayang.core.optimizer.enumeration.PlanEnumerator
  • org.apache.wayang.core.optimizer.enumeration.PlanEnumerator.ConcatenationActivator
  • org.apache.wayang.core.optimizer.enumeration.PlanEnumerator.EnumerationActivator
  • org.apache.wayang.core.optimizer.enumeration.PlanImplementation
  • org.apache.wayang.core.mapping.PlanTransformation
  • org.apache.wayang.core.plan.wayangplan.PlanTraversal
  • org.apache.wayang.core.platform.Platform
    • org.apache.wayang.flink.platform.FlinkPlatform
    • org.apache.wayang.giraph.platform.GiraphPlatform
    • org.apache.wayang.java.platform.JavaPlatform
    • org.apache.wayang.jdbc.platform.JdbcPlatformTemplate
      • org.apache.wayang.genericjdbc.platform.GenericJdbcPlatform
      • org.apache.wayang.postgres.platform.PostgresPlatform
      • org.apache.wayang.sqlite3.platform.Sqlite3Platform
    • org.apache.wayang.spark.platform.SparkPlatform
    • org.apache.wayang.tensorflow.platform.TensorflowPlatform
  • org.apache.wayang.core.plan.executionplan.PlatformExecution
  • org.apache.wayang.postgres.Postgres
  • org.apache.wayang.postgres.plugin.PostgresConversionsPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.postgres.plugin.PostgresPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.spark.compiler.PredicateAdapter<InputType> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.wayang.spark.mapping.ml.PredictMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.tensorflow.mapping.PredictMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.operators.PredictOperators
  • org.apache.wayang.api.sql.calcite.utils.PrintUtils
  • org.apache.wayang.core.optimizer.ProbabilisticDoubleInterval (implements java.io.Serializable)
  • org.apache.wayang.core.optimizer.ProbabilisticIntervalEstimate (implements java.io.Serializable)
    • org.apache.wayang.core.optimizer.cardinality.CardinalityEstimate (implements org.apache.wayang.core.util.JsonSerializable, java.io.Serializable)
    • org.apache.wayang.core.optimizer.costs.LoadEstimate (implements org.apache.wayang.core.util.JsonSerializable, java.io.Serializable)
    • org.apache.wayang.core.optimizer.costs.TimeEstimate
  • org.apache.wayang.api.python.executor.ProcessFeeder<Input,Output>
  • org.apache.wayang.api.python.executor.ProcessReceiver<Output>
  • org.apache.wayang.commons.util.profiledb.ProfileDB
  • org.apache.wayang.core.profiling.ProfileDBs
  • org.apache.wayang.profiler.java.Profiler
  • org.apache.wayang.profiler.util.ProfilingUtils
  • org.apache.wayang.genericjdbc.mapping.ProjectionMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.postgres.mapping.ProjectionMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.sqlite3.mapping.ProjectionMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.api.python.PythonAPI
  • org.apache.wayang.api.python.executor.PythonProcessCaller
  • org.apache.wayang.api.python.executor.PythonWorkerManager<Input,Output>
  • org.apache.wayang.core.optimizer.enumeration.RandomPruningStrategy (implements org.apache.wayang.core.optimizer.enumeration.PlanEnumerationPruningStrategy)
  • org.apache.wayang.api.python.executor.ReaderIterator<Output> (implements java.util.Iterator<E>)
  • org.antlr.v4.runtime.Recognizer<Symbol,ATNInterpreter>
    • org.antlr.v4.runtime.Lexer (implements org.antlr.v4.runtime.TokenSource)
      • org.apache.wayang.core.mathex.MathExLexer
    • org.antlr.v4.runtime.Parser
      • org.apache.wayang.core.mathex.MathExParser
  • org.apache.wayang.basic.data.Record (implements org.apache.wayang.core.util.Copyable<Self>, java.io.Serializable)
  • org.apache.wayang.basic.mapping.ReduceByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.mapping.ReduceByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.ReduceByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.ReduceByMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.ml4all.abstraction.plan.wrappers.ReduceWrapper<T> (implements org.apache.wayang.core.function.FunctionDescriptor.SerializableBinaryOperator<Type>)
  • org.apache.wayang.core.util.ReflectionUtils
  • org.apache.wayang.basic.mapping.RepeatMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.flink.mapping.RepeatMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.RepeatMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.RepeatMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.mapping.ReplacementSubplanFactory
    • org.apache.wayang.core.mapping.ReplacementSubplanFactory.OfSingleOperators<MatchedOperator>
  • org.apache.wayang.profiler.log.sampling.ReservoirSampler<T> (implements org.apache.wayang.profiler.log.sampling.Sampler<T>)
  • org.apache.wayang.apps.tpch.data.q1.ReturnTuple (implements java.io.Serializable)
  • org.apache.wayang.iejoin.operators.java_helpers.revDataComparator<Type0,Type1,Input> (implements java.util.Comparator<T>, java.io.Serializable)
  • org.apache.wayang.iejoin.operators.spark_helpers.revDataComparator (implements java.util.Comparator<T>, java.io.Serializable)
  • org.apache.flink.api.common.io.RichOutputFormat<IT> (implements org.apache.flink.api.common.io.OutputFormat<IT>)
    • org.apache.flink.api.common.io.FileOutputFormat<IT> (implements org.apache.flink.api.common.io.CleanupWhenUnsuccessful, org.apache.flink.api.common.io.InitializeOnMaster)
      • org.apache.wayang.flink.compiler.WayangFileOutputFormat<IT> (implements org.apache.flink.api.common.io.CleanupWhenUnsuccessful, org.apache.flink.api.common.io.InitializeOnMaster)
  • org.apache.wayang.profiler.util.RrdAccessor (implements java.lang.AutoCloseable)
  • org.antlr.v4.runtime.RuleContext (implements org.antlr.v4.runtime.tree.RuleNode)
    • org.antlr.v4.runtime.ParserRuleContext
      • org.apache.wayang.core.mathex.MathExParser.ExpressionContext
        • org.apache.wayang.core.mathex.MathExParser.BinaryOperationContext
        • org.apache.wayang.core.mathex.MathExParser.ConstantContext
        • org.apache.wayang.core.mathex.MathExParser.FunctionContext
        • org.apache.wayang.core.mathex.MathExParser.ParensExpressionContext
        • org.apache.wayang.core.mathex.MathExParser.UnaryOperationContext
        • org.apache.wayang.core.mathex.MathExParser.VariableContext
  • org.apache.wayang.ml4all.examples.RunKMeans
  • org.apache.wayang.ml4all.examples.RunSGD
  • org.apache.wayang.core.util.fs.S3FileSystem (implements org.apache.wayang.core.util.fs.FileSystem)
  • org.apache.wayang.flink.mapping.SampleMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.SampleMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.SampleMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.core.optimizer.SanityChecker
  • org.apache.wayang.api.sql.calcite.schema.SchemaUtils
  • org.apache.wayang.apps.sgd.SGDImpl
  • org.apache.wayang.apps.sgd.SGDImprovedImpl
  • org.apache.wayang.core.optimizer.costs.SimpleEstimationContext (implements org.apache.wayang.core.optimizer.costs.EstimationContext)
  • org.apache.wayang.core.optimizer.enumeration.SinglePlatformPruningStrategy (implements org.apache.wayang.core.optimizer.enumeration.PlanEnumerationPruningStrategy)
  • org.apache.wayang.core.plan.wayangplan.Slot<T> (implements java.io.Serializable)
    • org.apache.wayang.core.plan.wayangplan.InputSlot<T> (implements java.io.Serializable)
    • org.apache.wayang.core.plan.wayangplan.OutputSlot<T>
  • org.apache.wayang.core.plan.wayangplan.SlotMapping (implements java.io.Serializable)
  • org.apache.wayang.flink.mapping.SortMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.SortMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.SortMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.Spark
  • org.apache.wayang.spark.plugin.SparkBasicPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.spark.plugin.SparkConversionPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.spark.operators.ml.SparkDecisionTreeClassificationOperator.Model (implements org.apache.wayang.basic.model.DecisionTreeClassificationModel, org.apache.wayang.spark.model.SparkMLModel<X,Y>)
  • org.apache.wayang.spark.execution.SparkExecutionContext (implements org.apache.wayang.core.function.ExecutionContext, java.io.Serializable)
  • org.apache.wayang.spark.plugin.SparkGraphPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.spark.operators.ml.SparkKMeansOperator.Model (implements org.apache.wayang.basic.model.KMeansModel, org.apache.wayang.spark.model.SparkMLModel<X,Y>)
  • org.apache.wayang.spark.operators.ml.SparkLinearRegressionOperator.Model (implements org.apache.wayang.basic.model.LinearRegressionModel, org.apache.wayang.spark.model.SparkMLModel<X,Y>)
  • org.apache.spark.scheduler.SparkListener (implements org.apache.spark.scheduler.SparkListenerInterface)
    • org.apache.wayang.spark.monitoring.metrics.SparkListener
  • org.apache.wayang.spark.plugin.SparkMLPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.profiler.spark.SparkOperatorProfiler
    • org.apache.wayang.profiler.spark.BinaryOperatorProfiler
    • org.apache.wayang.profiler.spark.SinkProfiler
    • org.apache.wayang.profiler.spark.SparkSourceProfiler
      • org.apache.wayang.profiler.spark.SparkCollectionSourceProfiler
      • org.apache.wayang.profiler.spark.SparkTextFileSourceProfiler
    • org.apache.wayang.profiler.spark.SparkUnaryOperatorProfiler
  • org.apache.wayang.profiler.spark.SparkOperatorProfiler.Result
  • org.apache.wayang.ml4all.utils.SparseVector (implements java.io.Serializable)
  • org.apache.wayang.sqlite3.Sqlite3
  • org.apache.wayang.sqlite3.plugin.Sqlite3ConversionPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.sqlite3.plugin.Sqlite3Plugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.jdbc.operators.SqlToStreamOperator.ResultSetIterator (implements java.lang.AutoCloseable, java.util.Iterator<E>)
  • org.apache.wayang.spark.monitoring.metrics.StageCompleted (implements org.apache.wayang.spark.monitoring.interfaces.SerializableObject, org.apache.wayang.spark.monitoring.interfaces.Stage)
  • org.apache.wayang.spark.monitoring.metrics.StageExecutorMetrics (implements org.apache.wayang.spark.monitoring.interfaces.SerializableObject, org.apache.wayang.spark.monitoring.interfaces.Stage)
  • org.apache.wayang.spark.monitoring.metrics.StageSubmitted (implements org.apache.wayang.spark.monitoring.interfaces.SerializableObject, org.apache.wayang.spark.monitoring.interfaces.Stage)
  • org.apache.wayang.commons.util.profiledb.instrumentation.StopWatch
  • org.apache.wayang.commons.util.profiledb.storage.Storage
    • org.apache.wayang.commons.util.profiledb.storage.FileStorage
    • org.apache.wayang.commons.util.profiledb.storage.JDBCStorage
  • org.apache.wayang.ml4all.utils.StringUtil
  • org.apache.wayang.commons.util.profiledb.model.Subject
  • org.apache.wayang.core.mapping.SubplanMatch
  • org.apache.wayang.core.optimizer.cardinality.SwitchForwardCardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
  • org.apache.wayang.spark.monitoring.metrics.TaskEnd (implements org.apache.wayang.spark.monitoring.interfaces.SerializableObject, org.apache.wayang.spark.monitoring.interfaces.Task)
  • org.apache.wayang.spark.monitoring.metrics.TaskGettingResult (implements org.apache.wayang.spark.monitoring.interfaces.SerializableObject, org.apache.wayang.spark.monitoring.interfaces.Task)
  • org.apache.wayang.spark.monitoring.metrics.TaskMetric (implements org.apache.wayang.spark.monitoring.interfaces.SerializableObject, org.apache.wayang.spark.monitoring.interfaces.TaskMetric)
  • org.apache.wayang.spark.monitoring.metrics.TaskStart (implements org.apache.wayang.spark.monitoring.interfaces.SerializableObject, org.apache.wayang.spark.monitoring.interfaces.Task)
  • org.apache.wayang.tensorflow.Tensorflow
  • org.apache.wayang.tensorflow.plugin.TensorflowConversionPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.tensorflow.plugin.TensorflowPlugin (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.flink.mapping.TextFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.TextFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.TextFileSinkMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.basic.operators.TextFileSource.CardinalityEstimator (implements org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator)
  • org.apache.wayang.flink.mapping.TextFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.TextFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.TextFileSourceMapping (implements org.apache.wayang.core.mapping.Mapping)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.wayang.core.util.mathex.exceptions.MathExException
          • org.apache.wayang.core.util.mathex.exceptions.EvaluationException
          • org.apache.wayang.core.util.mathex.exceptions.ParseException
        • org.apache.wayang.core.api.exception.WayangException
          • org.apache.wayang.core.plan.wayangplan.traversal.AbstractTopologicalTraversal.AbortException
          • org.apache.wayang.core.api.configuration.KeyValueProvider.NoSuchKeyException
          • org.apache.wayang.core.api.configuration.ValueProvider.NotAvailableException
  • org.apache.wayang.core.optimizer.costs.TimeToCostConverter
  • org.apache.wayang.core.plan.wayangplan.TopDownPlanVisitor<Payload,Return>
  • org.apache.wayang.core.optimizer.enumeration.TopKPruningStrategy (implements org.apache.wayang.core.optimizer.enumeration.PlanEnumerationPruningStrategy)
  • org.apache.wayang.profiler.log.sampling.TournamentSampler<T> (implements org.apache.wayang.profiler.log.sampling.Sampler<T>)
  • org.apache.wayang.apps.tpch.TPCHQ1WithJavaNative
  • org.apache.wayang.core.util.Tuple<T0,T1>
  • org.apache.wayang.basic.data.Tuple2<T0,T1> (implements java.io.Serializable)
  • org.apache.wayang.basic.data.Tuple5<T0,T1,T2,T3,T4> (implements java.io.Serializable)
  • org.apache.wayang.core.util.TypeConverter
  • org.apache.wayang.core.util.mathex.model.UnaryOperation (implements org.apache.wayang.core.util.mathex.Expression)
  • org.apache.wayang.flink.mapping.UnionAllMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.UnionAllMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.UnionAllMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.applications.Util (implements java.io.Serializable)
  • org.apache.wayang.core.api.configuration.ValueProvider<Value>
    • org.apache.wayang.core.api.configuration.ConstantValueProvider<Value>
    • org.apache.wayang.core.api.configuration.FunctionalValueProvider<Value>
  • org.apache.wayang.core.util.mathex.model.Variable (implements org.apache.wayang.core.util.mathex.Expression)
  • org.apache.wayang.profiler.log.Variable
  • org.apache.wayang.api.sql.calcite.converter.WayangAggregateVisitor
  • org.apache.wayang.flink.compiler.criterion.WayangAggregator (implements org.apache.flink.api.common.aggregators.Aggregator<T>)
  • org.apache.wayang.core.util.WayangArrays
  • org.apache.wayang.basic.plugin.WayangBasic (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.basic.plugin.WayangBasicGraph (implements org.apache.wayang.core.plugin.Plugin)
  • org.apache.wayang.basic.WayangBasics
  • org.apache.wayang.core.util.WayangCollections
  • org.apache.wayang.core.api.WayangContext
    • org.apache.wayang.api.sql.context.SqlContext
  • org.apache.wayang.flink.compiler.criterion.WayangConvergenceCriterion<T> (implements org.apache.flink.api.common.aggregators.ConvergenceCriterion<T>, java.io.Serializable)
  • org.apache.wayang.api.sql.calcite.converter.WayangFilterVisitor
  • org.apache.wayang.api.sql.calcite.converter.WayangJoinVisitor
  • org.apache.wayang.core.util.json.WayangJsonArray (implements java.lang.Iterable<T>)
  • org.apache.wayang.core.util.json.WayangJsonObj
  • org.apache.wayang.core.plan.wayangplan.WayangPlan
  • org.apache.wayang.api.sql.calcite.optimizer.WayangProgram (implements org.apache.calcite.tools.Program)
  • org.apache.wayang.api.sql.calcite.converter.WayangProjectVisitor
  • org.apache.wayang.api.sql.calcite.converter.WayangRelConverter
  • org.apache.wayang.api.sql.calcite.rules.WayangRules
  • org.apache.wayang.api.sql.calcite.schema.WayangSchemaBuilder
  • org.apache.wayang.api.sql.calcite.schema.WayangTableBuilder
  • org.apache.wayang.api.sql.calcite.converter.WayangTableScanVisitor
  • org.apache.wayang.api.sql.calcite.schema.WayangTableStatistic (implements org.apache.calcite.schema.Statistic)
  • org.apache.wayang.flink.compiler.criterion.WayangValue<T> (implements org.apache.flink.types.Value)
  • org.apache.wayang.applications.WordCount
  • org.apache.wayang.apps.wordcount.WordCount
  • org.apache.wayang.applications.WordCountOnKafkaTopic
  • org.apache.wayang.apps.wordcount.WordCountWithJavaNativeAPI
  • org.apache.wayang.api.python.function.WrappedPythonFunction<Input,Output> (implements org.apache.wayang.core.function.FunctionDescriptor.SerializableFunction<Input,Output>)
  • org.apache.wayang.flink.mapping.ZipWithIdMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.java.mapping.ZipWithIdMapping (implements org.apache.wayang.core.mapping.Mapping)
  • org.apache.wayang.spark.mapping.ZipWithIdMapping (implements org.apache.wayang.core.mapping.Mapping)

Interface Hierarchy

• org.apache.wayang.core.util.Action
• org.apache.wayang.profiler.log.sampling.Battle<T>
• java.util.function.BiFunction<T,U,R>
  • java.util.function.BinaryOperator<T>
    • org.apache.wayang.core.function.FunctionDescriptor.SerializableBinaryOperator<Type> (also extends java.io.Serializable)
      • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableBinaryOperator<Type> (also extends org.apache.wayang.core.function.ExtendedFunction)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableBiFunction<Input0,Input1,Output> (also extends java.io.Serializable)
  • org.apache.wayang.api.sql.calcite.jdbc.JdbcSchema.Foo
• org.apache.wayang.core.platform.Breakpoint
• org.apache.wayang.core.plan.executionplan.ChannelInitializer
• java.lang.Cloneable
  • org.apache.calcite.rel.RelNode (also extends org.apache.calcite.plan.RelOptNode)
    • org.apache.wayang.api.sql.calcite.rel.WayangRel
• java.util.function.Consumer<T>
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableConsumer<T> (also extends java.io.Serializable)
    • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableConsumer<T> (also extends org.apache.wayang.core.function.ExtendedFunction)
• org.apache.wayang.core.util.mathex.Context
• org.apache.wayang.core.util.Copyable<Self>
• org.apache.wayang.profiler.log.DynamicLoadEstimator.SinglePointEstimator
• org.apache.wayang.core.optimizer.costs.EstimatableCost
• org.apache.wayang.core.optimizer.costs.EstimatableCostFactory
• org.apache.wayang.core.optimizer.costs.EstimationContext
• org.apache.wayang.core.function.ExecutionContext
• org.apache.wayang.core.platform.ExecutionState
• org.apache.wayang.core.platform.Executor.Factory
• org.apache.wayang.core.util.mathex.Expression
• org.apache.wayang.core.function.ExtendedFunction
  • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableBinaryOperator<Type> (also extends org.apache.wayang.core.function.FunctionDescriptor.SerializableBinaryOperator<Type>)
  • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableConsumer<T> (also extends org.apache.wayang.core.function.FunctionDescriptor.SerializableConsumer<T>)
  • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableFunction<Input,Output> (also extends org.apache.wayang.core.function.FunctionDescriptor.SerializableFunction<Input,Output>)
  • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializablePredicate<T> (also extends org.apache.wayang.core.function.FunctionDescriptor.SerializablePredicate<T>)
• org.apache.wayang.core.util.fs.FileSystem
• java.util.function.Function<T,R>
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableFunction<Input,Output> (also extends java.io.Serializable)
    • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableFunction<Input,Output> (also extends org.apache.wayang.core.function.ExtendedFunction)
• org.apache.wayang.spark.compiler.FunctionCompiler.WayangSparkFunction
• org.apache.wayang.core.profiling.InstrumentationStrategy
• java.util.function.IntUnaryOperator
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableIntUnaryOperator (also extends java.io.Serializable)
• org.apache.wayang.core.util.JsonSerializable
• org.apache.wayang.core.util.JsonSerializer<T>
• org.apache.wayang.core.platform.lineage.LazyExecutionLineageNode.Aggregator<T>
• org.apache.wayang.core.optimizer.costs.LoadProfileEstimator
• org.apache.wayang.core.optimizer.costs.LoadProfileToTimeConverter.ResourceTimeEstimateAggregator
• org.apache.wayang.core.util.Logging
• java.util.function.LongUnaryOperator
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableLongUnaryOperator (also extends java.io.Serializable)
• org.apache.wayang.core.mapping.Mapping
• org.apache.wayang.core.plan.wayangplan.Operator
  • org.apache.wayang.core.plan.wayangplan.ActualOperator
    • org.apache.wayang.core.plan.wayangplan.ElementaryOperator
      • org.apache.wayang.core.plan.wayangplan.ExecutionOperator
        • org.apache.wayang.flink.operators.FlinkExecutionOperator (also extends java.io.Serializable)
        • org.apache.wayang.giraph.operators.GiraphExecutionOperator
        • org.apache.wayang.java.operators.JavaExecutionOperator
        • org.apache.wayang.jdbc.operators.JdbcExecutionOperator
          • org.apache.wayang.genericjdbc.operators.GenericJdbcExecutionOperator
          • org.apache.wayang.postgres.operators.PostgresExecutionOperator
        • org.apache.wayang.spark.operators.SparkExecutionOperator
        • org.apache.wayang.tensorflow.operators.TensorflowExecutionOperator
  • org.apache.wayang.core.plan.wayangplan.CompositeOperator
  • org.apache.wayang.core.plan.wayangplan.LoopHeadOperator
• org.antlr.v4.runtime.tree.ParseTreeListener
  • org.apache.wayang.core.mathex.MathExListener
• org.antlr.v4.runtime.tree.ParseTreeVisitor<T>
  • org.apache.wayang.core.mathex.MathExVisitor<T>
• org.apache.wayang.core.optimizer.enumeration.PlanEnumerationPruningStrategy
• org.apache.wayang.core.plan.wayangplan.PlanTraversal.Callback
• org.apache.wayang.core.plan.wayangplan.PlanTraversal.SimpleCallback
• org.apache.wayang.core.plugin.Plugin
• java.util.function.Predicate<T>
  • org.apache.wayang.core.function.FunctionDescriptor.SerializablePredicate<T> (also extends java.io.Serializable)
    • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializablePredicate<T> (also extends org.apache.wayang.core.function.ExtendedFunction)
• org.apache.wayang.core.util.ReferenceCountable
  • org.apache.wayang.core.platform.ExecutionResource
    • org.apache.wayang.core.platform.ChannelInstance
      • org.apache.wayang.java.channels.JavaChannelInstance
    • org.apache.wayang.core.platform.CompositeExecutionResource
      • org.apache.wayang.core.platform.Executor
• org.apache.calcite.plan.RelOptNode
  • org.apache.calcite.rel.RelNode (also extends java.lang.Cloneable)
    • org.apache.wayang.api.sql.calcite.rel.WayangRel
• org.apache.wayang.profiler.log.sampling.Sampler<T>
• java.io.Serializable
  • org.apache.wayang.spark.monitoring.interfaces.Application
  • org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator
  • org.apache.wayang.profiler.data.DataGenerators.Generator<T> (also extends java.util.function.Supplier<T>)
  • org.apache.wayang.spark.monitoring.interfaces.Executor
  • org.apache.wayang.flink.operators.FlinkExecutionOperator (also extends org.apache.wayang.core.plan.wayangplan.ExecutionOperator)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableBiFunction<Input0,Input1,Output> (also extends java.util.function.BiFunction<T,U,R>)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableBinaryOperator<Type> (also extends java.util.function.BinaryOperator<T>)
    • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableBinaryOperator<Type> (also extends org.apache.wayang.core.function.ExtendedFunction)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableConsumer<T> (also extends java.util.function.Consumer<T>)
    • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableConsumer<T> (also extends org.apache.wayang.core.function.ExtendedFunction)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableFunction<Input,Output> (also extends java.util.function.Function<T,R>)
    • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializableFunction<Input,Output> (also extends org.apache.wayang.core.function.ExtendedFunction)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableIntUnaryOperator (also extends java.util.function.IntUnaryOperator)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableLongUnaryOperator (also extends java.util.function.LongUnaryOperator)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializablePredicate<T> (also extends java.util.function.Predicate<T>)
    • org.apache.wayang.core.function.FunctionDescriptor.ExtendedSerializablePredicate<T> (also extends org.apache.wayang.core.function.ExtendedFunction)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableToDoubleBiFunction<T,U> (also extends java.util.function.ToDoubleBiFunction<T,U>)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableToLongBiFunction<T,U> (also extends java.util.function.ToLongBiFunction<T,U>)
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableToLongFunction<T> (also extends java.util.function.ToLongFunction<T>)
  • org.apache.wayang.spark.monitoring.interfaces.Job
  • org.apache.wayang.core.optimizer.costs.LoadEstimator.SinglePointEstimationFunction
  • org.apache.wayang.basic.model.Model
    • org.apache.wayang.basic.model.DecisionTreeClassificationModel
    • org.apache.wayang.basic.model.KMeansModel
    • org.apache.wayang.basic.model.LinearRegressionModel
    • org.apache.wayang.spark.model.SparkMLModel<X,Y>
  • org.apache.wayang.core.plan.wayangplan.OperatorContainer
  • org.apache.wayang.spark.monitoring.interfaces.SerializableObject
    • org.apache.wayang.spark.monitoring.interfaces.Task
  • org.apache.wayang.spark.monitoring.interfaces.Stage
  • org.apache.wayang.spark.monitoring.interfaces.TaskMetric
• org.apache.wayang.core.optimizer.enumeration.StageAssignmentTraversal.StageSplittingCriterion
• java.util.function.Supplier<T>
  • org.apache.wayang.profiler.data.DataGenerators.Generator<T> (also extends java.io.Serializable)
• java.util.function.ToDoubleBiFunction<T,U>
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableToDoubleBiFunction<T,U> (also extends java.io.Serializable)
• java.util.function.ToLongBiFunction<T,U>
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableToLongBiFunction<T,U> (also extends java.io.Serializable)
• java.util.function.ToLongFunction<T>
  • org.apache.wayang.core.function.FunctionDescriptor.SerializableToLongFunction<T> (also extends java.io.Serializable)

Annotation Type Hierarchy

• org.apache.wayang.core.plan.wayangplan.EstimationContextProperty (implements java.lang.annotation.Annotation)
• org.apache.wayang.commons.util.profiledb.model.Type (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.wayang.iejoin.operators.IEJoinMasterOperator.JoinCondition
    • org.apache.wayang.basic.model.op.Input.Type
    • org.apache.wayang.core.plan.wayangplan.LoopHeadOperator.State
    • org.apache.wayang.basic.model.op.Op.DType
    • org.apache.wayang.giraph.Algorithm.PageRankParameters.PageRankEnum
    • org.apache.wayang.ml4all.abstraction.plan.Platforms
    • org.apache.wayang.basic.operators.SampleOperator.Methods
    • org.apache.wayang.spark.monitoring.interfaces.Task.TaskStatusForRunning
    • org.apache.wayang.api.sql.calcite.convention.WayangConvention (implements org.apache.calcite.plan.Convention)