graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala]" -- "[wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala]" [label=" 15 ", penwidth="10", color="#00688bFF"]; "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateGetResult.java]" -- "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java]" [label=" 9 ", penwidth="6", color="#00688bB7"]; "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java]" -- "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java]" [label=" 9 ", penwidth="6", color="#00688bB7"]; "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateGetResult.java]" -- "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java]" [label=" 9 ", penwidth="6", color="#00688bB7"]; "[python/src/pywy/operators/binary.py]" -- "[python/src/pywy/core/serializer.py]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java]" -- "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java]" -- "[wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java]" -- "[wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java]" -- "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java]" -- "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java]" -- "[python/src/pywy/operators/binary.py]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java]" -- "[wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java]" -- "[wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java]" -- "[wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java]" -- "[wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java]" -- "[python/src/pywy/core/serializer.py]" [label=" 7 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkMapOperator.java]" -- "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFlatMapOperator.java]" -- "[wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java]" -- "[wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java]" [label=" 6 ", penwidth="4", color="#00688b93"]; }