This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 93a9c504b88 [FLINK-29681][python] Fix Python side-output operator not
generated in some cases
add a215d9424af [FLINK-29668][Gelly] Remove Gelly. This closes #21096
No new revisions were added by this update.
Summary of changes:
.../docs/dev/dataset/cluster_execution.md | 14 +
docs/content.zh/docs/dev/dataset/examples.md | 14 +
.../docs/dev/dataset/hadoop_compatibility.md | 14 +
docs/content.zh/docs/dev/dataset/iterations.md | 21 +-
.../content.zh/docs/dev/dataset/local_execution.md | 14 +
.../content.zh/docs/dev/dataset/transformations.md | 14 +
.../docs/dev/dataset/zip_elements_guide.md | 14 +
docs/content.zh/docs/dev/table/overview.md | 4 +-
docs/content.zh/docs/libs/gelly/_index.md | 23 -
docs/content.zh/docs/libs/gelly/bipartite_graph.md | 186 --
.../content.zh/docs/libs/gelly/graph_algorithms.md | 246 --
docs/content.zh/docs/libs/gelly/graph_api.md | 817 ------
.../content.zh/docs/libs/gelly/graph_generators.md | 471 ----
.../docs/libs/gelly/iterative_graph_processing.md | 957 -------
docs/content.zh/docs/libs/gelly/library_methods.md | 458 ----
docs/content.zh/docs/libs/gelly/overview.md | 129 -
docs/content/docs/dev/dataset/cluster_execution.md | 14 +
docs/content/docs/dev/dataset/examples.md | 14 +
docs/content/docs/dev/dataset/hadoop_map_reduce.md | 14 +
docs/content/docs/dev/dataset/iterations.md | 21 +-
docs/content/docs/dev/dataset/local_execution.md | 14 +
docs/content/docs/dev/dataset/transformations.md | 14 +
.../content/docs/dev/dataset/zip_elements_guide.md | 14 +
docs/content/docs/libs/gelly/_index.md | 23 -
docs/content/docs/libs/gelly/bipartite_graph.md | 186 --
docs/content/docs/libs/gelly/graph_algorithms.md | 246 --
docs/content/docs/libs/gelly/graph_api.md | 817 ------
docs/content/docs/libs/gelly/graph_generators.md | 471 ----
.../docs/libs/gelly/iterative_graph_processing.md | 957 -------
docs/content/docs/libs/gelly/library_methods.md | 456 ----
docs/content/docs/libs/gelly/overview.md | 129 -
docs/static/fig/gelly-example-graph.png | Bin 18813 -> 0 bytes
docs/static/fig/gelly-filter.png | Bin 57192 -> 0 bytes
docs/static/fig/gelly-gsa-sssp1.png | Bin 31201 -> 0 bytes
docs/static/fig/gelly-reduceOnEdges.png | Bin 23843 -> 0 bytes
docs/static/fig/gelly-reduceOnNeighbors.png | Bin 34903 -> 0 bytes
docs/static/fig/gelly-union.png | Bin 50498 -> 0 bytes
docs/static/fig/gelly-vc-sssp1.png | Bin 28537 -> 0 bytes
flink-dist/pom.xml | 21 -
flink-dist/src/main/assemblies/bin.xml | 10 -
flink-dist/src/main/assemblies/opt.xml | 15 -
.../apache/flink/api/java/utils/DataSetUtils.java | 3 +-
flink-libraries/flink-gelly-examples/pom.xml | 258 --
.../main/java/org/apache/flink/graph/Runner.java | 572 -----
.../org/apache/flink/graph/drivers/AdamicAdar.java | 74 -
.../flink/graph/drivers/ClusteringCoefficient.java | 149 --
.../flink/graph/drivers/ConnectedComponents.java | 63 -
.../org/apache/flink/graph/drivers/Driver.java | 78 -
.../org/apache/flink/graph/drivers/DriverBase.java | 44 -
.../org/apache/flink/graph/drivers/EdgeList.java | 79 -
.../apache/flink/graph/drivers/GraphMetrics.java | 126 -
.../java/org/apache/flink/graph/drivers/HITS.java | 64 -
.../apache/flink/graph/drivers/JaccardIndex.java | 82 -
.../org/apache/flink/graph/drivers/PageRank.java | 73 -
.../flink/graph/drivers/TriangleListing.java | 147 --
.../org/apache/flink/graph/drivers/input/CSV.java | 106 -
.../flink/graph/drivers/input/CirculantGraph.java | 125 -
.../flink/graph/drivers/input/CompleteGraph.java | 52 -
.../flink/graph/drivers/input/CycleGraph.java | 51 -
.../flink/graph/drivers/input/EchoGraph.java | 57 -
.../flink/graph/drivers/input/EmptyGraph.java | 51 -
.../flink/graph/drivers/input/GeneratedGraph.java | 49 -
.../graph/drivers/input/GeneratedMultiGraph.java | 58 -
.../flink/graph/drivers/input/GridGraph.java | 156 --
.../flink/graph/drivers/input/HypercubeGraph.java | 53 -
.../apache/flink/graph/drivers/input/Input.java | 49 -
.../flink/graph/drivers/input/InputBase.java | 46 -
.../flink/graph/drivers/input/PathGraph.java | 51 -
.../flink/graph/drivers/input/RMatGraph.java | 109 -
.../graph/drivers/input/SingletonEdgeGraph.java | 54 -
.../flink/graph/drivers/input/StarGraph.java | 51 -
.../org/apache/flink/graph/drivers/output/CSV.java | 60 -
.../apache/flink/graph/drivers/output/Hash.java | 51 -
.../apache/flink/graph/drivers/output/Output.java | 38 -
.../flink/graph/drivers/output/OutputBase.java | 29 -
.../apache/flink/graph/drivers/output/Print.java | 66 -
.../graph/drivers/parameter/BooleanParameter.java | 50 -
.../graph/drivers/parameter/ChoiceParameter.java | 144 --
.../graph/drivers/parameter/DoubleParameter.java | 238 --
.../drivers/parameter/IterationConvergence.java | 90 -
.../graph/drivers/parameter/LongParameter.java | 140 --
.../flink/graph/drivers/parameter/Parameter.java | 63 -
.../graph/drivers/parameter/Parameterized.java | 49 -
.../graph/drivers/parameter/ParameterizedBase.java | 72 -
.../graph/drivers/parameter/SimpleParameter.java | 72 -
.../flink/graph/drivers/parameter/Simplify.java | 154 --
.../graph/drivers/parameter/StringParameter.java | 54 -
.../apache/flink/graph/drivers/parameter/Util.java | 51 -
.../drivers/transform/GraphKeyTypeTransform.java | 806 ------
.../transform/LongValueWithProperHashCode.java | 243 --
.../flink/graph/drivers/transform/Transform.java | 59 -
.../graph/drivers/transform/Transformable.java | 36 -
.../graph/examples/EuclideanGraphWeighing.java | 227 --
.../apache/flink/graph/examples/GSAPageRank.java | 129 -
.../examples/GSASingleSourceShortestPaths.java | 197 --
.../flink/graph/examples/IncrementalSSSP.java | 291 ---
.../apache/flink/graph/examples/MusicProfiles.java | 322 ---
.../org/apache/flink/graph/examples/PageRank.java | 127 -
.../apache/flink/graph/examples/PregelSSSP.java | 196 --
.../graph/examples/SingleSourceShortestPaths.java | 204 --
.../examples/data/CommunityDetectionData.java | 95 -
.../data/ConnectedComponentsDefaultData.java | 58 -
.../graph/examples/data/EuclideanGraphData.java | 108 -
.../graph/examples/data/IncrementalSSSPData.java | 107 -
.../graph/examples/data/LabelPropagationData.java | 103 -
.../graph/examples/data/MusicProfilesData.java | 111 -
.../flink/graph/examples/data/PageRankData.java | 58 -
.../data/SingleSourceShortestPathsData.java | 69 -
.../graph/examples/data/SummarizationData.java | 130 -
.../graph/examples/data/TriangleCountData.java | 66 -
.../src/main/resources/log4j2.properties | 25 -
.../src/main/resources/logback.xml | 29 -
.../graph/scala/examples/ConnectedComponents.scala | 116 -
.../examples/GSASingleSourceShortestPaths.scala | 155 --
.../scala/examples/SingleSourceShortestPaths.scala | 171 --
.../java/org/apache/flink/graph/RunnerITCase.java | 114 -
.../flink/graph/drivers/AdamicAdarITCase.java | 84 -
.../graph/drivers/ClusteringCoefficientITCase.java | 109 -
.../graph/drivers/ConnectedComponentsITCase.java | 87 -
.../drivers/CopyableValueDriverBaseITCase.java | 53 -
.../flink/graph/drivers/DriverBaseITCase.java | 256 --
.../apache/flink/graph/drivers/EdgeListITCase.java | 380 ---
.../flink/graph/drivers/GraphMetricsITCase.java | 119 -
.../org/apache/flink/graph/drivers/HITSITCase.java | 75 -
.../flink/graph/drivers/JaccardIndexITCase.java | 90 -
.../drivers/NonTransformableDriverBaseITCase.java | 63 -
.../apache/flink/graph/drivers/PageRankITCase.java | 75 -
.../org/apache/flink/graph/drivers/TestUtils.java | 117 -
.../flink/graph/drivers/TriangleListingITCase.java | 147 --
.../drivers/parameter/BooleanParameterTest.java | 54 -
.../drivers/parameter/ChoiceParameterTest.java | 84 -
.../drivers/parameter/DoubleParameterTest.java | 341 ---
.../parameter/IterationConvergenceTest.java | 68 -
.../graph/drivers/parameter/LongParameterTest.java | 177 --
.../graph/drivers/parameter/ParameterTestBase.java | 39 -
.../graph/drivers/parameter/SimplifyTest.java | 57 -
.../drivers/parameter/StringParameterTest.java | 78 -
.../transform/GraphKeyTypeTransformTest.java | 638 -----
...lueWithProperHashCodeSerializerUpgradeTest.java | 99 -
.../graph/library/CommunityDetectionITCase.java | 93 -
.../graph/library/LabelPropagationITCase.java | 83 -
.../flink/graph/library/SummarizationITCase.java | 232 --
.../graph/library/TriangleEnumeratorITCase.java | 60 -
.../flink/graph/test/GatherSumApplyITCase.java | 124 -
.../examples/EuclideanGraphWeighingITCase.java | 78 -
.../graph/test/examples/IncrementalSSSPITCase.java | 144 --
.../graph/test/examples/MusicProfilesITCase.java | 114 -
.../flink/graph/test/examples/PageRankITCase.java | 128 -
.../examples/SingleSourceShortestPathsITCase.java | 95 -
.../serializer-snapshot | Bin 162 -> 0 bytes
.../test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 162 -> 0 bytes
.../test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 162 -> 0 bytes
.../test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 162 -> 0 bytes
.../test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 162 -> 0 bytes
.../test-data | Bin 8 -> 0 bytes
flink-libraries/flink-gelly-scala/pom.xml | 241 --
.../apache/flink/graph/scala/EdgesFunction.scala | 36 -
.../graph/scala/EdgesFunctionWithVertexValue.scala | 34 -
.../scala/org/apache/flink/graph/scala/Graph.scala | 1401 -----------
.../flink/graph/scala/NeighborsFunction.scala | 37 -
.../scala/NeighborsFunctionWithVertexValue.scala | 43 -
.../org/apache/flink/graph/scala/package.scala | 32 -
.../flink/graph/scala/utils/EdgeToTuple3Map.scala | 29 -
.../graph/scala/utils/Tuple2ToVertexMap.scala | 29 -
.../flink/graph/scala/utils/Tuple3ToEdgeMap.scala | 29 -
.../graph/scala/utils/VertexToTuple2Map.scala | 29 -
.../scala/test/GellyScalaAPICompletenessTest.scala | 46 -
.../flink/graph/scala/test/TestGraphUtils.scala | 54 -
.../scala/test/operations/DegreesITCase.scala | 77 -
.../operations/GraphCreationWithCsvITCase.scala | 210 --
.../test/operations/GraphMutationsITCase.scala | 315 ---
.../test/operations/GraphOperationsITCase.scala | 347 ---
.../test/operations/JoinWithEdgesITCase.scala | 171 --
.../test/operations/JoinWithVerticesITCase.scala | 80 -
.../scala/test/operations/MapEdgesITCase.scala | 85 -
.../scala/test/operations/MapVerticesITCase.scala | 81 -
.../operations/ReduceOnEdgesMethodsITCase.scala | 168 --
.../operations/ReduceOnNeighborMethodsITCase.scala | 143 --
flink-libraries/flink-gelly/pom.xml | 86 -
.../org/apache/flink/graph/AnalyticHelper.java | 84 -
.../src/main/java/org/apache/flink/graph/Edge.java | 76 -
.../java/org/apache/flink/graph/EdgeDirection.java | 34 -
.../org/apache/flink/graph/EdgeJoinFunction.java | 45 -
.../java/org/apache/flink/graph/EdgeOrder.java | 48 -
.../java/org/apache/flink/graph/EdgesFunction.java | 54 -
.../flink/graph/EdgesFunctionWithVertexValue.java | 55 -
.../main/java/org/apache/flink/graph/Graph.java | 2648 --------------------
.../org/apache/flink/graph/GraphAlgorithm.java | 30 -
.../java/org/apache/flink/graph/GraphAnalytic.java | 71 -
.../org/apache/flink/graph/GraphAnalyticBase.java | 80 -
.../org/apache/flink/graph/GraphCsvReader.java | 501 ----
.../apache/flink/graph/IterationConfiguration.java | 159 --
.../org/apache/flink/graph/NeighborsFunction.java | 59 -
.../graph/NeighborsFunctionWithVertexValue.java | 62 -
.../apache/flink/graph/ReduceEdgesFunction.java | 42 -
.../flink/graph/ReduceNeighborsFunction.java | 43 -
.../main/java/org/apache/flink/graph/Triplet.java | 78 -
.../main/java/org/apache/flink/graph/Vertex.java | 56 -
.../org/apache/flink/graph/VertexJoinFunction.java | 44 -
.../flink/graph/asm/dataset/ChecksumHashCode.java | 178 --
.../apache/flink/graph/asm/dataset/Collect.java | 102 -
.../org/apache/flink/graph/asm/dataset/Count.java | 72 -
.../flink/graph/asm/dataset/DataSetAnalytic.java | 70 -
.../graph/asm/dataset/DataSetAnalyticBase.java | 54 -
.../degree/annotate/DegreeAnnotationFunctions.java | 178 --
.../degree/annotate/directed/EdgeDegreesPair.java | 63 -
.../annotate/directed/EdgeSourceDegrees.java | 58 -
.../annotate/directed/EdgeTargetDegrees.java | 58 -
.../degree/annotate/directed/VertexDegrees.java | 281 ---
.../degree/annotate/directed/VertexInDegree.java | 112 -
.../degree/annotate/directed/VertexOutDegree.java | 112 -
.../graph/asm/degree/annotate/package-info.java | 44 -
.../degree/annotate/undirected/EdgeDegreePair.java | 98 -
.../annotate/undirected/EdgeSourceDegree.java | 88 -
.../annotate/undirected/EdgeTargetDegree.java | 88 -
.../degree/annotate/undirected/VertexDegree.java | 134 -
.../degree/filter/undirected/MaximumDegree.java | 242 --
.../flink/graph/asm/result/BinaryResult.java | 80 -
.../flink/graph/asm/result/BinaryResultBase.java | 97 -
.../flink/graph/asm/result/PrintableResult.java | 32 -
.../apache/flink/graph/asm/result/ResultBase.java | 34 -
.../flink/graph/asm/result/TertiaryResult.java | 73 -
.../flink/graph/asm/result/TertiaryResultBase.java | 114 -
.../flink/graph/asm/result/TranslatableResult.java | 46 -
.../apache/flink/graph/asm/result/UnaryResult.java | 45 -
.../flink/graph/asm/result/UnaryResultBase.java | 82 -
.../flink/graph/asm/simple/directed/Simplify.java | 68 -
.../graph/asm/simple/undirected/Simplify.java | 114 -
.../graph/asm/translate/RichTranslateFunction.java | 40 -
.../flink/graph/asm/translate/Translate.java | 393 ---
.../graph/asm/translate/TranslateEdgeValues.java | 73 -
.../graph/asm/translate/TranslateFunction.java | 49 -
.../graph/asm/translate/TranslateGraphIds.java | 83 -
.../graph/asm/translate/TranslateVertexValues.java | 73 -
.../asm/translate/translators/LongToLongValue.java | 36 -
.../translate/translators/LongValueAddOffset.java | 49 -
.../translators/LongValueToSignedIntValue.java | 45 -
.../translators/LongValueToStringValue.java | 37 -
.../translators/LongValueToUnsignedIntValue.java | 49 -
.../asm/translate/translators/ToNullValue.java | 35 -
.../flink/graph/bipartite/BipartiteEdge.java | 68 -
.../flink/graph/bipartite/BipartiteGraph.java | 354 ---
.../apache/flink/graph/bipartite/Projection.java | 79 -
.../flink/graph/generator/CirculantGraph.java | 246 --
.../flink/graph/generator/CompleteGraph.java | 63 -
.../apache/flink/graph/generator/CycleGraph.java | 63 -
.../apache/flink/graph/generator/EchoGraph.java | 82 -
.../apache/flink/graph/generator/EmptyGraph.java | 82 -
.../flink/graph/generator/GraphGenerator.java | 49 -
.../flink/graph/generator/GraphGeneratorBase.java | 47 -
.../flink/graph/generator/GraphGeneratorUtils.java | 132 -
.../apache/flink/graph/generator/GridGraph.java | 163 --
.../flink/graph/generator/HypercubeGraph.java | 69 -
.../apache/flink/graph/generator/PathGraph.java | 67 -
.../apache/flink/graph/generator/RMatGraph.java | 294 ---
.../flink/graph/generator/SingletonEdgeGraph.java | 111 -
.../apache/flink/graph/generator/StarGraph.java | 108 -
.../flink/graph/generator/random/BlockInfo.java | 77 -
.../generator/random/GeneratorFactoryBase.java | 77 -
.../random/JDKRandomGeneratorFactory.java | 70 -
.../generator/random/MersenneTwisterFactory.java | 70 -
.../graph/generator/random/RandomGenerable.java | 40 -
.../generator/random/RandomGenerableFactory.java | 54 -
.../org/apache/flink/graph/gsa/ApplyFunction.java | 156 --
.../apache/flink/graph/gsa/GSAConfiguration.java | 133 -
.../org/apache/flink/graph/gsa/GatherFunction.java | 136 -
.../flink/graph/gsa/GatherSumApplyIteration.java | 507 ----
.../java/org/apache/flink/graph/gsa/Neighbor.java | 46 -
.../org/apache/flink/graph/gsa/SumFunction.java | 134 -
.../flink/graph/library/CommunityDetection.java | 195 --
.../flink/graph/library/ConnectedComponents.java | 129 -
.../graph/library/GSAConnectedComponents.java | 148 --
.../library/GSASingleSourceShortestPaths.java | 112 -
.../flink/graph/library/LabelPropagation.java | 143 --
.../graph/library/SingleSourceShortestPaths.java | 123 -
.../apache/flink/graph/library/Summarization.java | 551 ----
.../flink/graph/library/TriangleEnumerator.java | 379 ---
.../library/clustering/TriangleListingBase.java | 88 -
.../directed/AverageClusteringCoefficient.java | 197 --
.../directed/GlobalClusteringCoefficient.java | 176 --
.../directed/LocalClusteringCoefficient.java | 326 ---
.../library/clustering/directed/TriadicCensus.java | 599 -----
.../clustering/directed/TriangleListing.java | 546 ----
.../undirected/AverageClusteringCoefficient.java | 197 --
.../undirected/GlobalClusteringCoefficient.java | 175 --
.../undirected/LocalClusteringCoefficient.java | 317 ---
.../clustering/undirected/TriadicCensus.java | 241 --
.../clustering/undirected/TriangleListing.java | 367 ---
.../graph/library/linkanalysis/Functions.java | 44 -
.../flink/graph/library/linkanalysis/HITS.java | 602 -----
.../flink/graph/library/linkanalysis/PageRank.java | 580 -----
.../graph/library/metric/ChecksumHashCode.java | 61 -
.../graph/library/metric/directed/EdgeMetrics.java | 369 ---
.../library/metric/directed/VertexMetrics.java | 392 ---
.../library/metric/undirected/EdgeMetrics.java | 339 ---
.../library/metric/undirected/VertexMetrics.java | 319 ---
.../flink/graph/library/similarity/AdamicAdar.java | 512 ----
.../graph/library/similarity/JaccardIndex.java | 592 -----
.../apache/flink/graph/pregel/ComputeFunction.java | 275 --
.../apache/flink/graph/pregel/MessageCombiner.java | 67 -
.../apache/flink/graph/pregel/MessageIterator.java | 74 -
.../graph/pregel/VertexCentricConfiguration.java | 63 -
.../flink/graph/pregel/VertexCentricIteration.java | 530 ----
.../apache/flink/graph/spargel/GatherFunction.java | 263 --
.../flink/graph/spargel/MessageIterator.java | 58 -
.../flink/graph/spargel/ScatterFunction.java | 355 ---
.../graph/spargel/ScatterGatherConfiguration.java | 132 -
.../graph/spargel/ScatterGatherIteration.java | 821 ------
.../graph/types/valuearray/ByteValueArray.java | 398 ---
.../types/valuearray/ByteValueArrayComparator.java | 161 --
.../types/valuearray/ByteValueArraySerializer.java | 98 -
.../graph/types/valuearray/CharValueArray.java | 398 ---
.../types/valuearray/CharValueArrayComparator.java | 161 --
.../types/valuearray/CharValueArraySerializer.java | 99 -
.../graph/types/valuearray/DoubleValueArray.java | 399 ---
.../valuearray/DoubleValueArrayComparator.java | 162 --
.../valuearray/DoubleValueArraySerializer.java | 99 -
.../graph/types/valuearray/FloatValueArray.java | 398 ---
.../valuearray/FloatValueArrayComparator.java | 162 --
.../valuearray/FloatValueArraySerializer.java | 99 -
.../graph/types/valuearray/IntValueArray.java | 396 ---
.../types/valuearray/IntValueArrayComparator.java | 160 --
.../types/valuearray/IntValueArraySerializer.java | 97 -
.../graph/types/valuearray/LongValueArray.java | 397 ---
.../types/valuearray/LongValueArrayComparator.java | 160 --
.../types/valuearray/LongValueArraySerializer.java | 98 -
.../graph/types/valuearray/NullValueArray.java | 260 --
.../types/valuearray/NullValueArrayComparator.java | 151 --
.../types/valuearray/NullValueArraySerializer.java | 98 -
.../graph/types/valuearray/ShortValueArray.java | 398 ---
.../valuearray/ShortValueArrayComparator.java | 162 --
.../valuearray/ShortValueArraySerializer.java | 99 -
.../graph/types/valuearray/StringValueArray.java | 515 ----
.../valuearray/StringValueArrayComparator.java | 222 --
.../valuearray/StringValueArraySerializer.java | 98 -
.../flink/graph/types/valuearray/ValueArray.java | 97 -
.../graph/types/valuearray/ValueArrayFactory.java | 106 -
.../graph/types/valuearray/ValueArrayTypeInfo.java | 220 --
.../valuearray/ValueArrayTypeInfoFactory.java | 46 -
.../apache/flink/graph/utils/EdgeToTuple2Map.java | 45 -
.../apache/flink/graph/utils/EdgeToTuple3Map.java | 41 -
.../org/apache/flink/graph/utils/GraphUtils.java | 121 -
.../org/apache/flink/graph/utils/MurmurHash.java | 127 -
.../apache/flink/graph/utils/Tuple2ToEdgeMap.java | 47 -
.../flink/graph/utils/Tuple2ToVertexMap.java | 45 -
.../apache/flink/graph/utils/Tuple3ToEdgeMap.java | 46 -
.../flink/graph/utils/VertexToTuple2Map.java | 41 -
.../utils/proxy/GraphAlgorithmWrappingBase.java | 109 -
.../utils/proxy/GraphAlgorithmWrappingDataSet.java | 130 -
.../utils/proxy/GraphAlgorithmWrappingGraph.java | 143 --
.../flink/graph/utils/proxy/OptionalBoolean.java | 133 -
.../flink/graph/validation/GraphValidator.java | 36 -
.../validation/InvalidVertexIdsValidator.java | 85 -
.../org/apache/flink/graph/asm/AsmTestBase.java | 165 --
.../graph/asm/dataset/ChecksumHashCodeTest.java | 69 -
.../flink/graph/asm/dataset/CollectTest.java | 67 -
.../apache/flink/graph/asm/dataset/CountTest.java | 66 -
.../annotate/directed/EdgeDegreesPairTest.java | 86 -
.../annotate/directed/EdgeSourceDegreesTest.java | 86 -
.../annotate/directed/EdgeTargetDegreesTest.java | 86 -
.../annotate/directed/VertexDegreesTest.java | 117 -
.../annotate/directed/VertexInDegreeTest.java | 112 -
.../annotate/directed/VertexOutDegreeTest.java | 113 -
.../annotate/undirected/EdgeDegreePairTest.java | 135 -
.../annotate/undirected/EdgeSourceDegreeTest.java | 135 -
.../annotate/undirected/EdgeTargetDegreeTest.java | 135 -
.../annotate/undirected/VertexDegreeTest.java | 149 --
.../filter/undirected/MaximumDegreeTest.java | 87 -
.../graph/asm/simple/directed/SimplifyTest.java | 90 -
.../graph/asm/simple/undirected/SimplifyTest.java | 100 -
.../flink/graph/asm/translate/TranslateTest.java | 127 -
.../translators/LongValueAddOffsetTest.java | 68 -
.../translators/LongValueToSignedIntValueTest.java | 56 -
.../translators/LongValueToStringValueTest.java | 46 -
.../LongValueToUnsignedIntValueTest.java | 54 -
.../asm/translate/translators/ToNullValueTest.java | 49 -
.../flink/graph/bipartite/BipartiteEdgeTest.java | 70 -
.../flink/graph/bipartite/BipartiteGraphTest.java | 153 --
.../flink/graph/bipartite/ProjectionTest.java | 78 -
.../flink/graph/generator/CirculantGraphTest.java | 79 -
.../flink/graph/generator/CompleteGraphTest.java | 79 -
.../flink/graph/generator/CycleGraphTest.java | 77 -
.../flink/graph/generator/EchoGraphTest.java | 118 -
.../flink/graph/generator/EmptyGraphTest.java | 71 -
.../graph/generator/GraphGeneratorTestBase.java | 34 -
.../flink/graph/generator/GridGraphTest.java | 88 -
.../flink/graph/generator/HypercubeGraphTest.java | 81 -
.../flink/graph/generator/PathGraphTest.java | 77 -
.../flink/graph/generator/RMatGraphTest.java | 66 -
.../graph/generator/SingletonEdgeGraphTest.java | 79 -
.../flink/graph/generator/StarGraphTest.java | 79 -
.../apache/flink/graph/generator/TestUtils.java | 121 -
.../apache/flink/graph/gsa/GSACompilerTest.java | 151 --
.../apache/flink/graph/gsa/GSATranslationTest.java | 178 --
.../graph/library/CommunityDetectionTest.java | 110 -
...nnectedComponentsWithRandomisedEdgesITCase.java | 99 -
.../directed/AverageClusteringCoefficientTest.java | 81 -
.../directed/GlobalClusteringCoefficientTest.java | 83 -
.../directed/LocalClusteringCoefficientTest.java | 108 -
.../clustering/directed/TriadicCensusTest.java | 168 --
.../clustering/directed/TriangleListingTest.java | 133 -
.../AverageClusteringCoefficientTest.java | 81 -
.../GlobalClusteringCoefficientTest.java | 83 -
.../undirected/LocalClusteringCoefficientTest.java | 107 -
.../clustering/undirected/TriadicCensusTest.java | 108 -
.../clustering/undirected/TriangleListingTest.java | 129 -
.../flink/graph/library/linkanalysis/HITSTest.java | 168 --
.../graph/library/linkanalysis/PageRankTest.java | 158 --
.../graph/library/metric/ChecksumHashCodeTest.java | 62 -
.../library/metric/directed/EdgeMetricsTest.java | 85 -
.../library/metric/directed/VertexMetricsTest.java | 113 -
.../library/metric/undirected/EdgeMetricsTest.java | 85 -
.../metric/undirected/VertexMetricsTest.java | 105 -
.../graph/library/similarity/AdamicAdarTest.java | 196 --
.../graph/library/similarity/JaccardIndexTest.java | 184 --
.../flink/graph/pregel/PregelCompilerTest.java | 299 ---
.../flink/graph/pregel/PregelTranslationTest.java | 139 -
.../flink/graph/spargel/SpargelCompilerTest.java | 214 --
.../graph/spargel/SpargelTranslationTest.java | 258 --
.../graph/test/CollectionModeSuperstepITCase.java | 86 -
.../test/GatherSumApplyConfigurationITCase.java | 429 ----
.../test/ScatterGatherConfigurationITCase.java | 813 ------
.../apache/flink/graph/test/TestGraphUtils.java | 389 ---
.../flink/graph/test/operations/DegreesITCase.java | 171 --
.../operations/DegreesWithExceptionITCase.java | 156 --
.../test/operations/FromCollectionITCase.java | 118 -
.../graph/test/operations/GraphCreationITCase.java | 233 --
.../operations/GraphCreationWithCsvITCase.java | 196 --
.../operations/GraphCreationWithMapperITCase.java | 159 --
.../test/operations/GraphMutationsITCase.java | 641 -----
.../test/operations/GraphOperationsITCase.java | 524 ----
.../graph/test/operations/JoinWithEdgesITCase.java | 631 -----
.../test/operations/JoinWithVerticesITCase.java | 226 --
.../graph/test/operations/MapEdgesITCase.java | 238 --
.../graph/test/operations/MapVerticesITCase.java | 221 --
.../operations/ReduceOnEdgesMethodsITCase.java | 633 -----
.../ReduceOnEdgesWithExceptionITCase.java | 124 -
.../operations/ReduceOnNeighborMethodsITCase.java | 680 -----
.../ReduceOnNeighborsWithExceptionITCase.java | 186 --
.../graph/test/operations/TypeExtractorTest.java | 149 --
.../valuearray/ByteValueArrayComparatorTest.java | 53 -
.../valuearray/ByteValueArraySerializerTest.java | 92 -
.../graph/types/valuearray/ByteValueArrayTest.java | 127 -
.../valuearray/CharValueArrayComparatorTest.java | 53 -
.../valuearray/CharValueArraySerializerTest.java | 92 -
.../graph/types/valuearray/CharValueArrayTest.java | 172 --
.../valuearray/DoubleValueArrayComparatorTest.java | 53 -
.../valuearray/DoubleValueArraySerializerTest.java | 93 -
.../types/valuearray/DoubleValueArrayTest.java | 129 -
.../valuearray/FloatValueArrayComparatorTest.java | 53 -
.../valuearray/FloatValueArraySerializerTest.java | 92 -
.../types/valuearray/FloatValueArrayTest.java | 127 -
.../valuearray/IntValueArrayComparatorTest.java | 52 -
.../valuearray/IntValueArraySerializerTest.java | 91 -
.../graph/types/valuearray/IntValueArrayTest.java | 125 -
.../valuearray/LongValueArrayComparatorTest.java | 52 -
.../valuearray/LongValueArraySerializerTest.java | 91 -
.../graph/types/valuearray/LongValueArrayTest.java | 126 -
.../valuearray/NullValueArrayComparatorTest.java | 52 -
.../valuearray/NullValueArraySerializerTest.java | 65 -
.../graph/types/valuearray/NullValueArrayTest.java | 82 -
.../valuearray/ShortValueArrayComparatorTest.java | 53 -
.../valuearray/ShortValueArraySerializerTest.java | 92 -
.../types/valuearray/ShortValueArrayTest.java | 127 -
.../valuearray/StringValueArrayComparatorTest.java | 52 -
.../valuearray/StringValueArraySerializerTest.java | 90 -
.../types/valuearray/StringValueArrayTest.java | 171 --
.../valuearray/ValueArraySerializerTestBase.java | 39 -
.../ValueArraySerializerUpgradeTest.java | 558 -----
.../types/valuearray/ValueArrayTypeInfoTest.java | 81 -
.../graph/utils/proxy/OptionalBooleanTest.java | 176 --
.../serializer-snapshot | Bin 107 -> 0 bytes
.../byte-value-array-serializer-1.11/test-data | Bin 6 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../byte-value-array-serializer-1.12/test-data | Bin 6 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../byte-value-array-serializer-1.13/test-data | Bin 6 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../byte-value-array-serializer-1.14/test-data | Bin 6 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../byte-value-array-serializer-1.15/test-data | Bin 6 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../char-value-array-serializer-1.11/test-data | Bin 10 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../char-value-array-serializer-1.12/test-data | Bin 10 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../char-value-array-serializer-1.13/test-data | Bin 10 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../char-value-array-serializer-1.14/test-data | Bin 10 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../char-value-array-serializer-1.15/test-data | Bin 10 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../double-value-array-serializer-1.11/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../double-value-array-serializer-1.12/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../double-value-array-serializer-1.13/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../double-value-array-serializer-1.14/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../double-value-array-serializer-1.15/test-data | Bin 20 -> 0 bytes
.../resources/flink-1.7-array-list-serializer-data | Bin 240 -> 0 bytes
.../flink-1.7-array-list-serializer-snapshot | Bin 231 -> 0 bytes
...k-1.7-avro-generic-type-serializer-address-data | Bin 240 -> 0 bytes
...7-avro-generic-type-serializer-address-snapshot | Bin 370 -> 0 bytes
.../flink-1.7-avro-type-serializer-address-data | Bin 240 -> 0 bytes
...flink-1.7-avro-type-serializer-address-snapshot | Bin 380 -> 0 bytes
.../resources/flink-1.7-either-serializer-data | 1 -
.../resources/flink-1.7-either-serializer-snapshot | Bin 383 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../float-value-array-serializer-1.11/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../float-value-array-serializer-1.12/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../float-value-array-serializer-1.13/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../float-value-array-serializer-1.14/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../float-value-array-serializer-1.15/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 105 -> 0 bytes
.../int-value-array-serializer-1.11/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 105 -> 0 bytes
.../int-value-array-serializer-1.12/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 105 -> 0 bytes
.../int-value-array-serializer-1.13/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 105 -> 0 bytes
.../int-value-array-serializer-1.14/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 105 -> 0 bytes
.../int-value-array-serializer-1.15/test-data | Bin 12 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../long-value-array-serializer-1.11/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../long-value-array-serializer-1.12/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../long-value-array-serializer-1.13/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../long-value-array-serializer-1.14/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../long-value-array-serializer-1.15/test-data | Bin 20 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../null-value-array-serializer-1.11/test-data | Bin 4 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../null-value-array-serializer-1.12/test-data | Bin 4 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../null-value-array-serializer-1.13/test-data | Bin 4 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../null-value-array-serializer-1.14/test-data | Bin 4 -> 0 bytes
.../serializer-snapshot | Bin 107 -> 0 bytes
.../null-value-array-serializer-1.15/test-data | Bin 4 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../short-value-array-serializer-1.11/test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../short-value-array-serializer-1.12/test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../short-value-array-serializer-1.13/test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../short-value-array-serializer-1.14/test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 109 -> 0 bytes
.../short-value-array-serializer-1.15/test-data | Bin 8 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../string-value-array-serializer-1.11/test-data | Bin 16 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../string-value-array-serializer-1.12/test-data | Bin 16 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../string-value-array-serializer-1.13/test-data | Bin 16 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../string-value-array-serializer-1.14/test-data | Bin 16 -> 0 bytes
.../serializer-snapshot | Bin 111 -> 0 bytes
.../string-value-array-serializer-1.15/test-data | Bin 16 -> 0 bytes
flink-libraries/pom.xml | 3 -
tools/ci/stage.sh | 3 -
575 files changed, 212 insertions(+), 71766 deletions(-)
delete mode 100644 docs/content.zh/docs/libs/gelly/_index.md
delete mode 100644 docs/content.zh/docs/libs/gelly/bipartite_graph.md
delete mode 100644 docs/content.zh/docs/libs/gelly/graph_algorithms.md
delete mode 100644 docs/content.zh/docs/libs/gelly/graph_api.md
delete mode 100644 docs/content.zh/docs/libs/gelly/graph_generators.md
delete mode 100644
docs/content.zh/docs/libs/gelly/iterative_graph_processing.md
delete mode 100644 docs/content.zh/docs/libs/gelly/library_methods.md
delete mode 100644 docs/content.zh/docs/libs/gelly/overview.md
delete mode 100644 docs/content/docs/libs/gelly/_index.md
delete mode 100644 docs/content/docs/libs/gelly/bipartite_graph.md
delete mode 100644 docs/content/docs/libs/gelly/graph_algorithms.md
delete mode 100644 docs/content/docs/libs/gelly/graph_api.md
delete mode 100644 docs/content/docs/libs/gelly/graph_generators.md
delete mode 100644 docs/content/docs/libs/gelly/iterative_graph_processing.md
delete mode 100644 docs/content/docs/libs/gelly/library_methods.md
delete mode 100644 docs/content/docs/libs/gelly/overview.md
delete mode 100644 docs/static/fig/gelly-example-graph.png
delete mode 100644 docs/static/fig/gelly-filter.png
delete mode 100644 docs/static/fig/gelly-gsa-sssp1.png
delete mode 100644 docs/static/fig/gelly-reduceOnEdges.png
delete mode 100644 docs/static/fig/gelly-reduceOnNeighbors.png
delete mode 100644 docs/static/fig/gelly-union.png
delete mode 100644 docs/static/fig/gelly-vc-sssp1.png
delete mode 100644 flink-libraries/flink-gelly-examples/pom.xml
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/Runner.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/AdamicAdar.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/ClusteringCoefficient.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/ConnectedComponents.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/Driver.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/DriverBase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/EdgeList.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/GraphMetrics.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/HITS.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/JaccardIndex.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/PageRank.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/TriangleListing.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/CSV.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/CirculantGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/CompleteGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/CycleGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/EchoGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/EmptyGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/GeneratedGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/GeneratedMultiGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/GridGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/HypercubeGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/Input.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/InputBase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/PathGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/RMatGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/SingletonEdgeGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/StarGraph.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/output/CSV.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/output/Hash.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/output/Output.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/output/OutputBase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/output/Print.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/BooleanParameter.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/ChoiceParameter.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/DoubleParameter.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/IterationConvergence.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/LongParameter.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Parameter.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Parameterized.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/ParameterizedBase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/SimpleParameter.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Simplify.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/StringParameter.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Util.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/GraphKeyTypeTransform.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/LongValueWithProperHashCode.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/Transform.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/Transformable.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/EuclideanGraphWeighing.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/GSAPageRank.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/GSASingleSourceShortestPaths.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/IncrementalSSSP.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/MusicProfiles.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/PageRank.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/PregelSSSP.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/SingleSourceShortestPaths.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/CommunityDetectionData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/ConnectedComponentsDefaultData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/EuclideanGraphData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/IncrementalSSSPData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/LabelPropagationData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/MusicProfilesData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/PageRankData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/SingleSourceShortestPathsData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/SummarizationData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/TriangleCountData.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/resources/log4j2.properties
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/resources/logback.xml
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/scala/org/apache/flink/graph/scala/examples/ConnectedComponents.scala
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/scala/org/apache/flink/graph/scala/examples/GSASingleSourceShortestPaths.scala
delete mode 100644
flink-libraries/flink-gelly-examples/src/main/scala/org/apache/flink/graph/scala/examples/SingleSourceShortestPaths.scala
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/RunnerITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/AdamicAdarITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/ClusteringCoefficientITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/ConnectedComponentsITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/CopyableValueDriverBaseITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/DriverBaseITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/EdgeListITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/GraphMetricsITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/HITSITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/JaccardIndexITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/NonTransformableDriverBaseITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/PageRankITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/TestUtils.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/TriangleListingITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/BooleanParameterTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/ChoiceParameterTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/DoubleParameterTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/IterationConvergenceTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/LongParameterTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/ParameterTestBase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/SimplifyTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/parameter/StringParameterTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/transform/GraphKeyTypeTransformTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/transform/LongValueWithProperHashCodeSerializerUpgradeTest.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/library/CommunityDetectionITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/library/LabelPropagationITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/library/SummarizationITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/library/TriangleEnumeratorITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/examples/EuclideanGraphWeighingITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/examples/IncrementalSSSPITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/examples/MusicProfilesITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/examples/PageRankITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/examples/SingleSourceShortestPathsITCase.java
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.15/test-data
delete mode 100644 flink-libraries/flink-gelly-scala/pom.xml
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunction.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunctionWithVertexValue.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunction.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunctionWithVertexValue.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/package.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/EdgeToTuple3Map.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple3ToEdgeMap.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/VertexToTuple2Map.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/GellyScalaAPICompletenessTest.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/TestGraphUtils.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/DegreesITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphCreationWithCsvITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphMutationsITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphOperationsITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithEdgesITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithVerticesITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapEdgesITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapVerticesITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnEdgesMethodsITCase.scala
delete mode 100644
flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnNeighborMethodsITCase.scala
delete mode 100644 flink-libraries/flink-gelly/pom.xml
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/AnalyticHelper.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgeDirection.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgeJoinFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgeOrder.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunctionWithVertexValue.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphAlgorithm.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphAnalytic.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphAnalyticBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/IterationConfiguration.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunctionWithVertexValue.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/ReduceEdgesFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/ReduceNeighborsFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Triplet.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Vertex.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/VertexJoinFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/dataset/ChecksumHashCode.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/dataset/Collect.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/dataset/Count.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/dataset/DataSetAnalytic.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/dataset/DataSetAnalyticBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/DegreeAnnotationFunctions.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeDegreesPair.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeSourceDegrees.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeTargetDegrees.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/VertexDegrees.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/VertexInDegree.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/VertexOutDegree.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/package-info.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/undirected/EdgeDegreePair.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/undirected/EdgeSourceDegree.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/undirected/EdgeTargetDegree.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/undirected/VertexDegree.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/filter/undirected/MaximumDegree.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/BinaryResult.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/BinaryResultBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/PrintableResult.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/ResultBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/TertiaryResult.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/TertiaryResultBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/TranslatableResult.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/UnaryResult.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/result/UnaryResultBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/simple/directed/Simplify.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/simple/undirected/Simplify.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/RichTranslateFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/TranslateEdgeValues.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/TranslateFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/TranslateGraphIds.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/TranslateVertexValues.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/translators/LongToLongValue.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/translators/LongValueAddOffset.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/translators/LongValueToSignedIntValue.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/translators/LongValueToStringValue.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/translators/LongValueToUnsignedIntValue.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/translators/ToNullValue.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/bipartite/BipartiteEdge.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/bipartite/BipartiteGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/bipartite/Projection.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/CirculantGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/CompleteGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/CycleGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/EchoGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/EmptyGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/GraphGenerator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/GraphGeneratorBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/GraphGeneratorUtils.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/GridGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/HypercubeGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/PathGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/RMatGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/SingletonEdgeGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/StarGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/random/BlockInfo.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/random/GeneratorFactoryBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/random/JDKRandomGeneratorFactory.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/random/MersenneTwisterFactory.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/random/RandomGenerable.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/random/RandomGenerableFactory.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GSAConfiguration.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/CommunityDetection.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/ConnectedComponents.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/Summarization.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/TriangleListingBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/AverageClusteringCoefficient.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/GlobalClusteringCoefficient.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/LocalClusteringCoefficient.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/TriadicCensus.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/directed/TriangleListing.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/AverageClusteringCoefficient.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/GlobalClusteringCoefficient.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/LocalClusteringCoefficient.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/TriadicCensus.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/TriangleListing.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/linkanalysis/Functions.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/linkanalysis/HITS.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/linkanalysis/PageRank.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/ChecksumHashCode.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed/EdgeMetrics.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed/VertexMetrics.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/undirected/EdgeMetrics.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/undirected/VertexMetrics.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/AdamicAdar.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/pregel/ComputeFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/pregel/MessageCombiner.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/pregel/MessageIterator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/pregel/VertexCentricConfiguration.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/pregel/VertexCentricIteration.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/GatherFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessageIterator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/ScatterFunction.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/ScatterGatherConfiguration.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/ScatterGatherIteration.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ByteValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ByteValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ByteValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/CharValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/CharValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/CharValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/DoubleValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/DoubleValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/DoubleValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/FloatValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/FloatValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/FloatValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/IntValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/IntValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/IntValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/LongValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/LongValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/LongValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/NullValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/NullValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/NullValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/StringValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/StringValueArrayComparator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/StringValueArraySerializer.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ValueArray.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ValueArrayFactory.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ValueArrayTypeInfo.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ValueArrayTypeInfoFactory.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/EdgeToTuple2Map.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/EdgeToTuple3Map.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/GraphUtils.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/MurmurHash.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple2ToEdgeMap.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple2ToVertexMap.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple3ToEdgeMap.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/VertexToTuple2Map.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/proxy/GraphAlgorithmWrappingBase.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/proxy/GraphAlgorithmWrappingDataSet.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/proxy/GraphAlgorithmWrappingGraph.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/proxy/OptionalBoolean.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/GraphValidator.java
delete mode 100644
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidVertexIdsValidator.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/AsmTestBase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/dataset/ChecksumHashCodeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/dataset/CollectTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/dataset/CountTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeDegreesPairTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeSourceDegreesTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeTargetDegreesTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/directed/VertexDegreesTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/directed/VertexInDegreeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/directed/VertexOutDegreeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/undirected/EdgeDegreePairTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/undirected/EdgeSourceDegreeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/undirected/EdgeTargetDegreeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/annotate/undirected/VertexDegreeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/degree/filter/undirected/MaximumDegreeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/simple/directed/SimplifyTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/simple/undirected/SimplifyTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/translate/TranslateTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/translate/translators/LongValueAddOffsetTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/translate/translators/LongValueToSignedIntValueTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/translate/translators/LongValueToStringValueTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/translate/translators/LongValueToUnsignedIntValueTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/asm/translate/translators/ToNullValueTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/bipartite/BipartiteEdgeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/bipartite/BipartiteGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/bipartite/ProjectionTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/CirculantGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/CompleteGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/CycleGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/EchoGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/EmptyGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/GraphGeneratorTestBase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/GridGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/HypercubeGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/PathGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/RMatGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/SingletonEdgeGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/StarGraphTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/TestUtils.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSACompilerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSATranslationTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/CommunityDetectionTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/ConnectedComponentsWithRandomisedEdgesITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/directed/AverageClusteringCoefficientTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/directed/GlobalClusteringCoefficientTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/directed/LocalClusteringCoefficientTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/directed/TriadicCensusTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/directed/TriangleListingTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/undirected/AverageClusteringCoefficientTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/undirected/GlobalClusteringCoefficientTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/undirected/LocalClusteringCoefficientTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/undirected/TriadicCensusTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/clustering/undirected/TriangleListingTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/linkanalysis/HITSTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/linkanalysis/PageRankTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/metric/ChecksumHashCodeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/metric/directed/EdgeMetricsTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/metric/directed/VertexMetricsTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/metric/undirected/EdgeMetricsTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/metric/undirected/VertexMetricsTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/AdamicAdarTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/JaccardIndexTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/pregel/PregelCompilerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/pregel/PregelTranslationTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelCompilerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelTranslationTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/CollectionModeSuperstepITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyConfigurationITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/ScatterGatherConfigurationITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/TestGraphUtils.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesWithExceptionITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/FromCollectionITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithCsvITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphMutationsITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithEdgesITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithVerticesITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapEdgesITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapVerticesITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesMethodsITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesWithExceptionITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborMethodsITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborsWithExceptionITCase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ByteValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ByteValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ByteValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/CharValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/CharValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/CharValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/DoubleValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/DoubleValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/DoubleValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/FloatValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/FloatValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/FloatValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/IntValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/IntValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/IntValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/LongValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/LongValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/LongValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/NullValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/NullValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/NullValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ShortValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ShortValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ShortValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/StringValueArrayComparatorTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/StringValueArraySerializerTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/StringValueArrayTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ValueArraySerializerTestBase.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ValueArraySerializerUpgradeTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/types/valuearray/ValueArrayTypeInfoTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/utils/proxy/OptionalBooleanTest.java
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-array-list-serializer-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-array-list-serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-avro-generic-type-serializer-address-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-avro-generic-type-serializer-address-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-avro-type-serializer-address-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-avro-type-serializer-address-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-either-serializer-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/flink-1.7-either-serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.15/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.11/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.11/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.12/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.12/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.14/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.14/test-data
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.15/serializer-snapshot
delete mode 100644
flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.15/test-data
