From aa64b948149bc17eab05f8d9300288a40b12a5e2 Mon Sep 17 00:00:00 2001 From: vasia Date: Thu, 8 Oct 2015 11:48:06 +0200 Subject: [PATCH] [FLINK-2833] [gelly] create a flink-libraries module and move gelly there --- docs/libs/gelly_guide.md | 6 +-- .../flink-gelly-scala/pom.xml | 2 +- .../flink/graph/scala/EdgesFunction.scala | 0 .../scala/EdgesFunctionWithVertexValue.scala | 0 .../org/apache/flink/graph/scala/Graph.scala | 0 .../flink/graph/scala/NeighborsFunction.scala | 0 .../NeighborsFunctionWithVertexValue.scala | 0 .../scala/example/ConnectedComponents.scala | 0 .../GSASingleSourceShortestPaths.scala | 0 .../graph/scala/example/GraphMetrics.scala | 0 .../example/SingleSourceShortestPaths.scala | 0 .../apache/flink/graph/scala/package.scala | 0 .../graph/scala/utils/EdgeToTuple3Map.scala | 0 .../graph/scala/utils/Tuple2ToVertexMap.scala | 0 .../graph/scala/utils/Tuple3ToEdgeMap.scala | 0 .../graph/scala/utils/VertexToTuple2Map.scala | 0 .../test/GellyScalaAPICompletenessTest.scala | 0 .../graph/scala/test/TestGraphUtils.scala | 0 .../scala/test/operations/DegreesITCase.scala | 0 .../GraphCreationWithCsvITCase.scala | 0 .../operations/GraphMutationsITCase.scala | 0 .../operations/GraphOperationsITCase.scala | 0 .../test/operations/JoinWithEdgesITCase.scala | 0 .../operations/JoinWithVerticesITCase.scala | 0 .../test/operations/MapEdgesITCase.scala | 0 .../test/operations/MapVerticesITCase.scala | 0 .../ReduceOnEdgesMethodsITCase.scala | 0 .../ReduceOnNeighborMethodsITCase.scala | 0 .../flink-gelly/pom.xml | 2 +- .../java/org/apache/flink/graph/Edge.java | 0 .../org/apache/flink/graph/EdgeDirection.java | 0 .../org/apache/flink/graph/EdgesFunction.java | 0 .../graph/EdgesFunctionWithVertexValue.java | 0 .../java/org/apache/flink/graph/Graph.java | 0 .../apache/flink/graph/GraphAlgorithm.java | 0 .../apache/flink/graph/GraphCsvReader.java | 0 .../flink/graph/IterationConfiguration.java | 0 .../apache/flink/graph/NeighborsFunction.java | 0 .../NeighborsFunctionWithVertexValue.java | 0 .../flink/graph/ReduceEdgesFunction.java | 0 .../flink/graph/ReduceNeighborsFunction.java | 0 .../java/org/apache/flink/graph/Triplet.java | 0 .../java/org/apache/flink/graph/Vertex.java | 0 .../graph/example/ConnectedComponents.java | 0 .../graph/example/EuclideanGraphWeighing.java | 0 .../example/GSASingleSourceShortestPaths.java | 0 .../flink/graph/example/GraphMetrics.java | 0 .../flink/graph/example/IncrementalSSSP.java | 0 .../example/JaccardSimilarityMeasure.java | 0 .../flink/graph/example/MusicProfiles.java | 0 .../example/SingleSourceShortestPaths.java | 0 .../example/utils/CommunityDetectionData.java | 0 .../utils/ConnectedComponentsDefaultData.java | 0 .../example/utils/EuclideanGraphData.java | 0 .../graph/example/utils/ExampleUtils.java | 0 .../example/utils/IncrementalSSSPData.java | 0 .../utils/JaccardSimilarityMeasureData.java | 0 .../example/utils/LabelPropagationData.java | 0 .../example/utils/MusicProfilesData.java | 0 .../graph/example/utils/PageRankData.java | 0 .../utils/SingleSourceShortestPathsData.java | 0 .../example/utils/TriangleCountData.java | 0 .../apache/flink/graph/gsa/ApplyFunction.java | 0 .../flink/graph/gsa/GSAConfiguration.java | 0 .../flink/graph/gsa/GatherFunction.java | 0 .../graph/gsa/GatherSumApplyIteration.java | 0 .../org/apache/flink/graph/gsa/Neighbor.java | 0 .../apache/flink/graph/gsa/SumFunction.java | 0 .../graph/library/CommunityDetection.java | 0 .../graph/library/ConnectedComponents.java | 0 .../graph/library/GSAConnectedComponents.java | 0 .../flink/graph/library/GSAPageRank.java | 0 .../library/GSASingleSourceShortestPaths.java | 0 .../flink/graph/library/GSATriangleCount.java | 0 .../flink/graph/library/LabelPropagation.java | 0 .../apache/flink/graph/library/PageRank.java | 0 .../library/SingleSourceShortestPaths.java | 0 .../flink/graph/spargel/MessageIterator.java | 0 .../graph/spargel/MessagingFunction.java | 0 .../spargel/VertexCentricConfiguration.java | 0 .../graph/spargel/VertexCentricIteration.java | 0 .../graph/spargel/VertexUpdateFunction.java | 0 .../flink/graph/utils/EdgeToTuple3Map.java | 0 .../graph/utils/NullValueEdgeMapper.java | 0 .../flink/graph/utils/Tuple2ToVertexMap.java | 0 .../flink/graph/utils/Tuple3ToEdgeMap.java | 0 .../flink/graph/utils/VertexToTuple2Map.java | 0 .../graph/validation/GraphValidator.java | 0 .../validation/InvalidVertexIdsValidator.java | 0 .../flink/graph/gsa/GSACompilerTest.java | 0 .../flink/graph/gsa/GSATranslationTest.java | 0 .../graph/spargel/SpargelCompilerTest.java | 0 .../graph/spargel/SpargelTranslationTest.java | 0 .../test/CollectionModeSuperstepITCase.java | 0 .../GatherSumApplyConfigurationITCase.java | 0 .../graph/test/GatherSumApplyITCase.java | 0 .../flink/graph/test/TestGraphUtils.java | 0 .../VertexCentricConfigurationITCase.java | 0 .../example/ConnectedComponentsITCase.java | 0 .../example/EuclideanGraphWeighingITCase.java | 0 .../test/example/IncrementalSSSPITCase.java | 0 .../JaccardSimilarityMeasureITCase.java | 0 .../test/example/MusicProfilesITCase.java | 0 .../SingleSourceShortestPathsITCase.java | 0 .../library/CommunityDetectionITCase.java | 0 ...edComponentsWithRandomisedEdgesITCase.java | 0 .../test/library/LabelPropagationITCase.java | 0 .../graph/test/library/PageRankITCase.java | 0 .../test/library/TriangleCountITCase.java | 0 .../graph/test/operations/DegreesITCase.java | 0 .../DegreesWithExceptionITCase.java | 0 .../test/operations/FromCollectionITCase.java | 0 .../test/operations/GraphCreationITCase.java | 0 .../GraphCreationWithCsvITCase.java | 0 .../GraphCreationWithMapperITCase.java | 0 .../test/operations/GraphMutationsITCase.java | 0 .../operations/GraphOperationsITCase.java | 0 .../test/operations/JoinWithEdgesITCase.java | 0 .../operations/JoinWithVerticesITCase.java | 0 .../graph/test/operations/MapEdgesITCase.java | 0 .../test/operations/MapVerticesITCase.java | 0 .../ReduceOnEdgesMethodsITCase.java | 0 .../ReduceOnEdgesWithExceptionITCase.java | 0 .../ReduceOnNeighborMethodsITCase.java | 0 .../ReduceOnNeighborsWithExceptionITCase.java | 0 flink-libraries/pom.xml | 40 +++++++++++++++++++ flink-staging/pom.xml | 2 - pom.xml | 1 + 128 files changed, 46 insertions(+), 7 deletions(-) rename {flink-staging => flink-libraries}/flink-gelly-scala/pom.xml (99%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunction.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunctionWithVertexValue.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunction.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunctionWithVertexValue.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/ConnectedComponents.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GSASingleSourceShortestPaths.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GraphMetrics.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/SingleSourceShortestPaths.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/package.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/EdgeToTuple3Map.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple3ToEdgeMap.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/VertexToTuple2Map.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/GellyScalaAPICompletenessTest.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/TestGraphUtils.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/DegreesITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphCreationWithCsvITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphMutationsITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphOperationsITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithEdgesITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithVerticesITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapEdgesITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapVerticesITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnEdgesMethodsITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnNeighborMethodsITCase.scala (100%) rename {flink-staging => flink-libraries}/flink-gelly/pom.xml (98%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/EdgeDirection.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunctionWithVertexValue.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/GraphAlgorithm.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/IterationConfiguration.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunctionWithVertexValue.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/ReduceEdgesFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/ReduceNeighborsFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/Triplet.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/Vertex.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/ConnectedComponents.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphWeighing.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPaths.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/GraphMetrics.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasure.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/MusicProfiles.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/SingleSourceShortestPaths.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/CommunityDetectionData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ConnectedComponentsDefaultData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/EuclideanGraphData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ExampleUtils.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/IncrementalSSSPData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/JaccardSimilarityMeasureData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/LabelPropagationData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/MusicProfilesData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/PageRankData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/SingleSourceShortestPathsData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GSAConfiguration.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/CommunityDetection.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/ConnectedComponents.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAPageRank.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/PageRank.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessageIterator.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricConfiguration.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexUpdateFunction.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/utils/EdgeToTuple3Map.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/utils/NullValueEdgeMapper.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple2ToVertexMap.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple3ToEdgeMap.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/utils/VertexToTuple2Map.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/validation/GraphValidator.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidVertexIdsValidator.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSACompilerTest.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSATranslationTest.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelCompilerTest.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelTranslationTest.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/CollectionModeSuperstepITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyConfigurationITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/TestGraphUtils.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/VertexCentricConfigurationITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/example/ConnectedComponentsITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/example/EuclideanGraphWeighingITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/example/JaccardSimilarityMeasureITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/example/MusicProfilesITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/example/SingleSourceShortestPathsITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/library/CommunityDetectionITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/library/ConnectedComponentsWithRandomisedEdgesITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/library/LabelPropagationITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/library/PageRankITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/library/TriangleCountITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesWithExceptionITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/FromCollectionITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithCsvITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphMutationsITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithEdgesITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithVerticesITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapEdgesITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapVerticesITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesMethodsITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesWithExceptionITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborMethodsITCase.java (100%) rename {flink-staging => flink-libraries}/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborsWithExceptionITCase.java (100%) create mode 100644 flink-libraries/pom.xml diff --git a/docs/libs/gelly_guide.md b/docs/libs/gelly_guide.md index 766b395b82ad2..f8e4f28fbdc8f 100644 --- a/docs/libs/gelly_guide.md +++ b/docs/libs/gelly_guide.md @@ -30,7 +30,7 @@ Gelly is a Graph API for Flink. It contains a set of methods and utilities which Using Gelly ----------- -Gelly is currently part of the *staging* Maven project. All relevant classes are located in the *org.apache.flink.graph* package. +Gelly is currently part of the *libraries* Maven project. All relevant classes are located in the *org.apache.flink.graph* package. Add the following dependency to your `pom.xml` to use Gelly. @@ -57,7 +57,7 @@ Add the following dependency to your `pom.xml` to use Gelly. Note that Gelly is currently not part of the binary distribution. See linking with it for cluster execution [here](../apis/cluster_execution.html#linking-with-modules-not-contained-in-the-binary-distribution). -The remaining sections provide a description of available methods and present several examples of how to use Gelly and how to mix it with the Flink DataSet API. After reading this guide, you might also want to check the {% gh_link /flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/ "Gelly examples" %}. +The remaining sections provide a description of available methods and present several examples of how to use Gelly and how to mix it with the Flink DataSet API. After reading this guide, you might also want to check the {% gh_link /flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/ "Gelly examples" %}. Graph Representation ----------- @@ -1194,7 +1194,7 @@ final class UpdateDistance extends ApplyFunction[Long, Double, Double] { Note that `gather` takes a `Neighbor` type as an argument. This is a convenience type which simply wraps a vertex with its neighboring edge. -For more examples of how to implement algorithms with the Gather-Sum-Apply model, check the {% gh_link /flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAPageRank.java "GSAPageRank" %} and {% gh_link /flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java "GSAConnectedComponents" %} library methods of Gelly. +For more examples of how to implement algorithms with the Gather-Sum-Apply model, check the {% gh_link /flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAPageRank.java "GSAPageRank" %} and {% gh_link /flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java "GSAConnectedComponents" %} library methods of Gelly. [Back to top](#top) diff --git a/flink-staging/flink-gelly-scala/pom.xml b/flink-libraries/flink-gelly-scala/pom.xml similarity index 99% rename from flink-staging/flink-gelly-scala/pom.xml rename to flink-libraries/flink-gelly-scala/pom.xml index edcb865738da0..90d29712bcd76 100644 --- a/flink-staging/flink-gelly-scala/pom.xml +++ b/flink-libraries/flink-gelly-scala/pom.xml @@ -22,7 +22,7 @@ under the License. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> org.apache.flink - flink-staging + flink-libraries 0.10-SNAPSHOT .. diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunction.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunction.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunction.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunction.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunctionWithVertexValue.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunctionWithVertexValue.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunctionWithVertexValue.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/EdgesFunctionWithVertexValue.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunction.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunction.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunction.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunction.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunctionWithVertexValue.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunctionWithVertexValue.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunctionWithVertexValue.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/NeighborsFunctionWithVertexValue.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/ConnectedComponents.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/ConnectedComponents.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/ConnectedComponents.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/ConnectedComponents.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GSASingleSourceShortestPaths.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GSASingleSourceShortestPaths.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GSASingleSourceShortestPaths.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GSASingleSourceShortestPaths.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GraphMetrics.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GraphMetrics.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GraphMetrics.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/GraphMetrics.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/SingleSourceShortestPaths.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/SingleSourceShortestPaths.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/SingleSourceShortestPaths.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/example/SingleSourceShortestPaths.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/package.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/package.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/package.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/package.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/EdgeToTuple3Map.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/EdgeToTuple3Map.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/EdgeToTuple3Map.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/EdgeToTuple3Map.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple3ToEdgeMap.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple3ToEdgeMap.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple3ToEdgeMap.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple3ToEdgeMap.scala diff --git a/flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/VertexToTuple2Map.scala b/flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/VertexToTuple2Map.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/VertexToTuple2Map.scala rename to flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/VertexToTuple2Map.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/GellyScalaAPICompletenessTest.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/GellyScalaAPICompletenessTest.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/GellyScalaAPICompletenessTest.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/GellyScalaAPICompletenessTest.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/TestGraphUtils.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/TestGraphUtils.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/TestGraphUtils.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/TestGraphUtils.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/DegreesITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/DegreesITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/DegreesITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/DegreesITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphCreationWithCsvITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphCreationWithCsvITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphCreationWithCsvITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphCreationWithCsvITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphMutationsITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphMutationsITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphMutationsITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphMutationsITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphOperationsITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphOperationsITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphOperationsITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/GraphOperationsITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithEdgesITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithEdgesITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithEdgesITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithEdgesITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithVerticesITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithVerticesITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithVerticesITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/JoinWithVerticesITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapEdgesITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapEdgesITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapEdgesITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapEdgesITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapVerticesITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapVerticesITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapVerticesITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/MapVerticesITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnEdgesMethodsITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnEdgesMethodsITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnEdgesMethodsITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnEdgesMethodsITCase.scala diff --git a/flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnNeighborMethodsITCase.scala b/flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnNeighborMethodsITCase.scala similarity index 100% rename from flink-staging/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnNeighborMethodsITCase.scala rename to flink-libraries/flink-gelly-scala/src/test/scala/org/apache/flink/graph/scala/test/operations/ReduceOnNeighborMethodsITCase.scala diff --git a/flink-staging/flink-gelly/pom.xml b/flink-libraries/flink-gelly/pom.xml similarity index 98% rename from flink-staging/flink-gelly/pom.xml rename to flink-libraries/flink-gelly/pom.xml index 9dce170cca343..7fd95ed9fefd0 100644 --- a/flink-staging/flink-gelly/pom.xml +++ b/flink-libraries/flink-gelly/pom.xml @@ -24,7 +24,7 @@ under the License. org.apache.flink - flink-staging + flink-libraries 0.10-SNAPSHOT .. diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/EdgeDirection.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgeDirection.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/EdgeDirection.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgeDirection.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunctionWithVertexValue.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunctionWithVertexValue.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunctionWithVertexValue.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/EdgesFunctionWithVertexValue.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphAlgorithm.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphAlgorithm.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphAlgorithm.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphAlgorithm.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/IterationConfiguration.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/IterationConfiguration.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/IterationConfiguration.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/IterationConfiguration.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunctionWithVertexValue.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunctionWithVertexValue.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunctionWithVertexValue.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/NeighborsFunctionWithVertexValue.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/ReduceEdgesFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/ReduceEdgesFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/ReduceEdgesFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/ReduceEdgesFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/ReduceNeighborsFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/ReduceNeighborsFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/ReduceNeighborsFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/ReduceNeighborsFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Triplet.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Triplet.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Triplet.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Triplet.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Vertex.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Vertex.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Vertex.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Vertex.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/ConnectedComponents.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/ConnectedComponents.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/ConnectedComponents.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/ConnectedComponents.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphWeighing.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphWeighing.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphWeighing.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphWeighing.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPaths.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPaths.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPaths.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPaths.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GraphMetrics.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/GraphMetrics.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GraphMetrics.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/GraphMetrics.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasure.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasure.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasure.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasure.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/MusicProfiles.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/MusicProfiles.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/MusicProfiles.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/MusicProfiles.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/SingleSourceShortestPaths.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/SingleSourceShortestPaths.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/SingleSourceShortestPaths.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/SingleSourceShortestPaths.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/CommunityDetectionData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/CommunityDetectionData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/CommunityDetectionData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/CommunityDetectionData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ConnectedComponentsDefaultData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ConnectedComponentsDefaultData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ConnectedComponentsDefaultData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ConnectedComponentsDefaultData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/EuclideanGraphData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/EuclideanGraphData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/EuclideanGraphData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/EuclideanGraphData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ExampleUtils.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ExampleUtils.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ExampleUtils.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ExampleUtils.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/IncrementalSSSPData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/IncrementalSSSPData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/IncrementalSSSPData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/IncrementalSSSPData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/JaccardSimilarityMeasureData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/JaccardSimilarityMeasureData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/JaccardSimilarityMeasureData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/JaccardSimilarityMeasureData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/LabelPropagationData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/LabelPropagationData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/LabelPropagationData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/LabelPropagationData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/MusicProfilesData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/MusicProfilesData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/MusicProfilesData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/MusicProfilesData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/PageRankData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/PageRankData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/PageRankData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/PageRankData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/SingleSourceShortestPathsData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/SingleSourceShortestPathsData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/SingleSourceShortestPathsData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/SingleSourceShortestPathsData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GSAConfiguration.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GSAConfiguration.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GSAConfiguration.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GSAConfiguration.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/CommunityDetection.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/CommunityDetection.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/CommunityDetection.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/CommunityDetection.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/ConnectedComponents.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/ConnectedComponents.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/ConnectedComponents.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/ConnectedComponents.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAPageRank.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAPageRank.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAPageRank.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAPageRank.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/PageRank.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/PageRank.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/PageRank.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/PageRank.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessageIterator.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessageIterator.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessageIterator.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessageIterator.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricConfiguration.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricConfiguration.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricConfiguration.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricConfiguration.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexUpdateFunction.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexUpdateFunction.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexUpdateFunction.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexUpdateFunction.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/EdgeToTuple3Map.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/EdgeToTuple3Map.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/EdgeToTuple3Map.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/EdgeToTuple3Map.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/NullValueEdgeMapper.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/NullValueEdgeMapper.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/NullValueEdgeMapper.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/NullValueEdgeMapper.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple2ToVertexMap.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple2ToVertexMap.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple2ToVertexMap.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple2ToVertexMap.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple3ToEdgeMap.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple3ToEdgeMap.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple3ToEdgeMap.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/Tuple3ToEdgeMap.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/VertexToTuple2Map.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/VertexToTuple2Map.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/utils/VertexToTuple2Map.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/utils/VertexToTuple2Map.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/validation/GraphValidator.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/GraphValidator.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/validation/GraphValidator.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/GraphValidator.java diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidVertexIdsValidator.java b/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidVertexIdsValidator.java similarity index 100% rename from flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidVertexIdsValidator.java rename to flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidVertexIdsValidator.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSACompilerTest.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSACompilerTest.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSACompilerTest.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSACompilerTest.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSATranslationTest.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSATranslationTest.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSATranslationTest.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/gsa/GSATranslationTest.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelCompilerTest.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelCompilerTest.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelCompilerTest.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelCompilerTest.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelTranslationTest.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelTranslationTest.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelTranslationTest.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/spargel/SpargelTranslationTest.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/CollectionModeSuperstepITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/CollectionModeSuperstepITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/CollectionModeSuperstepITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/CollectionModeSuperstepITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyConfigurationITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyConfigurationITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyConfigurationITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyConfigurationITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/TestGraphUtils.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/TestGraphUtils.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/TestGraphUtils.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/TestGraphUtils.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/VertexCentricConfigurationITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/VertexCentricConfigurationITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/VertexCentricConfigurationITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/VertexCentricConfigurationITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/ConnectedComponentsITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/ConnectedComponentsITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/ConnectedComponentsITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/ConnectedComponentsITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/EuclideanGraphWeighingITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/EuclideanGraphWeighingITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/EuclideanGraphWeighingITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/EuclideanGraphWeighingITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/JaccardSimilarityMeasureITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/JaccardSimilarityMeasureITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/JaccardSimilarityMeasureITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/JaccardSimilarityMeasureITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/MusicProfilesITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/MusicProfilesITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/MusicProfilesITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/MusicProfilesITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/SingleSourceShortestPathsITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/SingleSourceShortestPathsITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/SingleSourceShortestPathsITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/example/SingleSourceShortestPathsITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/CommunityDetectionITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/CommunityDetectionITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/CommunityDetectionITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/CommunityDetectionITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/ConnectedComponentsWithRandomisedEdgesITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/ConnectedComponentsWithRandomisedEdgesITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/ConnectedComponentsWithRandomisedEdgesITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/ConnectedComponentsWithRandomisedEdgesITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/LabelPropagationITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/LabelPropagationITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/LabelPropagationITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/LabelPropagationITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/PageRankITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/PageRankITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/PageRankITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/PageRankITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/TriangleCountITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/TriangleCountITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/library/TriangleCountITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/library/TriangleCountITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesWithExceptionITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesWithExceptionITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesWithExceptionITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/DegreesWithExceptionITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/FromCollectionITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/FromCollectionITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/FromCollectionITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/FromCollectionITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithCsvITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithCsvITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithCsvITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithCsvITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphMutationsITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphMutationsITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphMutationsITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphMutationsITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithEdgesITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithEdgesITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithEdgesITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithEdgesITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithVerticesITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithVerticesITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithVerticesITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithVerticesITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapEdgesITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapEdgesITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapEdgesITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapEdgesITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapVerticesITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapVerticesITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapVerticesITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/MapVerticesITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesMethodsITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesMethodsITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesMethodsITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesMethodsITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesWithExceptionITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesWithExceptionITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesWithExceptionITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnEdgesWithExceptionITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborMethodsITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborMethodsITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborMethodsITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborMethodsITCase.java diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborsWithExceptionITCase.java b/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborsWithExceptionITCase.java similarity index 100% rename from flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborsWithExceptionITCase.java rename to flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/ReduceOnNeighborsWithExceptionITCase.java diff --git a/flink-libraries/pom.xml b/flink-libraries/pom.xml new file mode 100644 index 0000000000000..b38ffebf1d6ab --- /dev/null +++ b/flink-libraries/pom.xml @@ -0,0 +1,40 @@ + + + + + 4.0.0 + + + org.apache.flink + flink-parent + 0.10-SNAPSHOT + .. + + + flink-libraries + flink-libraries + pom + + + flink-gelly + flink-gelly-scala + + diff --git a/flink-staging/pom.xml b/flink-staging/pom.xml index 67aec5ae1d253..7bc76a739a999 100644 --- a/flink-staging/pom.xml +++ b/flink-staging/pom.xml @@ -40,12 +40,10 @@ under the License. flink-hadoop-compatibility flink-streaming flink-hbase - flink-gelly flink-hcatalog flink-table flink-ml flink-language-binding - flink-gelly-scala flink-scala-shell diff --git a/pom.xml b/pom.xml index 7e90ad6aea498..63ffa55240edc 100644 --- a/pom.xml +++ b/pom.xml @@ -63,6 +63,7 @@ under the License. flink-tests flink-test-utils flink-staging + flink-libraries flink-quickstart flink-contrib flink-dist