Path	Lines of Code
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/WayangBasics.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels/FileChannel.java	139
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java	96
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple2.java	38
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple5.java	56
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java	107
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/GlobalReduceMapping.java	43
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/Mappings.java	14
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/MaterializedGroupByMapping.java	41
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/PageRankMapping.java	226
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/ReduceByMapping.java	52
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/RepeatMapping.java	69
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DLModel.java	11
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DecisionTreeClassificationModel.java	4
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/KMeansModel.java	5
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/LinearRegressionModel.java	5
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/Model.java	4
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/ArgMax.java	19
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Cast.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Eq.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Input.java	37
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Mean.java	26
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Op.java	51
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/CrossEntropyLoss.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/Linear.java	38
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/ReLU.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/Sigmoid.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/Softmax.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/Adam.java	33
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/GradientDescent.java	9
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/Optimizer.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java	188
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java	185
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CartesianOperator.java	34
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CoGroupOperator.java	67
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CollectionSource.java	46
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CountOperator.java	26
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DLTrainingOperator.java	59
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DecisionTreeClassificationOperator.java	15
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DistinctOperator.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DoWhileOperator.java	168
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FilterOperator.java	62
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FlatMapOperator.java	63
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GlobalMaterializedGroupOperator.java	25
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GlobalReduceOperator.java	43
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java	163
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GroupByOperator.java	30
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/IntersectOperator.java	32
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/JoinOperator.java	67
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KMeansOperator.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java	126
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java	177
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LinearRegressionOperator.java	29
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LocalCallbackSink.java	73
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LoopOperator.java	194
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/MapOperator.java	56
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/MapPartitionsOperator.java	63
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/MaterializedGroupByOperator.java	44
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ModelTransformOperator.java	38
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSink.java	26
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSource.java	92
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PageRankOperator.java	64
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ParquetSource.java	125
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperator.java	20
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperators.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PyWayangReduceByOperator.java	34
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ReduceByOperator.java	58
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ReduceOperator.java	37
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java	130
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/SampleOperator.java	96
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/SortOperator.java	40
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TableSource.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TextFileSink.java	43
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TextFileSource.java	121
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/UnionAllOperator.java	33
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ZipWithIdOperator.java	30
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/plugin/WayangBasic.java	37
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/plugin/WayangBasicGraph.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/types/RecordType.java	44
wayang-commons/wayang-core/src/main/antlr4/org/apache/wayang/core/mathex/MathEx.g4	61
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Configuration.java	621
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java	545
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/WayangContext.java	99
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/CollectionProvider.java	29
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/ConstantValueProvider.java	25
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/ExplicitCollectionProvider.java	47
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalCollectionProvider.java	24
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalKeyValueProvider.java	34
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalValueProvider.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/KeyValueProvider.java	68
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/MapBasedKeyValueProvider.java	44
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/ValueProvider.java	52
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/exception/WayangException.java	17
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/AggregationDescriptor.java	52
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ConsumerDescriptor.java	55
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ExecutionContext.java	8
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ExtendedFunction.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FlatMapDescriptor.java	73
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FunctionDescriptor.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/MapPartitionsDescriptor.java	76
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/PredicateDescriptor.java	64
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ReduceDescriptor.java	51
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/TransformationDescriptor.java	74
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/Mapping.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorMatch.java	16
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorPattern.java	100
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/PlanTransformation.java	110
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/ReplacementSubplanFactory.java	67
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/SubplanMatch.java	67
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/SubplanPattern.java	100
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/DisabledMonitor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/FileMonitor.java	61
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/HttpMonitor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/Monitor.java	21
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/ZeroMQMonitor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/AggregateOptimizationContext.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/DefaultOptimizationContext.java	169
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationContext.java	452
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationUtils.java	84
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticIntervalEstimate.java	86
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/SanityChecker.java	93
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/AbstractAlternativeCardinalityPusher.java	57
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/AggregatingCardinalityEstimator.java	21
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimate.java	59
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimationTraversal.java	256
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimator.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimatorManager.java	130
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityPusher.java	50
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityEstimator.java	76
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityPusher.java	43
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/FallbackCardinalityEstimator.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/FixedSizeCardinalityEstimator.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/LoopHeadAlternativeCardinalityPusher.java	40
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/LoopSubplanCardinalityPusher.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/OperatorAlternativeCardinalityPusher.java	35
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/SubplanCardinalityPusher.java	54
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/SwitchForwardCardinalityEstimator.java	28
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversion.java	49
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraph.java	629
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/DefaultChannelConversion.java	143
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/ConstantLoadProfileEstimator.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultEstimatableCost.java	244
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultLoadEstimator.java	99
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimatableCost.java	24
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimatableCostFactory.java	4
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimationContext.java	77
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/IntervalLoadEstimator.java	99
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimate.java	48
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimator.java	50
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfile.java	120
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimator.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java	281
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileToTimeConverter.java	57
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadToTimeConverter.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/NestableLoadProfileEstimator.java	129
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/SimpleEstimationContext.java	80
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/TimeEstimate.java	54
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/TimeToCostConverter.java	26
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlow.java	97
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlowCompiler.java	305
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LatentOperatorPruningStrategy.java	61
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LoopEnumerator.java	102
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LoopImplementation.java	142
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumeration.java	401
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerationPruningStrategy.java	6
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerator.java	666
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanImplementation.java	665
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/RandomPruningStrategy.java	23
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/SinglePlatformPruningStrategy.java	15
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversal.java	549
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/TopKPruningStrategy.java	23
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/partition/EnumerationAlternative.java	3
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/partition/EnumerationBranch.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/Channel.java	249
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ChannelInitializer.java	16
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionPlan.java	153
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStage.java	233
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStageLoop.java	45
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionTask.java	135
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/PlatformExecution.java	40
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ActualOperator.java	7
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/BinaryToUnaryOperator.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/CompositeOperator.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ElementaryOperator.java	17
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/EstimationContextProperty.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ExecutionOperator.java	148
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java	119
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopHeadAlternative.java	101
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopHeadOperator.java	46
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopIsolator.java	82
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopSubplan.java	53
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java	270
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorAlternative.java	216
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorBase.java	233
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainer.java	111
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainers.java	83
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operators.java	89
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OutputSlot.java	116
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanMetrics.java	63
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanTraversal.java	180
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Slot.java	54
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java	185
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Subplan.java	181
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/TopDownPlanVisitor.java	36
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySink.java	25
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySource.java	22
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnaryToUnaryOperator.java	30
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/WayangPlan.java	111
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/traversal/AbstractTopologicalTraversal.java	91
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AbstractChannelInstance.java	58
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecution.java	101
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecutionGroup.java	95
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Breakpoint.java	11
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CardinalityBreakpoint.java	73
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ChannelDescriptor.java	63
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ChannelInstance.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CompositeExecutionResource.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ConjunctiveBreakpoint.java	25
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CrossPlatformExecutor.java	604
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutionResource.java	6
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutionResourceTemplate.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutionState.java	12
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Executor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutorTemplate.java	118
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/FixBreakpoint.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Junction.java	135
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/NoIterationBreakpoint.java	12
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PartialExecution.java	134
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Platform.java	68
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PushExecutorTemplate.java	222
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/ChannelLineageNode.java	28
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/ExecutionLineageNode.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/LazyExecutionLineageNode.java	94
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin/DynamicPlugin.java	198
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin/Plugin.java	32
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java	143
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CostMeasurement.java	34
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionLog.java	90
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionPlanMeasurement.java	169
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/FullInstrumentationStrategy.java	12
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/InstrumentationStrategy.java	7
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/NoInstrumentationStrategy.java	9
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/OutboundInstrumentationStrategy.java	9
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/PartialExecutionMeasurement.java	30
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ProfileDBs.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java	41
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataSetType.java	69
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitGroupType.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitType.java	27
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/AbstractReferenceCountable.java	43
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Action.java	13
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Actions.java	6
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Bitmask.java	260
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Canonicalizer.java	104
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ConsumerIteratorAdapter.java	110
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Copyable.java	4
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Counter.java	57
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/CrossProductIterable.java	62
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainTreeNode.java	58
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java	142
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Formats.java	37
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Iterators.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JsonSerializable.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JsonSerializables.java	115
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JsonSerializer.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JuelUtils.java	74
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/LimitedInputStream.java	65
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Logging.java	8
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/LruCache.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/MultiMap.java	17
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/OneTimeExecutable.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Optional.java	41
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReferenceCountable.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReflectionUtils.java	282
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Tuple.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/TypeConverter.java	13
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/WayangArrays.java	52
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/WayangCollections.java	146
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/FileSystem.java	16
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/FileSystems.java	75
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/FileUtils.java	56
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/HadoopFileSystem.java	93
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/LocalFileSystem.java	150
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/S3FileSystem.java	194
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonArray.java	97
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonObj.java	223
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/Context.java	8
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/DefaultContext.java	69
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/Expression.java	22
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/ExpressionBuilder.java	80
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/exceptions/EvaluationException.java	19
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/exceptions/MathExException.java	19
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/exceptions/ParseException.java	19
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/BinaryOperation.java	48
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/CompiledFunction.java	47
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/Constant.java	24
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/NamedFunction.java	44
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/UnaryOperation.java	27
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/Variable.java	17
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/ProfileDB.java	70
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/instrumentation/StopWatch.java	79
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/json/MeasurementDeserializer.java	29
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/json/MeasurementSerializer.java	15
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Experiment.java	90
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Measurement.java	33
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Subject.java	34
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Type.java	10
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/measurement/TimeMeasurement.java	102
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/FileStorage.java	44
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/JDBCStorage.java	47
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/Storage.java	63