apache / incubator-wayang
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 8% | 12% | 28% | 50%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 7% | 13% | 29% | 49%
scala0% | 25% | 3% | 14% | 56%
py0% | 0% | 0% | 45% | 54%
xml0% | 0% | 0% | 62% | 37%
groovy0% | 0% | 0% | 100% | 0%
css0% | 0% | 0% | 43% | 56%
html0% | 0% | 0% | 0% | 100%
g40% | 0% | 0% | 0% | 100%
cfg0% | 0% | 0% | 0% | 100%
toml0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
scss0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
wayang-commons0% | 17% | 17% | 25% | 39%
wayang-api0% | 22% | 8% | 19% | 50%
wayang-profiler0% | 0% | 48% | 21% | 30%
wayang-platforms0% | 0% | 5% | 30% | 63%
wayang-benchmark0% | 0% | 7% | 40% | 51%
wayang-plugins0% | 0% | 0% | 40% | 59%
python0% | 0% | 0% | 44% | 55%
wayang-ml4all0% | 0% | 0% | 32% | 67%
wayang-assembly0% | 0% | 0% | 100% | 0%
src0% | 0% | 0% | 100% | 0%
wayang-docs0% | 0% | 0% | 21% | 78%
wayang-applications0% | 0% | 0% | 0% | 100%
guides0% | 0% | 0% | 0% | 100%
wayang-resources0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
DataQuantaBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 721 59
PlanEnumerator.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 666 53
PlanImplementation.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 665 37
ChannelConversionGraph.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels
 629 33
Configuration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 621 62
DataQuanta.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 610 45
CrossPlatformExecutor.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform
 604 54
StageAssignmentTraversal.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 549 44
Job.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 545 31
JsonPlanBuilder.scala
in wayang-api/wayang-api-json/src/main/scala/builder
 503 39
GeneticOptimizerApp.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/log
 481 14
OptimizationContext.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer
 452 59
JdbcSchema.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc
 403 21
PlanEnumeration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 401 20
SparkListener.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 375 14
OperatorProfilers.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/spark
 322 30
ExecutionTaskFlowCompiler.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 305 23
Random16.java
in wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort
 294 3
OperatorDeserializer.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers
 286 33
ReflectionUtils.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util
 282 19
WayangFileOutputFormat.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler
 282 25
LoadProfileEstimators.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs
 281 12
Profiler.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/java
 272 7
Operator.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 270 39
SparkOperatorProfiler.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/spark
 262 22
Bitmask.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util
 260 32
TensorflowCollectOperator.java
in wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators
 257 3
CardinalityEstimationTraversal.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality
 256 28
OperatorProfilers.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/java
 253 24
Channel.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan
 249 32
DefaultEstimatableCost.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs
 244 2
OperatorBase.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 233 29
ExecutionStage.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan
 233 29
PageRankMapping.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping
 226 10
WayangJsonObj.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json
 223 29
PushExecutorTemplate.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform
 222 21
OperatorAlternative.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 216 25
SparkRandomPartitionSampleOperator.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators
 207 9
Convertor.java
in wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model
 205 13
GeneticOptimizer.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/log
 201 17
DynamicPlugin.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin
 198 16
S3FileSystem.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs
 194 25
LoopOperator.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 194 21
JdbcUtils.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc
 193 8
Unsigned16.java
in wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort
 191 20
AmazonS3Source.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 188 15
BitSetJoin.java
in wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers
 188 1
SlotMapping.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 185 14
AzureBlobStorageSource.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 185 17
PageRankAlgorithm.java
in wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm
 183 12
Files With Most Units (Top 50)
File# lines# units
Configuration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 621 62
DataQuantaBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 721 59
OptimizationContext.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer
 452 59
CrossPlatformExecutor.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform
 604 54
PlanEnumerator.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 666 53
DataQuanta.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 610 45
StageAssignmentTraversal.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 549 44
ops.py
in python/src/pywy/basic/model
 157 40
JsonPlanBuilder.scala
in wayang-api/wayang-api-json/src/main/scala/builder
 503 39
Operator.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 270 39
PlanImplementation.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 665 37
OperatorDeserializer.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers
 286 33
ChannelConversionGraph.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels
 629 33
Bitmask.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util
 260 32
Channel.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan
 249 32
TaskStart.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 147 32
TaskGettingResult.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 147 32
TaskEnd.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 149 32
Job.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 545 31
OperatorProfilers.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/spark
 322 30
ExecutionPlanMeasurement.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling
 169 30
unary.py
in python/src/pywy/operators
 127 29
WayangJsonObj.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json
 223 29
OperatorBase.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 233 29
ExecutionStage.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan
 233 29
CardinalityEstimationTraversal.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality
 256 28
LoopImplementation.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 142 28
PlanTraversal.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 180 26
S3FileSystem.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs
 194 25
OperatorAlternative.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 216 25
WayangFileOutputFormat.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler
 282 25
OperatorProfilers.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/java
 253 24
StageCompleted.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 113 24
TaskMetric.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 110 24
StageSubmitted.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 111 24
StageExecutorMetrics.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics
 110 24
dataquanta.py
in python/src/pywy
 154 23
ExecutionTaskFlowCompiler.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 305 23
SparkOperatorProfiler.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/spark
 262 22
Subplan.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 181 22
JdbcSchema.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc
 403 21
PushExecutorTemplate.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform
 222 21
Canonicalizer.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util
 104 21
LoopOperator.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 194 21
Junction.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform
 135 20
JsonSerializables.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util
 115 20
InputSlot.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 119 20
ExecutionTask.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan
 135 20
PlanEnumeration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 401 20
FileChannel.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels
 139 20
Files With Long Lines (Top 50)

There are 330 files with lines longer than 120 characters. In total, there are 1135 long lines.

File# lines# units# long lines
JsonPlanBuilder.scala
in wayang-api/wayang-api-json/src/main/scala/builder
 503 39 61
OperatorFromDrawflowConverter.scala
in wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow
 83 3 33
DefaultEstimatableCost.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs
 244 2 33
PlanImplementation.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 665 37 33
ChannelConversionGraph.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels
 629 33 26
CrossPlatformExecutor.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform
 604 54 21
OperatorDeserializer.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers
 286 33 20
SerializationUtils.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization
 165 4 20
Configuration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 621 62 20
GeneticOptimizerApp.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/log
 481 14 19
PlanEnumerator.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 666 53 18
DataQuantaBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 721 59 15
TensorflowCollectOperator.java
in wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators
 257 3 15
PushExecutorTemplate.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform
 222 21 13
PlanEnumeration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 401 20 13
DescriptorMixIns.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins
 88 6 12
LoadProfileEstimators.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs
 281 12 12
SparkIEJoinOperator.java
in wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators
 158 5 12
OperatorProfilers.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/spark
 322 30 11
AmazonS3Source.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 188 15 10
AzureBlobStorageSource.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 185 17 10
OperatorProfilers.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/java
 253 24 9
SparkOperatorProfiler.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/spark
 262 22 9
OptimizationContext.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer
 452 59 9
SparkIESelfJoinOperator.java
in wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators
 123 5 9
MultiContextPlanBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 76 12 8
JavaPlanBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 61 6 8
OperatorAlternative.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 216 25 8
CardinalityEstimatorManager.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality
 130 9 8
ExecutionTaskFlowCompiler.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration
 305 23 8
FlinkRepeatExpandedOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 149 7 8
FlinkPageRankOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 167 16 8
Profiler.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/java
 272 7 7
package.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 100 12 7
OperatorBase.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 233 29 7
WayangFileOutputFormat.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler
 282 25 7
PlanBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 73 7 6
Job.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 545 31 6
TextFileSource.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 121 8 6
FlinkDoWhileOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 155 9 6
FlinkLoopOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 123 8 6
FlinkCollectionSource.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 100 8 6
FunctionCompiler.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler
 125 13 6
FunctionCompiler.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler
 128 10 6
GeneticOptimizer.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/log
 201 17 5
EstimatorMixIns.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins
 90 5 5
DataQuanta.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 610 45 5
Subplan.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan
 181 22 5
DefaultChannelConversion.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels
 143 12 5
CardinalityEstimationTraversal.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality
 256 28 5
Correlations

File Size vs. Commits (all time): 1055 points

python/src/pywy/basic/data/__init__.py x: 2 commits (all time) y: 1 lines of code python/src/pywy/basic/data/record.py x: 4 commits (all time) y: 31 lines of code python/src/pywy/core/core.py x: 17 commits (all time) y: 56 lines of code python/src/pywy/core/serializer.py x: 24 commits (all time) y: 76 lines of code python/src/pywy/dataquanta.py x: 38 commits (all time) y: 154 lines of code python/src/pywy/execution/util.py x: 6 commits (all time) y: 7 lines of code python/src/pywy/execution/worker.py x: 10 commits (all time) y: 91 lines of code python/src/pywy/graph/graph.py x: 12 commits (all time) y: 58 lines of code python/src/pywy/operators/__init__.py x: 18 commits (all time) y: 27 lines of code python/src/pywy/operators/base.py x: 20 commits (all time) y: 66 lines of code python/src/pywy/operators/binary.py x: 21 commits (all time) y: 59 lines of code python/src/pywy/operators/sink.py x: 16 commits (all time) y: 24 lines of code python/src/pywy/operators/source.py x: 15 commits (all time) y: 44 lines of code python/src/pywy/operators/unary.py x: 25 commits (all time) y: 127 lines of code python/src/pywy/types.py x: 21 commits (all time) y: 154 lines of code wayang-api/wayang-api-json/src/main/scala/Main.scala x: 13 commits (all time) y: 49 lines of code wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 31 commits (all time) y: 503 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 16 commits (all time) y: 83 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 8 commits (all time) y: 44 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 19 commits (all time) y: 135 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 6 commits (all time) y: 37 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 12 commits (all time) y: 12 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 12 commits (all time) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 4 commits (all time) y: 20 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/GroupByOperatorFromJson.scala x: 2 commits (all time) y: 16 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java x: 11 commits (all time) y: 28 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 34 commits (all time) y: 61 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 40 commits (all time) y: 73 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 6 commits (all time) y: 30 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 11 commits (all time) y: 96 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 44 commits (all time) y: 610 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 20 commits (all time) y: 60 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 6 commits (all time) y: 33 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 16 commits (all time) y: 29 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 27 commits (all time) y: 52 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 8 commits (all time) y: 88 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 25 commits (all time) y: 25 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 30 commits (all time) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 9 commits (all time) y: 10 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 7 commits (all time) y: 48 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 29 commits (all time) y: 50 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 9 commits (all time) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 11 commits (all time) y: 92 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 6 commits (all time) y: 19 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 10 commits (all time) y: 116 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 commits (all time) y: 14 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java x: 3 commits (all time) y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinKeyExtractor.java x: 4 commits (all time) y: 12 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 6 commits (all time) y: 86 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 5 commits (all time) y: 18 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java x: 3 commits (all time) y: 30 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java x: 4 commits (all time) y: 32 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 14 commits (all time) y: 149 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 31 commits (all time) y: 79 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 13 commits (all time) y: 74 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaSortOperator.java x: 6 commits (all time) y: 60 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 13 commits (all time) y: 177 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 22 commits (all time) y: 721 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 17 commits (all time) y: 179 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 15 commits (all time) y: 66 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 22 commits (all time) y: 65 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java x: 21 commits (all time) y: 38 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 6 commits (all time) y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 14 commits (all time) y: 188 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 6 commits (all time) y: 185 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 12 commits (all time) y: 163 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 13 commits (all time) y: 126 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ParquetSource.java x: 5 commits (all time) y: 125 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 8 commits (all time) y: 270 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java x: 14 commits (all time) y: 125 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 14 commits (all time) y: 107 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java x: 7 commits (all time) y: 43 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java x: 14 commits (all time) y: 73 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 14 commits (all time) y: 111 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java x: 15 commits (all time) y: 75 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 16 commits (all time) y: 100 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java x: 14 commits (all time) y: 63 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFilterOperator.java x: 14 commits (all time) y: 68 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 14 commits (all time) y: 82 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 14 commits (all time) y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 14 commits (all time) y: 103 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 15 commits (all time) y: 69 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 14 commits (all time) y: 78 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java x: 15 commits (all time) y: 99 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java x: 14 commits (all time) y: 87 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatOperator.java x: 14 commits (all time) y: 102 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSortOperator.java x: 14 commits (all time) y: 70 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 15 commits (all time) y: 60 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java x: 15 commits (all time) y: 77 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java x: 16 commits (all time) y: 126 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 10 commits (all time) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GoogleCloudStorageSourceMapping.java x: 7 commits (all time) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java x: 18 commits (all time) y: 45 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ParquetSourceMapping.java x: 5 commits (all time) y: 32 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java x: 13 commits (all time) y: 70 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAzureBlobStorageSource.java x: 6 commits (all time) y: 70 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java x: 12 commits (all time) y: 98 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 5 commits (all time) y: 115 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java x: 23 commits (all time) y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkParquetSource.java x: 5 commits (all time) y: 74 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 16 commits (all time) y: 130 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java x: 11 commits (all time) y: 118 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java x: 16 commits (all time) y: 50 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ParquetSourceMapping.java x: 2 commits (all time) y: 34 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java x: 10 commits (all time) y: 62 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java x: 4 commits (all time) y: 9 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/Util.java x: 3 commits (all time) y: 7 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCount.java x: 4 commits (all time) y: 46 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCountOnKafkaTopic.java x: 3 commits (all time) y: 62 lines of code wayang-assembly/dependency-reduced-pom.xml x: 8 commits (all time) y: 162 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSource.java x: 5 commits (all time) y: 78 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/tpch/Query1.scala x: 9 commits (all time) y: 79 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCount.scala x: 9 commits (all time) y: 30 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FlinkCoGroupFunction.java x: 10 commits (all time) y: 10 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorDistinct.java x: 10 commits (all time) y: 19 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/OutputFormatConsumer.java x: 10 commits (all time) y: 25 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/DummyFilter.java x: 10 commits (all time) y: 20 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangAggregator.java x: 10 commits (all time) y: 26 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangConvergenceCriterion.java x: 10 commits (all time) y: 33 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java x: 8 commits (all time) y: 177 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Configuration.java x: 16 commits (all time) y: 621 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FunctionDescriptor.java x: 13 commits (all time) y: 78 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/TransformationDescriptor.java x: 11 commits (all time) y: 74 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticIntervalEstimate.java x: 5 commits (all time) y: 86 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimate.java x: 8 commits (all time) y: 59 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimator.java x: 5 commits (all time) y: 10 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityEstimator.java x: 14 commits (all time) y: 76 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimate.java x: 8 commits (all time) y: 48 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfile.java x: 8 commits (all time) y: 120 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java x: 5 commits (all time) y: 119 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorAlternative.java x: 5 commits (all time) y: 216 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorBase.java x: 5 commits (all time) y: 233 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainer.java x: 7 commits (all time) y: 111 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainers.java x: 5 commits (all time) y: 83 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Slot.java x: 5 commits (all time) y: 54 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java x: 9 commits (all time) y: 185 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySink.java x: 5 commits (all time) y: 25 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java x: 5 commits (all time) y: 41 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataSetType.java x: 5 commits (all time) y: 69 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitType.java x: 5 commits (all time) y: 27 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSource.java x: 7 commits (all time) y: 79 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSinkMapping.java x: 2 commits (all time) y: 29 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSourceMapping.java x: 2 commits (all time) y: 28 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSink.java x: 2 commits (all time) y: 83 lines of code python/setup.cfg x: 14 commits (all time) y: 28 lines of code python/src/pywy/basic/__init__.py x: 4 commits (all time) y: 1 lines of code python/src/pywy/basic/model/models.py x: 5 commits (all time) y: 8 lines of code python/src/pywy/basic/model/ops.py x: 7 commits (all time) y: 157 lines of code python/src/pywy/basic/model/option.py x: 6 commits (all time) y: 28 lines of code python/src/pywy/core/__init__.py x: 12 commits (all time) y: 7 lines of code python/src/pywy/platforms/java.py x: 4 commits (all time) y: 6 lines of code wayang-api/wayang-api-json/src/main/scala/exception/WayangApiJsonException.scala x: 10 commits (all time) y: 2 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflow.scala x: 10 commits (all time) y: 14 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/CoGroupOperatorFromJson.scala x: 10 commits (all time) y: 16 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/DLTrainingOperatorFromJson.scala x: 9 commits (all time) y: 68 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/PredictOperatorFromJson.scala x: 8 commits (all time) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/TextFileInputFromJson.scala x: 12 commits (all time) y: 20 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/FlatMapOperatorFromJson.scala x: 13 commits (all time) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/MapOperatorFromJson.scala x: 14 commits (all time) y: 21 lines of code wayang-api/wayang-api-json/src/main/scala/parserutil/ParseOperatorsFromJson.scala x: 10 commits (all time) y: 31 lines of code wayang-api/wayang-api-json/src/main/scala/parserutil/ParsePlanFromJson.scala x: 4 commits (all time) y: 25 lines of code wayang-api/wayang-api-json/src/main/scala/parserutil/SerializableIterable.scala x: 5 commits (all time) y: 22 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessFeeder.java x: 11 commits (all time) y: 103 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessReceiver.java x: 9 commits (all time) y: 24 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonProcessCaller.java x: 9 commits (all time) y: 75 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonWorkerManager.java x: 11 commits (all time) y: 31 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ReaderIterator.java x: 9 commits (all time) y: 53 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedMapPartitionsDescriptor.java x: 6 commits (all time) y: 24 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedPythonFunction.java x: 6 commits (all time) y: 16 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextDataQuanta.scala x: 7 commits (all time) y: 66 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextPlanBuilder.scala x: 7 commits (all time) y: 76 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaAsyncResult.scala x: 6 commits (all time) y: 4 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaImplicits.scala x: 7 commits (all time) y: 30 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/Main.scala x: 7 commits (all time) y: 39 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/PlanBuilderImplicits.scala x: 6 commits (all time) y: 11 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/package.scala x: 7 commits (all time) y: 63 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala x: 12 commits (all time) y: 100 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/SerializationUtils.scala x: 7 commits (all time) y: 165 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/GenericSerializableDeserializer.scala x: 6 commits (all time) y: 12 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/MultiContextSerializer.scala x: 5 commits (all time) y: 29 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/OperatorDeserializer.scala x: 6 commits (all time) y: 286 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformDeserializer.scala x: 6 commits (all time) y: 22 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/DataTypeMixIns.scala x: 6 commits (all time) y: 41 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/DescriptorMixIns.scala x: 6 commits (all time) y: 88 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/OperatorMixIns.scala x: 6 commits (all time) y: 102 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/ProviderMixIns.scala x: 6 commits (all time) y: 56 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/Parameters.scala x: 12 commits (all time) y: 70 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/async/apps/WordCount.scala x: 7 commits (all time) y: 42 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/SampleOperator.java x: 10 commits (all time) y: 96 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/WayangContext.java x: 28 commits (all time) y: 99 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimatorManager.java x: 9 commits (all time) y: 130 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultLoadEstimator.java x: 8 commits (all time) y: 99 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimator.java x: 8 commits (all time) y: 50 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java x: 13 commits (all time) y: 281 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/NestableLoadProfileEstimator.java x: 8 commits (all time) y: 129 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CrossPlatformExecutor.java x: 9 commits (all time) y: 604 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReflectionUtils.java x: 9 commits (all time) y: 282 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java x: 13 commits (all time) y: 97 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRandomSampleOperator.java x: 9 commits (all time) y: 101 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReservoirSampleOperator.java x: 9 commits (all time) y: 90 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToRddOperator.java x: 12 commits (all time) y: 76 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/FunctionCompiler.java x: 13 commits (all time) y: 128 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/MapPartitionsFunctionAdapter.java x: 13 commits (all time) y: 24 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java x: 14 commits (all time) y: 207 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java x: 14 commits (all time) y: 166 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DLModel.java x: 3 commits (all time) y: 11 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DecisionTreeClassificationModel.java x: 9 commits (all time) y: 4 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/KMeansModel.java x: 10 commits (all time) y: 5 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/ArgMax.java x: 3 commits (all time) y: 19 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Input.java x: 3 commits (all time) y: 37 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Mean.java x: 3 commits (all time) y: 26 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Op.java x: 3 commits (all time) y: 51 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/Adam.java x: 3 commits (all time) y: 33 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DLTrainingOperator.java x: 3 commits (all time) y: 59 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DecisionTreeClassificationOperator.java x: 9 commits (all time) y: 15 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ModelTransformOperator.java x: 14 commits (all time) y: 38 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/ModelTransformMapping.java x: 8 commits (all time) y: 31 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkDecisionTreeClassificationOperator.java x: 9 commits (all time) y: 119 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLinearRegressionOperator.java x: 9 commits (all time) y: 124 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkModelTransformOperator.java x: 8 commits (all time) y: 62 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/Tensorflow.java x: 3 commits (all time) y: 17 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/channels/TensorChannel.java x: 3 commits (all time) y: 69 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/execution/TensorflowContextReference.java x: 3 commits (all time) y: 25 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/execution/TensorflowExecutor.java x: 3 commits (all time) y: 79 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/Convertor.java x: 3 commits (all time) y: 205 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectOperator.java x: 3 commits (all time) y: 257 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowDLTrainingOperator.java x: 3 commits (all time) y: 56 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/TPCHQ1WithJavaNative.java x: 4 commits (all time) y: 104 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountWithJavaNativeAPI.java x: 5 commits (all time) y: 105 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java x: 7 commits (all time) y: 142 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Compute.java x: 10 commits (all time) y: 6 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/ML4allPlan.java x: 11 commits (all time) y: 125 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/ComputePerPartitionWrapper.java x: 9 commits (all time) y: 20 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/ComputeWrapper.java x: 9 commits (all time) y: 14 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java x: 13 commits (all time) y: 143 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonArray.java x: 5 commits (all time) y: 97 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonObj.java x: 5 commits (all time) y: 223 lines of code python/src/pywy/__init__.py x: 6 commits (all time) y: 1 lines of code python/src/pywy/graph/__init__.py x: 5 commits (all time) y: 1 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuanta.scala x: 7 commits (all time) y: 19 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuantaBuilder.scala x: 7 commits (all time) y: 34 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/Edge.scala x: 7 commits (all time) y: 4 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/EdgeDataQuanta.scala x: 7 commits (all time) y: 16 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala x: 7 commits (all time) y: 9 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderCache.scala x: 7 commits (all time) y: 14 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala x: 10 commits (all time) y: 49 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/convention/WayangConvention.java x: 5 commits (all time) y: 37 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcSchema.java x: 5 commits (all time) y: 403 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcTable.java x: 5 commits (all time) y: 177 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcUtils.java x: 5 commits (all time) y: 193 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangJoin.java x: 6 commits (all time) y: 36 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangTableScan.java x: 15 commits (all time) y: 64 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/SchemaUtils.java x: 11 commits (all time) y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTableBuilder.java x: 6 commits (all time) y: 43 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java x: 8 commits (all time) y: 124 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java x: 9 commits (all time) y: 139 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/grep/Grep.java x: 5 commits (all time) y: 110 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/sgd/SGDImpl.java x: 7 commits (all time) y: 177 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/sgd/SGDImprovedImpl.java x: 7 commits (all time) y: 117 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort/Random16.java x: 5 commits (all time) y: 294 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/LineItemTuple.java x: 7 commits (all time) y: 133 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/q1/GroupKey.java x: 7 commits (all time) y: 25 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/q1/ReturnTuple.java x: 7 commits (all time) y: 52 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/crocopr/CrocoPR.scala x: 7 commits (all time) y: 83 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala x: 7 commits (all time) y: 123 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala x: 7 commits (all time) y: 122 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/AddIdFunction.scala x: 7 commits (all time) y: 7 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SelectNearestCentroidFunction.scala x: 9 commits (all time) y: 33 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SimWords.scala x: 7 commits (all time) y: 116 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SparseVector.scala x: 7 commits (all time) y: 130 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/Word2NVec.scala x: 7 commits (all time) y: 98 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/sindy/Sindy.scala x: 7 commits (all time) y: 127 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraGen.scala x: 5 commits (all time) y: 82 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/TpcH.scala x: 7 commits (all time) y: 90 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/data/LineItem.scala x: 7 commits (all time) y: 62 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query1.scala x: 7 commits (all time) y: 92 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala x: 7 commits (all time) y: 95 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java x: 22 commits (all time) y: 545 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultEstimatableCost.java x: 5 commits (all time) y: 244 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimatableCostFactory.java x: 5 commits (all time) y: 4 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanImplementation.java x: 9 commits (all time) y: 665 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/S3FileSystem.java x: 5 commits (all time) y: 194 lines of code wayang-docs/src/main/resources/_includes/footer.html x: 8 commits (all time) y: 38 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/utils/SparseVector.java x: 6 commits (all time) y: 172 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/Flink.java x: 8 commits (all time) y: 22 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataSetChannel.java x: 8 commits (all time) y: 65 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/WayangFileOutputFormat.java x: 10 commits (all time) y: 282 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangListValue.java x: 8 commits (all time) y: 11 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangValue.java x: 8 commits (all time) y: 102 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkContextReference.java x: 8 commits (all time) y: 56 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/CartesianMapping.java x: 8 commits (all time) y: 34 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/FilterMapping.java x: 8 commits (all time) y: 36 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/SampleMapping.java x: 8 commits (all time) y: 41 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCountOperator.java x: 8 commits (all time) y: 66 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDoWhileOperator.java x: 8 commits (all time) y: 155 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkExecutionOperator.java x: 8 commits (all time) y: 25 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperator.java x: 8 commits (all time) y: 74 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkPageRankOperator.java x: 8 commits (all time) y: 167 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java x: 8 commits (all time) y: 70 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/plugin/FlinkGraphPlugin.java x: 8 commits (all time) y: 6 lines of code wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/GenericJdbc.java x: 5 commits (all time) y: 17 lines of code wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/execution/GenericJdbcExecutor.java x: 5 commits (all time) y: 153 lines of code wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/FilterMapping.java x: 5 commits (all time) y: 35 lines of code wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/ProjectionMapping.java x: 5 commits (all time) y: 44 lines of code wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericJdbcTableSource.java x: 7 commits (all time) y: 58 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/plugin/JavaChannelConversionPlugin.java x: 8 commits (all time) y: 27 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/channels/SqlQueryChannel.java x: 8 commits (all time) y: 72 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToStreamOperator.java x: 14 commits (all time) y: 159 lines of code wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/JoinMapping.java x: 7 commits (all time) y: 49 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/Spark.java x: 9 commits (all time) y: 27 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/ChannelConversions.java x: 9 commits (all time) y: 87 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutionContext.java x: 9 commits (all time) y: 47 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/LoopMapping.java x: 9 commits (all time) y: 35 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/SampleMapping.java x: 9 commits (all time) y: 57 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/graph/PageRankMapping.java x: 9 commits (all time) y: 42 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ExecutorAdded.java x: 6 commits (all time) y: 82 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/SparkListener.java x: 6 commits (all time) y: 375 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageCompleted.java x: 6 commits (all time) y: 113 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageExecutorMetrics.java x: 6 commits (all time) y: 110 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskEnd.java x: 6 commits (all time) y: 149 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskGettingResult.java x: 6 commits (all time) y: 147 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkBroadcastOperator.java x: 9 commits (all time) y: 64 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCartesianOperator.java x: 9 commits (all time) y: 71 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCountOperator.java x: 9 commits (all time) y: 60 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java x: 9 commits (all time) y: 131 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkFlatMapOperator.java x: 9 commits (all time) y: 83 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperator.java x: 9 commits (all time) y: 81 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java x: 9 commits (all time) y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java x: 9 commits (all time) y: 146 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java x: 11 commits (all time) y: 72 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRepeatOperator.java x: 9 commits (all time) y: 91 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/platform/SparkPlatform.java x: 11 commits (all time) y: 169 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/IEJoin.java x: 8 commits (all time) y: 82 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/data/Data.java x: 8 commits (all time) y: 94 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperator.java x: 8 commits (all time) y: 107 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIESelfJoinOperator.java x: 8 commits (all time) y: 87 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java x: 8 commits (all time) y: 158 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java x: 8 commits (all time) y: 188 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/DataComparator.java x: 8 commits (all time) y: 53 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/extractData.java x: 8 commits (all time) y: 18 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java x: 8 commits (all time) y: 182 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfiler.java x: 10 commits (all time) y: 140 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfilers.java x: 8 commits (all time) y: 253 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/java/Profiler.java x: 11 commits (all time) y: 272 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicLoadEstimator.java x: 8 commits (all time) y: 161 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimators.java x: 12 commits (all time) y: 95 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java x: 10 commits (all time) y: 201 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java x: 13 commits (all time) y: 481 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/Individual.java x: 8 commits (all time) y: 172 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/LogEvaluator.java x: 10 commits (all time) y: 181 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/sampling/Battle.java x: 8 commits (all time) y: 5 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/Main.java x: 11 commits (all time) y: 137 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/OperatorProfilers.java x: 8 commits (all time) y: 322 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkOperatorProfiler.java x: 10 commits (all time) y: 262 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/util/RrdAccessor.java x: 10 commits (all time) y: 71 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/platform/JdbcPlatformTemplate.java x: 6 commits (all time) y: 72 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSink.java x: 1 commits (all time) y: 26 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSource.java x: 1 commits (all time) y: 92 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSinkMapping.java x: 1 commits (all time) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSourceMapping.java x: 1 commits (all time) y: 40 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSink.java x: 6 commits (all time) y: 133 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSource.java x: 6 commits (all time) y: 164 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/SanityChecker.java x: 5 commits (all time) y: 93 lines of code wayang-docs/src/main/resources/_includes/head.html x: 3 commits (all time) y: 44 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Experiment.java x: 5 commits (all time) y: 90 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/measurement/TimeMeasurement.java x: 5 commits (all time) y: 102 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/JDBCStorage.java x: 5 commits (all time) y: 47 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/Storage.java x: 5 commits (all time) y: 63 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/FileMonitor.java x: 5 commits (all time) y: 61 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/SimpleEstimationContext.java x: 7 commits (all time) y: 80 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecutionGroup.java x: 5 commits (all time) y: 95 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PartialExecution.java x: 5 commits (all time) y: 134 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Platform.java x: 5 commits (all time) y: 68 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumeration.java x: 7 commits (all time) y: 401 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerator.java x: 7 commits (all time) y: 666 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionPlanMeasurement.java x: 5 commits (all time) y: 169 lines of code wayang-docs/src/main/resources/_sass/main.scss x: 2 commits (all time) y: 8 lines of code wayang-docs/src/main/resources/assets/css/color.css x: 2 commits (all time) y: 44 lines of code wayang-docs/src/main/resources/assets/css/main.css x: 8 commits (all time) y: 103 lines of code wayang-docs/src/main/resources/assets/css/monokai.css x: 2 commits (all time) y: 92 lines of code wayang-docs/src/main/resources/assets/js/add_numbers.js x: 2 commits (all time) y: 12 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/KeyValueProvider.java x: 4 commits (all time) y: 68 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/ValueProvider.java x: 4 commits (all time) y: 52 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/PlanTransformation.java x: 4 commits (all time) y: 110 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationContext.java x: 4 commits (all time) y: 452 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityPusher.java x: 4 commits (all time) y: 50 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/SwitchForwardCardinalityEstimator.java x: 4 commits (all time) y: 28 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraph.java x: 4 commits (all time) y: 629 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlow.java x: 4 commits (all time) y: 97 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlowCompiler.java x: 4 commits (all time) y: 305 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LatentOperatorPruningStrategy.java x: 4 commits (all time) y: 61 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LoopEnumerator.java x: 4 commits (all time) y: 102 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversal.java x: 4 commits (all time) y: 549 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/Channel.java x: 4 commits (all time) y: 249 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ExecutionOperator.java x: 4 commits (all time) y: 148 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopIsolator.java x: 4 commits (all time) y: 82 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanTraversal.java x: 4 commits (all time) y: 180 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/WayangPlan.java x: 4 commits (all time) y: 111 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/traversal/AbstractTopologicalTraversal.java x: 4 commits (all time) y: 91 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AbstractChannelInstance.java x: 4 commits (all time) y: 58 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CardinalityBreakpoint.java x: 4 commits (all time) y: 73 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutorTemplate.java x: 4 commits (all time) y: 118 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Junction.java x: 4 commits (all time) y: 135 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/LazyExecutionLineageNode.java x: 4 commits (all time) y: 94 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/AbstractReferenceCountable.java x: 4 commits (all time) y: 43 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JuelUtils.java x: 4 commits (all time) y: 74 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm/PageRankAlgorithm.java x: 5 commits (all time) y: 183 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/operators/GiraphPageRankOperator.java x: 5 commits (all time) y: 147 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java x: 2 commits (all time) y: 5 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels/FileChannel.java x: 2 commits (all time) y: 139 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple2.java x: 2 commits (all time) y: 38 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple5.java x: 2 commits (all time) y: 56 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java x: 2 commits (all time) y: 107 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/MaterializedGroupByMapping.java x: 2 commits (all time) y: 41 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/PageRankMapping.java x: 2 commits (all time) y: 226 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/ReduceByMapping.java x: 2 commits (all time) y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/RepeatMapping.java x: 2 commits (all time) y: 69 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CoGroupOperator.java x: 2 commits (all time) y: 67 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CollectionSource.java x: 2 commits (all time) y: 46 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DoWhileOperator.java x: 2 commits (all time) y: 168 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FilterOperator.java x: 2 commits (all time) y: 62 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FlatMapOperator.java x: 2 commits (all time) y: 63 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GlobalMaterializedGroupOperator.java x: 2 commits (all time) y: 25 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LocalCallbackSink.java x: 2 commits (all time) y: 73 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LoopOperator.java x: 2 commits (all time) y: 194 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ReduceByOperator.java x: 2 commits (all time) y: 58 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java x: 2 commits (all time) y: 130 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalValueProvider.java x: 2 commits (all time) y: 20 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/MapPartitionsDescriptor.java x: 2 commits (all time) y: 76 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ReduceDescriptor.java x: 2 commits (all time) y: 51 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorPattern.java x: 2 commits (all time) y: 100 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/AggregateOptimizationContext.java x: 2 commits (all time) y: 78 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimationTraversal.java x: 2 commits (all time) y: 256 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/FixedSizeCardinalityEstimator.java x: 2 commits (all time) y: 18 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/OperatorAlternativeCardinalityPusher.java x: 2 commits (all time) y: 35 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/DefaultChannelConversion.java x: 2 commits (all time) y: 143 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/IntervalLoadEstimator.java x: 2 commits (all time) y: 99 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStage.java x: 2 commits (all time) y: 233 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionTask.java x: 2 commits (all time) y: 135 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/CompositeOperator.java x: 2 commits (all time) y: 10 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operators.java x: 2 commits (all time) y: 89 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OutputSlot.java x: 2 commits (all time) y: 116 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Subplan.java x: 2 commits (all time) y: 181 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PushExecutorTemplate.java x: 2 commits (all time) y: 222 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin/DynamicPlugin.java x: 2 commits (all time) y: 198 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Bitmask.java x: 2 commits (all time) y: 260 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Canonicalizer.java x: 2 commits (all time) y: 104 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ConsumerIteratorAdapter.java x: 2 commits (all time) y: 110 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/WayangCollections.java x: 2 commits (all time) y: 146 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/ExpressionBuilder.java x: 2 commits (all time) y: 80 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/FilterMapping.java x: 3 commits (all time) y: 36 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/StreamChannel.java x: 3 commits (all time) y: 71 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/execution/JavaExecutor.java x: 3 commits (all time) y: 93 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/SampleMapping.java x: 3 commits (all time) y: 53 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCartesianOperator.java x: 3 commits (all time) y: 123 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCoGroupOperator.java x: 3 commits (all time) y: 119 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCountOperator.java x: 3 commits (all time) y: 63 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFilterOperator.java x: 3 commits (all time) y: 76 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFlatMapOperator.java x: 3 commits (all time) y: 86 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaIntersectOperator.java x: 3 commits (all time) y: 99 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaJoinOperator.java x: 3 commits (all time) y: 139 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMapPartitionsOperator.java x: 3 commits (all time) y: 85 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReduceByOperator.java x: 3 commits (all time) y: 131 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRepeatOperator.java x: 3 commits (all time) y: 90 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTsvFileSource.java x: 3 commits (all time) y: 104 lines of code
721.0
lines of code
  min: 1.0
  average: 64.89
  25th percentile: 24.0
  median: 38.0
  75th percentile: 79.0
  max: 721.0
0 44.0
commits (all time)
min: 1.0 | average: 6.68 | 25th percentile: 3.0 | median: 6.0 | 75th percentile: 9.0 | max: 44.0

File Size vs. Contributors (all time): 1055 points

python/src/pywy/basic/data/__init__.py x: 2 contributors (all time) y: 1 lines of code python/src/pywy/basic/data/record.py x: 2 contributors (all time) y: 31 lines of code python/src/pywy/core/core.py x: 7 contributors (all time) y: 56 lines of code python/src/pywy/core/serializer.py x: 7 contributors (all time) y: 76 lines of code python/src/pywy/dataquanta.py x: 9 contributors (all time) y: 154 lines of code python/src/pywy/execution/util.py x: 5 contributors (all time) y: 7 lines of code python/src/pywy/execution/worker.py x: 5 contributors (all time) y: 91 lines of code python/src/pywy/graph/graph.py x: 5 contributors (all time) y: 58 lines of code python/src/pywy/operators/__init__.py x: 7 contributors (all time) y: 27 lines of code python/src/pywy/operators/base.py x: 9 contributors (all time) y: 66 lines of code python/src/pywy/operators/binary.py x: 7 contributors (all time) y: 59 lines of code python/src/pywy/operators/sink.py x: 7 contributors (all time) y: 24 lines of code python/src/pywy/operators/source.py x: 7 contributors (all time) y: 44 lines of code python/src/pywy/operators/unary.py x: 7 contributors (all time) y: 127 lines of code python/src/pywy/types.py x: 7 contributors (all time) y: 154 lines of code wayang-api/wayang-api-json/src/main/scala/Main.scala x: 6 contributors (all time) y: 49 lines of code wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 6 contributors (all time) y: 503 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 6 contributors (all time) y: 83 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 5 contributors (all time) y: 44 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 6 contributors (all time) y: 135 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 5 contributors (all time) y: 37 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 6 contributors (all time) y: 12 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 6 contributors (all time) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 2 contributors (all time) y: 20 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/GroupByOperatorFromJson.scala x: 2 contributors (all time) y: 16 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 13 contributors (all time) y: 61 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 14 contributors (all time) y: 73 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 4 contributors (all time) y: 30 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 6 contributors (all time) y: 96 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 15 contributors (all time) y: 610 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 11 contributors (all time) y: 60 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 4 contributors (all time) y: 33 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 9 contributors (all time) y: 29 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 13 contributors (all time) y: 52 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 4 contributors (all time) y: 88 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 16 contributors (all time) y: 25 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 17 contributors (all time) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 8 contributors (all time) y: 10 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 4 contributors (all time) y: 48 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 15 contributors (all time) y: 50 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 4 contributors (all time) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 4 contributors (all time) y: 92 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 4 contributors (all time) y: 19 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 3 contributors (all time) y: 116 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 contributors (all time) y: 14 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java x: 3 contributors (all time) y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 4 contributors (all time) y: 86 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 3 contributors (all time) y: 18 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java x: 3 contributors (all time) y: 30 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java x: 3 contributors (all time) y: 32 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 11 contributors (all time) y: 149 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 18 contributors (all time) y: 79 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 5 contributors (all time) y: 74 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaSortOperator.java x: 4 contributors (all time) y: 60 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 10 contributors (all time) y: 177 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 12 contributors (all time) y: 721 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 11 contributors (all time) y: 179 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 7 contributors (all time) y: 66 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 13 contributors (all time) y: 65 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java x: 11 contributors (all time) y: 38 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 2 contributors (all time) y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 5 contributors (all time) y: 188 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 5 contributors (all time) y: 185 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 6 contributors (all time) y: 163 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 6 contributors (all time) y: 126 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ParquetSource.java x: 2 contributors (all time) y: 125 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 7 contributors (all time) y: 270 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java x: 9 contributors (all time) y: 125 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java x: 9 contributors (all time) y: 23 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 9 contributors (all time) y: 107 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java x: 9 contributors (all time) y: 73 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 9 contributors (all time) y: 111 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java x: 9 contributors (all time) y: 75 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 9 contributors (all time) y: 100 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java x: 9 contributors (all time) y: 63 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 9 contributors (all time) y: 82 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 9 contributors (all time) y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 9 contributors (all time) y: 103 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 9 contributors (all time) y: 69 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 9 contributors (all time) y: 78 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java x: 9 contributors (all time) y: 99 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java x: 9 contributors (all time) y: 87 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java x: 9 contributors (all time) y: 149 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 9 contributors (all time) y: 60 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/ScalaTupleSerializer.java x: 5 contributors (all time) y: 33 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java x: 10 contributors (all time) y: 126 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 5 contributors (all time) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GoogleCloudStorageSourceMapping.java x: 4 contributors (all time) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java x: 9 contributors (all time) y: 45 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ParquetSourceMapping.java x: 2 contributors (all time) y: 32 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java x: 5 contributors (all time) y: 70 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java x: 6 contributors (all time) y: 98 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 2 contributors (all time) y: 115 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java x: 11 contributors (all time) y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkParquetSource.java x: 2 contributors (all time) y: 74 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 7 contributors (all time) y: 130 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java x: 7 contributors (all time) y: 118 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java x: 11 contributors (all time) y: 50 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java x: 6 contributors (all time) y: 62 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java x: 3 contributors (all time) y: 9 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/Util.java x: 3 contributors (all time) y: 7 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCount.java x: 3 contributors (all time) y: 46 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCountOnKafkaTopic.java x: 3 contributors (all time) y: 62 lines of code wayang-assembly/dependency-reduced-pom.xml x: 5 contributors (all time) y: 162 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSource.java x: 3 contributors (all time) y: 78 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/tpch/Query1.scala x: 5 contributors (all time) y: 79 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCount.scala x: 5 contributors (all time) y: 30 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FlinkCoGroupFunction.java x: 6 contributors (all time) y: 10 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorDistinct.java x: 6 contributors (all time) y: 19 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/OutputFormatConsumer.java x: 6 contributors (all time) y: 25 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/DummyFilter.java x: 6 contributors (all time) y: 20 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangAggregator.java x: 6 contributors (all time) y: 26 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangConvergenceCriterion.java x: 6 contributors (all time) y: 33 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java x: 2 contributors (all time) y: 177 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Configuration.java x: 10 contributors (all time) y: 621 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FunctionDescriptor.java x: 7 contributors (all time) y: 78 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java x: 4 contributors (all time) y: 78 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimator.java x: 4 contributors (all time) y: 10 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimate.java x: 5 contributors (all time) y: 48 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfile.java x: 5 contributors (all time) y: 120 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java x: 4 contributors (all time) y: 119 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorAlternative.java x: 4 contributors (all time) y: 216 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorBase.java x: 4 contributors (all time) y: 233 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainer.java x: 4 contributors (all time) y: 111 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainers.java x: 4 contributors (all time) y: 83 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Slot.java x: 4 contributors (all time) y: 54 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java x: 4 contributors (all time) y: 185 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySink.java x: 4 contributors (all time) y: 25 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java x: 4 contributors (all time) y: 41 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataSetType.java x: 4 contributors (all time) y: 69 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitType.java x: 4 contributors (all time) y: 27 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSource.java x: 2 contributors (all time) y: 79 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSourceMapping.java x: 2 contributors (all time) y: 28 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSink.java x: 2 contributors (all time) y: 83 lines of code python/src/pywy/basic/__init__.py x: 3 contributors (all time) y: 1 lines of code python/src/pywy/basic/model/ops.py x: 3 contributors (all time) y: 157 lines of code python/src/pywy/basic/model/option.py x: 3 contributors (all time) y: 28 lines of code python/src/pywy/core/__init__.py x: 7 contributors (all time) y: 7 lines of code wayang-api/wayang-api-json/src/main/scala/exception/WayangApiJsonException.scala x: 5 contributors (all time) y: 2 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflow.scala x: 5 contributors (all time) y: 14 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ComposedOperatorFromJson.scala x: 5 contributors (all time) y: 11 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/CoGroupOperatorFromJson.scala x: 5 contributors (all time) y: 16 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/DLTrainingOperatorFromJson.scala x: 3 contributors (all time) y: 68 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/PredictOperatorFromJson.scala x: 3 contributors (all time) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/TextFileInputFromJson.scala x: 5 contributors (all time) y: 20 lines of code wayang-api/wayang-api-json/src/main/scala/parserutil/ParsePlanFromJson.scala x: 3 contributors (all time) y: 25 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessFeeder.java x: 5 contributors (all time) y: 103 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonWorkerManager.java x: 6 contributors (all time) y: 31 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ReaderIterator.java x: 5 contributors (all time) y: 53 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedPythonFunction.java x: 4 contributors (all time) y: 16 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextDataQuanta.scala x: 4 contributors (all time) y: 66 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextPlanBuilder.scala x: 4 contributors (all time) y: 76 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaAsyncResult.scala x: 4 contributors (all time) y: 4 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/package.scala x: 4 contributors (all time) y: 63 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/SerializationUtils.scala x: 4 contributors (all time) y: 165 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/GenericSerializableDeserializer.scala x: 4 contributors (all time) y: 12 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/OperatorDeserializer.scala x: 4 contributors (all time) y: 286 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformDeserializer.scala x: 4 contributors (all time) y: 22 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/IgnoreLoggerMixIn.scala x: 4 contributors (all time) y: 7 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/OperatorMixIns.scala x: 4 contributors (all time) y: 102 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/Parameters.scala x: 8 contributors (all time) y: 70 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/WayangContext.java x: 12 contributors (all time) y: 99 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimatorManager.java x: 6 contributors (all time) y: 130 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java x: 6 contributors (all time) y: 281 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CrossPlatformExecutor.java x: 6 contributors (all time) y: 604 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReflectionUtils.java x: 6 contributors (all time) y: 282 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java x: 8 contributors (all time) y: 97 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRandomSampleOperator.java x: 5 contributors (all time) y: 101 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReservoirSampleOperator.java x: 5 contributors (all time) y: 90 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToRddOperator.java x: 6 contributors (all time) y: 76 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/FunctionCompiler.java x: 8 contributors (all time) y: 128 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/MapPartitionsFunctionAdapter.java x: 8 contributors (all time) y: 24 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperator.java x: 8 contributors (all time) y: 77 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java x: 8 contributors (all time) y: 207 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java x: 8 contributors (all time) y: 166 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectionSource.java x: 5 contributors (all time) y: 177 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DecisionTreeClassificationModel.java x: 7 contributors (all time) y: 4 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Input.java x: 3 contributors (all time) y: 37 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Op.java x: 3 contributors (all time) y: 51 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DLTrainingOperator.java x: 3 contributors (all time) y: 59 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DecisionTreeClassificationOperator.java x: 7 contributors (all time) y: 15 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LinearRegressionOperator.java x: 7 contributors (all time) y: 29 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ModelTransformOperator.java x: 7 contributors (all time) y: 38 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/model/SparkMLModel.java x: 7 contributors (all time) y: 11 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLinearRegressionOperator.java x: 7 contributors (all time) y: 124 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkModelTransformOperator.java x: 7 contributors (all time) y: 62 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/channels/TensorChannel.java x: 3 contributors (all time) y: 69 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/Convertor.java x: 3 contributors (all time) y: 205 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectOperator.java x: 3 contributors (all time) y: 257 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowDLTrainingOperator.java x: 3 contributors (all time) y: 56 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/TPCHQ1WithJavaNative.java x: 3 contributors (all time) y: 104 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/wordcount/WordCountScala.scala x: 8 contributors (all time) y: 61 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainTreeNode.java x: 2 contributors (all time) y: 58 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java x: 2 contributors (all time) y: 142 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/LocalStage.java x: 5 contributors (all time) y: 5 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/ML4allPlan.java x: 5 contributors (all time) y: 125 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/AssignWrapper.java x: 5 contributors (all time) y: 18 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansUpdate.java x: 5 contributors (all time) y: 27 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/SGDLoop.java x: 5 contributors (all time) y: 25 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java x: 5 contributors (all time) y: 143 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonArray.java x: 4 contributors (all time) y: 97 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonObj.java x: 4 contributors (all time) y: 223 lines of code guides/pom-example.xml x: 6 contributors (all time) y: 68 lines of code src/main/script/prerequisiteCheck.groovy x: 8 contributors (all time) y: 143 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuanta.scala x: 7 contributors (all time) y: 19 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuantaBuilder.scala x: 7 contributors (all time) y: 34 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderCache.scala x: 7 contributors (all time) y: 14 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala x: 7 contributors (all time) y: 49 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcSchema.java x: 5 contributors (all time) y: 403 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcUtils.java x: 5 contributors (all time) y: 193 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/SchemaUtils.java x: 8 contributors (all time) y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTable.java x: 5 contributors (all time) y: 40 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java x: 6 contributors (all time) y: 124 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java x: 6 contributors (all time) y: 139 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/grep/Grep.java x: 5 contributors (all time) y: 110 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/sgd/SGDImpl.java x: 7 contributors (all time) y: 177 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort/Random16.java x: 5 contributors (all time) y: 294 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/LineItemTuple.java x: 7 contributors (all time) y: 133 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/q1/ReturnTuple.java x: 7 contributors (all time) y: 52 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/benchmark/PlanGenerator.scala x: 7 contributors (all time) y: 42 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/crocopr/CrocoPR.scala x: 7 contributors (all time) y: 83 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala x: 7 contributors (all time) y: 122 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SelectNearestCentroidFunction.scala x: 8 contributors (all time) y: 33 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SimWords.scala x: 7 contributors (all time) y: 116 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/Word2NVec.scala x: 7 contributors (all time) y: 98 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraGen.scala x: 5 contributors (all time) y: 82 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/TpcH.scala x: 7 contributors (all time) y: 90 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query1.scala x: 7 contributors (all time) y: 92 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala x: 7 contributors (all time) y: 95 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KMeansOperator.java x: 8 contributors (all time) y: 27 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java x: 14 contributors (all time) y: 545 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultEstimatableCost.java x: 5 contributors (all time) y: 244 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanImplementation.java x: 7 contributors (all time) y: 665 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/S3FileSystem.java x: 3 contributors (all time) y: 194 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/utils/SparseVector.java x: 5 contributors (all time) y: 172 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataSetChannel.java x: 6 contributors (all time) y: 65 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/WayangFileOutputFormat.java x: 7 contributors (all time) y: 282 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangValue.java x: 6 contributors (all time) y: 102 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkContextReference.java x: 6 contributors (all time) y: 56 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/DoWhileMapping.java x: 6 contributors (all time) y: 37 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/FilterMapping.java x: 6 contributors (all time) y: 36 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/SampleMapping.java x: 6 contributors (all time) y: 41 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDoWhileOperator.java x: 6 contributors (all time) y: 155 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkIntersectOperator.java x: 6 contributors (all time) y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkPageRankOperator.java x: 6 contributors (all time) y: 167 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java x: 6 contributors (all time) y: 70 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/plugin/FlinkGraphPlugin.java x: 6 contributors (all time) y: 6 lines of code wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/execution/GenericJdbcExecutor.java x: 5 contributors (all time) y: 153 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/channels/SqlQueryChannel.java x: 6 contributors (all time) y: 72 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcJoinOperator.java x: 5 contributors (all time) y: 54 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToStreamOperator.java x: 6 contributors (all time) y: 159 lines of code wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/JoinMapping.java x: 5 contributors (all time) y: 49 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/BroadcastChannel.java x: 6 contributors (all time) y: 52 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/ChannelConversions.java x: 6 contributors (all time) y: 87 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/FileChannels.java x: 6 contributors (all time) y: 4 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/RddChannel.java x: 6 contributors (all time) y: 92 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutionContext.java x: 6 contributors (all time) y: 47 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/SampleMapping.java x: 6 contributors (all time) y: 57 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ApplicationEnd.java x: 5 contributors (all time) y: 61 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/SparkListener.java x: 5 contributors (all time) y: 375 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageCompleted.java x: 5 contributors (all time) y: 113 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskEnd.java x: 5 contributors (all time) y: 149 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskGettingResult.java x: 5 contributors (all time) y: 147 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java x: 6 contributors (all time) y: 131 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkFilterOperator.java x: 6 contributors (all time) y: 77 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperator.java x: 6 contributors (all time) y: 81 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java x: 6 contributors (all time) y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java x: 6 contributors (all time) y: 146 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java x: 7 contributors (all time) y: 72 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/platform/SparkPlatform.java x: 7 contributors (all time) y: 169 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/IEJoin.java x: 7 contributors (all time) y: 82 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/spark/IESelfJoinMapping.java x: 7 contributors (all time) y: 36 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperator.java x: 7 contributors (all time) y: 107 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIESelfJoinOperator.java x: 7 contributors (all time) y: 87 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java x: 7 contributors (all time) y: 158 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java x: 7 contributors (all time) y: 188 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/revDataComparator.java x: 7 contributors (all time) y: 65 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java x: 7 contributors (all time) y: 182 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfiler.java x: 7 contributors (all time) y: 140 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfilers.java x: 6 contributors (all time) y: 253 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java x: 7 contributors (all time) y: 201 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java x: 7 contributors (all time) y: 481 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/Individual.java x: 6 contributors (all time) y: 172 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/LogEvaluator.java x: 7 contributors (all time) y: 181 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/OptimizationSpace.java x: 6 contributors (all time) y: 43 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/Main.java x: 7 contributors (all time) y: 137 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/OperatorProfilers.java x: 6 contributors (all time) y: 322 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkOperatorProfiler.java x: 7 contributors (all time) y: 262 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/platform/JdbcPlatformTemplate.java x: 2 contributors (all time) y: 72 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSink.java x: 1 contributors (all time) y: 26 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSource.java x: 1 contributors (all time) y: 92 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSinkMapping.java x: 1 contributors (all time) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSourceMapping.java x: 1 contributors (all time) y: 40 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSink.java x: 3 contributors (all time) y: 133 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSource.java x: 3 contributors (all time) y: 164 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionPlan.java x: 3 contributors (all time) y: 153 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/SanityChecker.java x: 3 contributors (all time) y: 93 lines of code wayang-docs/src/main/resources/_includes/head.html x: 2 contributors (all time) y: 44 lines of code wayang-docs/src/main/resources/_layouts/default.html x: 2 contributors (all time) y: 64 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/ProfileDB.java x: 2 contributors (all time) y: 70 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Experiment.java x: 2 contributors (all time) y: 90 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Type.java x: 2 contributors (all time) y: 10 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/measurement/TimeMeasurement.java x: 2 contributors (all time) y: 102 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/JDBCStorage.java x: 2 contributors (all time) y: 47 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/SimpleEstimationContext.java x: 4 contributors (all time) y: 80 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecution.java x: 3 contributors (all time) y: 101 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecutionGroup.java x: 3 contributors (all time) y: 95 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PartialExecution.java x: 3 contributors (all time) y: 134 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionLog.java x: 3 contributors (all time) y: 90 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/graph/JavaPageRankOperator.java x: 2 contributors (all time) y: 98 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TextFileSource.java x: 2 contributors (all time) y: 121 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumeration.java x: 2 contributors (all time) y: 401 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerator.java x: 2 contributors (all time) y: 666 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionPlanMeasurement.java x: 2 contributors (all time) y: 169 lines of code wayang-docs/src/main/resources/_includes/sub-menu.html x: 2 contributors (all time) y: 51 lines of code wayang-docs/src/main/resources/_sass/main.scss x: 2 contributors (all time) y: 8 lines of code wayang-docs/src/main/resources/assets/css/main.css x: 2 contributors (all time) y: 103 lines of code wayang-docs/src/main/resources/assets/css/monokai.css x: 2 contributors (all time) y: 92 lines of code wayang-docs/src/main/resources/assets/js/add_numbers.js x: 2 contributors (all time) y: 12 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/KeyValueProvider.java x: 2 contributors (all time) y: 68 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/PlanTransformation.java x: 2 contributors (all time) y: 110 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationContext.java x: 2 contributors (all time) y: 452 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraph.java x: 2 contributors (all time) y: 629 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlowCompiler.java x: 2 contributors (all time) y: 305 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LatentOperatorPruningStrategy.java x: 2 contributors (all time) y: 61 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversal.java x: 2 contributors (all time) y: 549 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/Channel.java x: 2 contributors (all time) y: 249 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ExecutionOperator.java x: 2 contributors (all time) y: 148 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopIsolator.java x: 2 contributors (all time) y: 82 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanTraversal.java x: 2 contributors (all time) y: 180 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/WayangPlan.java x: 2 contributors (all time) y: 111 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutorTemplate.java x: 2 contributors (all time) y: 118 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Junction.java x: 2 contributors (all time) y: 135 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/LazyExecutionLineageNode.java x: 2 contributors (all time) y: 94 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm/PageRankAlgorithm.java x: 2 contributors (all time) y: 183 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/operators/GiraphPageRankOperator.java x: 2 contributors (all time) y: 147 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java x: 2 contributors (all time) y: 5 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels/FileChannel.java x: 2 contributors (all time) y: 139 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple2.java x: 2 contributors (all time) y: 38 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple5.java x: 2 contributors (all time) y: 56 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java x: 2 contributors (all time) y: 107 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/MaterializedGroupByMapping.java x: 2 contributors (all time) y: 41 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/PageRankMapping.java x: 2 contributors (all time) y: 226 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GlobalMaterializedGroupOperator.java x: 2 contributors (all time) y: 25 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LoopOperator.java x: 2 contributors (all time) y: 194 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java x: 2 contributors (all time) y: 130 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimationTraversal.java x: 2 contributors (all time) y: 256 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/FixedSizeCardinalityEstimator.java x: 2 contributors (all time) y: 18 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/OperatorAlternativeCardinalityPusher.java x: 2 contributors (all time) y: 35 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStage.java x: 2 contributors (all time) y: 233 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PushExecutorTemplate.java x: 2 contributors (all time) y: 222 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin/DynamicPlugin.java x: 2 contributors (all time) y: 198 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Bitmask.java x: 2 contributors (all time) y: 260 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/Sqlite3.java x: 1 contributors (all time) y: 17 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/Mappings.java x: 1 contributors (all time) y: 10 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/ProjectionMapping.java x: 1 contributors (all time) y: 39 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/Sqlite3FilterOperator.java x: 1 contributors (all time) y: 18 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/Sqlite3ProjectionOperator.java x: 1 contributors (all time) y: 21 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/plugin/Sqlite3ConversionPlugin.java x: 1 contributors (all time) y: 29 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcFilterOperator.java x: 1 contributors (all time) y: 33 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcProjectionOperator.java x: 1 contributors (all time) y: 49 lines of code wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/ProjectionMapping.java x: 1 contributors (all time) y: 44 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/ChannelConversions.java x: 1 contributors (all time) y: 59 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/JavaChannelInstance.java x: 1 contributors (all time) y: 7 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/StreamChannel.java x: 1 contributors (all time) y: 71 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/SampleMapping.java x: 1 contributors (all time) y: 53 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCartesianOperator.java x: 1 contributors (all time) y: 123 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCoGroupOperator.java x: 1 contributors (all time) y: 119 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCountOperator.java x: 1 contributors (all time) y: 63 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaDistinctOperator.java x: 1 contributors (all time) y: 56 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFilterOperator.java x: 1 contributors (all time) y: 76 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFlatMapOperator.java x: 1 contributors (all time) y: 86 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGlobalMaterializedGroupOperator.java x: 1 contributors (all time) y: 60 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaIntersectOperator.java x: 1 contributors (all time) y: 99 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaJoinOperator.java x: 1 contributors (all time) y: 139 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMapPartitionsOperator.java x: 1 contributors (all time) y: 85 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMaterializedGroupByOperator.java x: 1 contributors (all time) y: 78 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReduceByOperator.java x: 1 contributors (all time) y: 131 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRepeatOperator.java x: 1 contributors (all time) y: 90 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTsvFileSource.java x: 1 contributors (all time) y: 104 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Giraph.java x: 1 contributors (all time) y: 12 lines of code
721.0
lines of code
  min: 1.0
  average: 64.89
  25th percentile: 24.0
  median: 38.0
  75th percentile: 79.0
  max: 721.0
0 18.0
contributors (all time)
min: 1.0 | average: 4.37 | 25th percentile: 2.0 | median: 5.0 | 75th percentile: 6.0 | max: 18.0

File Size vs. Commits (30 days): 118 points

python/src/pywy/basic/data/__init__.py x: 1 commits (30d) y: 1 lines of code python/src/pywy/basic/data/record.py x: 2 commits (30d) y: 31 lines of code python/src/pywy/core/core.py x: 1 commits (30d) y: 56 lines of code python/src/pywy/core/serializer.py x: 3 commits (30d) y: 76 lines of code python/src/pywy/dataquanta.py x: 2 commits (30d) y: 154 lines of code python/src/pywy/execution/util.py x: 1 commits (30d) y: 7 lines of code python/src/pywy/execution/worker.py x: 1 commits (30d) y: 91 lines of code python/src/pywy/graph/graph.py x: 1 commits (30d) y: 58 lines of code python/src/pywy/operators/__init__.py x: 1 commits (30d) y: 27 lines of code python/src/pywy/operators/base.py x: 2 commits (30d) y: 66 lines of code python/src/pywy/operators/binary.py x: 3 commits (30d) y: 59 lines of code python/src/pywy/operators/sink.py x: 1 commits (30d) y: 24 lines of code python/src/pywy/operators/source.py x: 2 commits (30d) y: 44 lines of code python/src/pywy/operators/unary.py x: 3 commits (30d) y: 127 lines of code wayang-api/wayang-api-json/src/main/scala/Main.scala x: 1 commits (30d) y: 49 lines of code wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 2 commits (30d) y: 503 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 2 commits (30d) y: 83 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 1 commits (30d) y: 44 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 1 commits (30d) y: 135 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 1 commits (30d) y: 37 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 1 commits (30d) y: 12 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 1 commits (30d) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 2 commits (30d) y: 20 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 3 commits (30d) y: 61 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 8 commits (30d) y: 73 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 1 commits (30d) y: 30 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 5 commits (30d) y: 96 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 4 commits (30d) y: 610 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 6 commits (30d) y: 60 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 4 commits (30d) y: 33 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 6 commits (30d) y: 29 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 6 commits (30d) y: 52 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 8 commits (30d) y: 88 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 3 commits (30d) y: 25 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 8 commits (30d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 3 commits (30d) y: 10 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 7 commits (30d) y: 48 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 4 commits (30d) y: 50 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 7 commits (30d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 9 commits (30d) y: 92 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 4 commits (30d) y: 19 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 10 commits (30d) y: 116 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 commits (30d) y: 14 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java x: 3 commits (30d) y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinKeyExtractor.java x: 4 commits (30d) y: 12 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 6 commits (30d) y: 86 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 5 commits (30d) y: 18 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java x: 3 commits (30d) y: 30 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 3 commits (30d) y: 149 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangSortRule.java x: 6 commits (30d) y: 32 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 3 commits (30d) y: 79 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 4 commits (30d) y: 74 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 3 commits (30d) y: 177 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 1 commits (30d) y: 721 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 1 commits (30d) y: 179 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 1 commits (30d) y: 66 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 1 commits (30d) y: 65 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 1 commits (30d) y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 1 commits (30d) y: 188 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 1 commits (30d) y: 185 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 1 commits (30d) y: 163 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 1 commits (30d) y: 126 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 1 commits (30d) y: 270 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 1 commits (30d) y: 107 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java x: 1 commits (30d) y: 73 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 1 commits (30d) y: 111 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java x: 1 commits (30d) y: 75 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 1 commits (30d) y: 100 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 1 commits (30d) y: 82 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 1 commits (30d) y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 1 commits (30d) y: 103 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 1 commits (30d) y: 69 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 1 commits (30d) y: 78 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java x: 1 commits (30d) y: 99 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java x: 1 commits (30d) y: 87 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java x: 1 commits (30d) y: 149 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 1 commits (30d) y: 60 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/ScalaTupleSerializer.java x: 1 commits (30d) y: 33 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 1 commits (30d) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 1 commits (30d) y: 115 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 1 commits (30d) y: 130 lines of code
721.0
lines of code
  min: 1.0
  average: 84.2
  25th percentile: 32.0
  median: 66.0
  75th percentile: 102.25
  max: 721.0
0 10.0
commits (30d)
min: 1.0 | average: 2.25 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 3.0 | max: 10.0

File Size vs. Contributors (30 days): 118 points

python/src/pywy/basic/data/__init__.py x: 1 contributors (30d) y: 1 lines of code python/src/pywy/basic/data/record.py x: 2 contributors (30d) y: 31 lines of code python/src/pywy/core/core.py x: 1 contributors (30d) y: 56 lines of code python/src/pywy/core/serializer.py x: 2 contributors (30d) y: 76 lines of code python/src/pywy/dataquanta.py x: 2 contributors (30d) y: 154 lines of code python/src/pywy/execution/util.py x: 1 contributors (30d) y: 7 lines of code python/src/pywy/execution/worker.py x: 1 contributors (30d) y: 91 lines of code python/src/pywy/graph/graph.py x: 1 contributors (30d) y: 58 lines of code python/src/pywy/operators/__init__.py x: 1 contributors (30d) y: 27 lines of code python/src/pywy/operators/base.py x: 2 contributors (30d) y: 66 lines of code python/src/pywy/operators/binary.py x: 2 contributors (30d) y: 59 lines of code python/src/pywy/operators/sink.py x: 1 contributors (30d) y: 24 lines of code python/src/pywy/operators/source.py x: 2 contributors (30d) y: 44 lines of code python/src/pywy/operators/unary.py x: 2 contributors (30d) y: 127 lines of code wayang-api/wayang-api-json/src/main/scala/Main.scala x: 1 contributors (30d) y: 49 lines of code wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 2 contributors (30d) y: 503 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 2 contributors (30d) y: 83 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 1 contributors (30d) y: 44 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 1 contributors (30d) y: 135 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 1 contributors (30d) y: 37 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 1 contributors (30d) y: 12 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 1 contributors (30d) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 2 contributors (30d) y: 20 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 2 contributors (30d) y: 61 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 5 contributors (30d) y: 73 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 1 contributors (30d) y: 30 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 4 contributors (30d) y: 96 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 4 contributors (30d) y: 610 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 4 contributors (30d) y: 60 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 4 contributors (30d) y: 33 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 4 contributors (30d) y: 29 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 3 contributors (30d) y: 52 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 4 contributors (30d) y: 88 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 3 contributors (30d) y: 25 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 5 contributors (30d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 3 contributors (30d) y: 10 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 4 contributors (30d) y: 48 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 4 contributors (30d) y: 50 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 4 contributors (30d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 4 contributors (30d) y: 92 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 4 contributors (30d) y: 19 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 3 contributors (30d) y: 116 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 contributors (30d) y: 14 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java x: 3 contributors (30d) y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 4 contributors (30d) y: 86 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 3 contributors (30d) y: 18 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java x: 3 contributors (30d) y: 30 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java x: 3 contributors (30d) y: 32 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 3 contributors (30d) y: 149 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 3 contributors (30d) y: 79 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 4 contributors (30d) y: 74 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaSortOperator.java x: 3 contributors (30d) y: 60 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 3 contributors (30d) y: 177 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 1 contributors (30d) y: 721 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 1 contributors (30d) y: 179 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 1 contributors (30d) y: 66 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 1 contributors (30d) y: 65 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 1 contributors (30d) y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 1 contributors (30d) y: 188 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 1 contributors (30d) y: 185 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 1 contributors (30d) y: 163 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 1 contributors (30d) y: 126 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 1 contributors (30d) y: 270 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 1 contributors (30d) y: 107 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java x: 1 contributors (30d) y: 73 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 1 contributors (30d) y: 111 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java x: 1 contributors (30d) y: 75 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 1 contributors (30d) y: 100 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 1 contributors (30d) y: 82 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 1 contributors (30d) y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 1 contributors (30d) y: 103 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 1 contributors (30d) y: 69 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 1 contributors (30d) y: 78 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java x: 1 contributors (30d) y: 99 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java x: 1 contributors (30d) y: 87 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java x: 1 contributors (30d) y: 149 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 1 contributors (30d) y: 60 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/ScalaTupleSerializer.java x: 1 contributors (30d) y: 33 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 1 contributors (30d) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 1 contributors (30d) y: 115 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 1 contributors (30d) y: 130 lines of code
721.0
lines of code
  min: 1.0
  average: 84.2
  25th percentile: 32.0
  median: 66.0
  75th percentile: 102.25
  max: 721.0
0 5.0
contributors (30d)
min: 1.0 | average: 1.82 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 3.0 | max: 5.0

File Size vs. Commits (90 days): 128 points

python/src/pywy/basic/data/__init__.py x: 1 commits (90d) y: 1 lines of code python/src/pywy/basic/data/record.py x: 3 commits (90d) y: 31 lines of code python/src/pywy/core/core.py x: 2 commits (90d) y: 56 lines of code python/src/pywy/core/serializer.py x: 10 commits (90d) y: 76 lines of code python/src/pywy/dataquanta.py x: 3 commits (90d) y: 154 lines of code python/src/pywy/execution/util.py x: 2 commits (90d) y: 7 lines of code python/src/pywy/execution/worker.py x: 2 commits (90d) y: 91 lines of code python/src/pywy/graph/graph.py x: 2 commits (90d) y: 58 lines of code python/src/pywy/operators/__init__.py x: 2 commits (90d) y: 27 lines of code python/src/pywy/operators/base.py x: 3 commits (90d) y: 66 lines of code python/src/pywy/operators/binary.py x: 9 commits (90d) y: 59 lines of code python/src/pywy/operators/sink.py x: 2 commits (90d) y: 24 lines of code python/src/pywy/operators/source.py x: 3 commits (90d) y: 44 lines of code python/src/pywy/operators/unary.py x: 4 commits (90d) y: 127 lines of code wayang-api/wayang-api-json/src/main/scala/Main.scala x: 1 commits (90d) y: 49 lines of code wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 4 commits (90d) y: 503 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 3 commits (90d) y: 83 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 2 commits (90d) y: 44 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 2 commits (90d) y: 135 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 1 commits (90d) y: 37 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 2 commits (90d) y: 12 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 2 commits (90d) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 3 commits (90d) y: 20 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java x: 7 commits (90d) y: 28 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 11 commits (90d) y: 61 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 14 commits (90d) y: 73 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 2 commits (90d) y: 30 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 7 commits (90d) y: 96 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 8 commits (90d) y: 610 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 8 commits (90d) y: 60 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 6 commits (90d) y: 33 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 10 commits (90d) y: 29 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 6 commits (90d) y: 52 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 8 commits (90d) y: 88 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 3 commits (90d) y: 25 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 14 commits (90d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 3 commits (90d) y: 10 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 7 commits (90d) y: 48 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 9 commits (90d) y: 50 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 9 commits (90d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 11 commits (90d) y: 92 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 6 commits (90d) y: 19 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 10 commits (90d) y: 116 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 commits (90d) y: 14 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinKeyExtractor.java x: 4 commits (90d) y: 12 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 6 commits (90d) y: 86 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 5 commits (90d) y: 18 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java x: 4 commits (90d) y: 32 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 3 commits (90d) y: 149 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 3 commits (90d) y: 79 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 7 commits (90d) y: 74 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaSortOperator.java x: 3 commits (90d) y: 60 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 3 commits (90d) y: 177 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 5 commits (90d) y: 721 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 5 commits (90d) y: 179 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 10 commits (90d) y: 66 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 5 commits (90d) y: 65 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java x: 8 commits (90d) y: 38 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 4 commits (90d) y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 4 commits (90d) y: 188 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 4 commits (90d) y: 185 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 5 commits (90d) y: 163 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 6 commits (90d) y: 270 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java x: 6 commits (90d) y: 125 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java x: 6 commits (90d) y: 23 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 6 commits (90d) y: 107 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java x: 7 commits (90d) y: 43 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java x: 6 commits (90d) y: 73 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 6 commits (90d) y: 111 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 8 commits (90d) y: 100 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java x: 6 commits (90d) y: 63 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFilterOperator.java x: 6 commits (90d) y: 68 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 6 commits (90d) y: 82 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 6 commits (90d) y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 6 commits (90d) y: 103 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 7 commits (90d) y: 69 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 6 commits (90d) y: 78 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java x: 7 commits (90d) y: 99 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java x: 6 commits (90d) y: 149 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatOperator.java x: 6 commits (90d) y: 102 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSortOperator.java x: 6 commits (90d) y: 70 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 7 commits (90d) y: 60 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java x: 7 commits (90d) y: 77 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 4 commits (90d) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java x: 5 commits (90d) y: 45 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java x: 4 commits (90d) y: 70 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java x: 4 commits (90d) y: 98 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 4 commits (90d) y: 115 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java x: 4 commits (90d) y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkParquetSource.java x: 4 commits (90d) y: 74 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkKMeansOperator.java x: 5 commits (90d) y: 101 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 7 commits (90d) y: 130 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java x: 1 commits (90d) y: 118 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ParquetSourceMapping.java x: 1 commits (90d) y: 34 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java x: 2 commits (90d) y: 62 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java x: 1 commits (90d) y: 9 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/Util.java x: 1 commits (90d) y: 7 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCount.java x: 1 commits (90d) y: 46 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCountOnKafkaTopic.java x: 1 commits (90d) y: 62 lines of code wayang-assembly/dependency-reduced-pom.xml x: 1 commits (90d) y: 162 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSource.java x: 1 commits (90d) y: 78 lines of code
721.0
lines of code
  min: 1.0
  average: 82.53
  25th percentile: 32.25
  median: 64.0
  75th percentile: 101.75
  max: 721.0
0 14.0
commits (90d)
min: 1.0 | average: 4.82 | 25th percentile: 3.0 | median: 4.0 | 75th percentile: 6.0 | max: 14.0

File Size vs. Contributors (90 days): 128 points

python/src/pywy/basic/data/__init__.py x: 1 contributors (90d) y: 1 lines of code python/src/pywy/basic/data/record.py x: 2 contributors (90d) y: 31 lines of code python/src/pywy/core/core.py x: 2 contributors (90d) y: 56 lines of code python/src/pywy/core/serializer.py x: 5 contributors (90d) y: 76 lines of code python/src/pywy/dataquanta.py x: 2 contributors (90d) y: 154 lines of code python/src/pywy/execution/util.py x: 2 contributors (90d) y: 7 lines of code python/src/pywy/execution/worker.py x: 2 contributors (90d) y: 91 lines of code python/src/pywy/graph/graph.py x: 2 contributors (90d) y: 58 lines of code python/src/pywy/operators/__init__.py x: 2 contributors (90d) y: 27 lines of code python/src/pywy/operators/base.py x: 2 contributors (90d) y: 66 lines of code python/src/pywy/operators/binary.py x: 5 contributors (90d) y: 59 lines of code python/src/pywy/operators/sink.py x: 2 contributors (90d) y: 24 lines of code python/src/pywy/operators/source.py x: 2 contributors (90d) y: 44 lines of code python/src/pywy/operators/unary.py x: 2 contributors (90d) y: 127 lines of code wayang-api/wayang-api-json/src/main/scala/Main.scala x: 1 contributors (90d) y: 49 lines of code wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 2 contributors (90d) y: 503 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 2 contributors (90d) y: 83 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 2 contributors (90d) y: 135 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 1 contributors (90d) y: 37 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 2 contributors (90d) y: 12 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 2 contributors (90d) y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 2 contributors (90d) y: 20 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java x: 5 contributors (90d) y: 28 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 3 contributors (90d) y: 61 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 5 contributors (90d) y: 73 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 4 contributors (90d) y: 96 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 6 contributors (90d) y: 610 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 4 contributors (90d) y: 60 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 4 contributors (90d) y: 33 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 4 contributors (90d) y: 29 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 3 contributors (90d) y: 52 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 4 contributors (90d) y: 88 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 3 contributors (90d) y: 25 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 6 contributors (90d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 3 contributors (90d) y: 10 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 4 contributors (90d) y: 48 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 5 contributors (90d) y: 50 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 4 contributors (90d) y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 4 contributors (90d) y: 92 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 4 contributors (90d) y: 19 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 3 contributors (90d) y: 116 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 contributors (90d) y: 14 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java x: 3 contributors (90d) y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 4 contributors (90d) y: 86 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 3 contributors (90d) y: 18 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java x: 3 contributors (90d) y: 30 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java x: 3 contributors (90d) y: 32 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 3 contributors (90d) y: 149 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 3 contributors (90d) y: 79 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 4 contributors (90d) y: 74 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 3 contributors (90d) y: 177 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 3 contributors (90d) y: 721 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 4 contributors (90d) y: 179 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 4 contributors (90d) y: 66 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 4 contributors (90d) y: 65 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java x: 5 contributors (90d) y: 38 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 2 contributors (90d) y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 3 contributors (90d) y: 188 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 3 contributors (90d) y: 185 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 4 contributors (90d) y: 163 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 3 contributors (90d) y: 126 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 5 contributors (90d) y: 270 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java x: 5 contributors (90d) y: 125 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java x: 5 contributors (90d) y: 23 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 5 contributors (90d) y: 107 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java x: 5 contributors (90d) y: 43 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 5 contributors (90d) y: 111 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 5 contributors (90d) y: 100 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java x: 5 contributors (90d) y: 63 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFilterOperator.java x: 5 contributors (90d) y: 68 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 5 contributors (90d) y: 82 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 5 contributors (90d) y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 5 contributors (90d) y: 103 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 5 contributors (90d) y: 69 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 5 contributors (90d) y: 78 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java x: 5 contributors (90d) y: 99 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java x: 5 contributors (90d) y: 87 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java x: 5 contributors (90d) y: 149 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 5 contributors (90d) y: 60 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/ScalaTupleSerializer.java x: 5 contributors (90d) y: 33 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 3 contributors (90d) y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java x: 3 contributors (90d) y: 45 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ParquetSourceMapping.java x: 2 contributors (90d) y: 32 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java x: 3 contributors (90d) y: 70 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java x: 3 contributors (90d) y: 98 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 2 contributors (90d) y: 115 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java x: 3 contributors (90d) y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkParquetSource.java x: 2 contributors (90d) y: 74 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkKMeansOperator.java x: 3 contributors (90d) y: 101 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 3 contributors (90d) y: 130 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java x: 1 contributors (90d) y: 118 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ParquetSourceMapping.java x: 1 contributors (90d) y: 34 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java x: 1 contributors (90d) y: 62 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java x: 1 contributors (90d) y: 9 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/Util.java x: 1 contributors (90d) y: 7 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCount.java x: 1 contributors (90d) y: 46 lines of code wayang-assembly/dependency-reduced-pom.xml x: 1 contributors (90d) y: 162 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSource.java x: 1 contributors (90d) y: 78 lines of code
721.0
lines of code
  min: 1.0
  average: 82.53
  25th percentile: 32.25
  median: 64.0
  75th percentile: 101.75
  max: 721.0
0 6.0
contributors (90d)
min: 1.0 | average: 3.29 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 5.0 | max: 6.0