Permalink
Browse files

[#1163] Replace Operator.getName with a default implementation. (#1167)

fixes #1163
  • Loading branch information...
p-f authored and galpha committed Jan 25, 2019
1 parent 58e9386 commit 3ba05803f8d8a7bbf4065ae7cd7a8663c87861ab
Showing with 4 additions and 511 deletions.
  1. +0 −5 ...tion/src/main/java/org/gradoop/dataintegration/transformation/impl/ExtractPropertyFromVertex.java
  2. +0 −5 ...gration/src/main/java/org/gradoop/dataintegration/transformation/impl/PropertyTransformation.java
  3. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/algorithms/btgs/BusinessTransactionGraphs.java
  4. +0 −5 ...src/main/java/org/gradoop/flink/algorithms/fsm/transactional/CategoryCharacteristicSubgraphs.java
  5. +0 −5 ...-flink/src/main/java/org/gradoop/flink/algorithms/fsm/transactional/ThinkLikeAnEmbeddingTFSM.java
  6. +0 −5 ...main/java/org/gradoop/flink/algorithms/gelly/clusteringcoefficient/ClusteringCoefficientBase.java
  7. +0 −5 ...radoop/flink/algorithms/gelly/clusteringcoefficient/GellyGlobalClusteringCoefficientDirected.java
  8. +0 −5 ...doop/flink/algorithms/gelly/clusteringcoefficient/GellyGlobalClusteringCoefficientUndirected.java
  9. +0 −5 ...gradoop/flink/algorithms/gelly/clusteringcoefficient/GellyLocalClusteringCoefficientDirected.java
  10. +0 −5 ...adoop/flink/algorithms/gelly/clusteringcoefficient/GellyLocalClusteringCoefficientUndirected.java
  11. +0 −5 ...ava/org/gradoop/flink/algorithms/gelly/connectedcomponents/AnnotateWeaklyConnectedComponents.java
  12. +0 −5 ...n/java/org/gradoop/flink/algorithms/gelly/connectedcomponents/ValueWeaklyConnectedComponents.java
  13. +0 −5 ...org/gradoop/flink/algorithms/gelly/connectedcomponents/WeaklyConnectedComponentsAsCollection.java
  14. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/algorithms/gelly/hits/HITS.java
  15. +0 −5 ...oop-flink/src/main/java/org/gradoop/flink/algorithms/gelly/labelpropagation/LabelPropagation.java
  16. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/algorithms/gelly/pagerank/PageRank.java
  17. +0 −5 ...ink/src/main/java/org/gradoop/flink/algorithms/gelly/shortestpaths/SingleSourceShortestPaths.java
  18. +0 −5 ...link/src/main/java/org/gradoop/flink/algorithms/gelly/trianglecounting/GellyTriangleCounting.java
  19. +0 −5 ...p-flink/src/main/java/org/gradoop/flink/algorithms/gelly/vertexdegrees/DistinctVertexDegrees.java
  20. +4 −1 gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/Operator.java
  21. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/aggregation/Aggregation.java
  22. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/aggregation/ApplyAggregation.java
  23. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/cloning/Cloning.java
  24. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/combination/Combination.java
  25. +0 −5 ...oop-flink/src/main/java/org/gradoop/flink/model/impl/operators/combination/ReduceCombination.java
  26. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/difference/Difference.java
  27. +0 −5 ...op-flink/src/main/java/org/gradoop/flink/model/impl/operators/difference/DifferenceBroadcast.java
  28. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/distinction/DistinctById.java
  29. +0 −5 ...flink/src/main/java/org/gradoop/flink/model/impl/operators/distinction/DistinctByIsomorphism.java
  30. +0 −5 ...op-flink/src/main/java/org/gradoop/flink/model/impl/operators/distinction/GroupByIsomorphism.java
  31. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/equality/CollectionEquality.java
  32. +0 −5 ...k/src/main/java/org/gradoop/flink/model/impl/operators/equality/CollectionEqualityByGraphIds.java
  33. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/equality/GraphEquality.java
  34. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/exclusion/Exclusion.java
  35. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/exclusion/ReduceExclusion.java
  36. +0 −7 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/fusion/VertexFusion.java
  37. +0 −5 ...oop-flink/src/main/java/org/gradoop/flink/model/impl/operators/grouping/GroupingGroupCombine.java
  38. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/grouping/GroupingGroupReduce.java
  39. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/intersection/Intersection.java
  40. +0 −5 ...link/src/main/java/org/gradoop/flink/model/impl/operators/intersection/IntersectionBroadcast.java
  41. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/limit/Limit.java
  42. +0 −5 ...ain/java/org/gradoop/flink/model/impl/operators/matching/single/cypher/CypherPatternMatching.java
  43. +0 −5 ...flink/model/impl/operators/matching/single/preserving/explorative/ExplorativePatternMatching.java
  44. +0 −5 ...n/java/org/gradoop/flink/model/impl/operators/matching/single/simulation/dual/DualSimulation.java
  45. +0 −5 ...a/org/gradoop/flink/model/impl/operators/matching/transactional/TransactionalPatternMatching.java
  46. +0 −5 ...ink/src/main/java/org/gradoop/flink/model/impl/operators/neighborhood/ReduceEdgeNeighborhood.java
  47. +0 −5 ...k/src/main/java/org/gradoop/flink/model/impl/operators/neighborhood/ReduceVertexNeighborhood.java
  48. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/overlap/Overlap.java
  49. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/overlap/ReduceOverlap.java
  50. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/rollup/EdgeRollUp.java
  51. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/rollup/VertexRollUp.java
  52. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/sampling/PageRankSampling.java
  53. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/sampling/RandomEdgeSampling.java
  54. +0 −5 .../main/java/org/gradoop/flink/model/impl/operators/sampling/RandomLimitedDegreeVertexSampling.java
  55. +0 −5 ...src/main/java/org/gradoop/flink/model/impl/operators/sampling/RandomNonUniformVertexSampling.java
  56. +0 −5 ...flink/src/main/java/org/gradoop/flink/model/impl/operators/sampling/RandomVertexEdgeSampling.java
  57. +0 −5 ...c/main/java/org/gradoop/flink/model/impl/operators/sampling/RandomVertexNeighborhoodSampling.java
  58. +0 −5 ...oop-flink/src/main/java/org/gradoop/flink/model/impl/operators/sampling/RandomVertexSampling.java
  59. +0 −5 ...gradoop/flink/model/impl/operators/sampling/functions/FilterVerticesWithDegreeOtherThanGiven.java
  60. +0 −5 ...java/org/gradoop/flink/model/impl/operators/sampling/statistics/AverageClusteringCoefficient.java
  61. +0 −5 ...flink/src/main/java/org/gradoop/flink/model/impl/operators/sampling/statistics/AverageDegree.java
  62. +0 −5 ...c/main/java/org/gradoop/flink/model/impl/operators/sampling/statistics/AverageIncomingDegree.java
  63. +0 −5 ...c/main/java/org/gradoop/flink/model/impl/operators/sampling/statistics/AverageOutgoingDegree.java
  64. +0 −5 ...a/org/gradoop/flink/model/impl/operators/sampling/statistics/ConnectedComponentsDistribution.java
  65. +0 −5 ...-flink/src/main/java/org/gradoop/flink/model/impl/operators/sampling/statistics/GraphDensity.java
  66. +0 −5 .../gradoop/flink/model/impl/operators/sampling/statistics/ValueConnectedComponentsDistribution.java
  67. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/selection/Selection.java
  68. +0 −3 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/selection/SelectionBase.java
  69. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/split/Split.java
  70. +0 −5 ...flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctEdgeProperties.java
  71. +0 −5 ...rc/main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctEdgePropertiesByLabel.java
  72. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctSourceIds.java
  73. +0 −5 ...src/main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctSourceIdsByEdgeLabel.java
  74. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctTargetIds.java
  75. +0 −5 ...src/main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctTargetIdsByEdgeLabel.java
  76. +0 −5 ...ink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctVertexProperties.java
  77. +0 −5 .../main/java/org/gradoop/flink/model/impl/operators/statistics/DistinctVertexPropertiesByLabel.java
  78. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/EdgeCount.java
  79. +0 −5 ...-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/EdgeLabelDistribution.java
  80. +0 −5 ...-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/EdgeValueDistribution.java
  81. +0 −5 ...main/java/org/gradoop/flink/model/impl/operators/statistics/IncomingVertexDegreeDistribution.java
  82. +0 −5 ...-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/IncomingVertexDegrees.java
  83. +0 −5 ...main/java/org/gradoop/flink/model/impl/operators/statistics/OutgoingVertexDegreeDistribution.java
  84. +0 −5 ...-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/OutgoingVertexDegrees.java
  85. +0 −5 ...n/java/org/gradoop/flink/model/impl/operators/statistics/SourceLabelAndEdgeLabelDistribution.java
  86. +0 −5 ...n/java/org/gradoop/flink/model/impl/operators/statistics/TargetLabelAndEdgeLabelDistribution.java
  87. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/VertexCount.java
  88. +0 −5 ...ink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/VertexDegreeDistribution.java
  89. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/VertexDegrees.java
  90. +0 −5 ...link/src/main/java/org/gradoop/flink/model/impl/operators/statistics/VertexLabelDistribution.java
  91. +0 −5 ...link/src/main/java/org/gradoop/flink/model/impl/operators/statistics/VertexValueDistribution.java
  92. +0 −5 ...g/gradoop/flink/model/impl/operators/statistics/writer/DistinctEdgePropertiesByLabelPreparer.java
  93. +0 −5 ...a/org/gradoop/flink/model/impl/operators/statistics/writer/DistinctSourceVertexCountPreparer.java
  94. +0 −5 ...a/org/gradoop/flink/model/impl/operators/statistics/writer/DistinctTargetVertexCountPreparer.java
  95. +0 −5 ...gradoop/flink/model/impl/operators/statistics/writer/DistinctVertexPropertiesByLabelPreparer.java
  96. +0 −5 ...ink/src/main/java/org/gradoop/flink/model/impl/operators/statistics/writer/EdgeCountPreparer.java
  97. +0 −5 .../gradoop/flink/model/impl/operators/statistics/writer/SourceAndEdgeLabelDistributionPreparer.java
  98. +0 −5 .../gradoop/flink/model/impl/operators/statistics/writer/TargetAndEdgeLabelDistributionPreparer.java
  99. +0 −5 ...k/src/main/java/org/gradoop/flink/model/impl/operators/statistics/writer/VertexCountPreparer.java
  100. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/subgraph/ApplySubgraph.java
  101. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/subgraph/Subgraph.java
  102. +0 −5 ...oop-flink/src/main/java/org/gradoop/flink/model/impl/operators/transformation/Transformation.java
  103. +0 −5 gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/union/Union.java
@@ -169,9 +169,4 @@ public LogicalGraph execute(LogicalGraph logicalGraph) {
.getLogicalGraphFactory()
.fromDataSets(logicalGraph.getGraphHead(), vertices, edges);
}

@Override
public String getName() {
return ExtractPropertyFromVertex.class.getName();
}
}
@@ -140,9 +140,4 @@ public LG execute(LG graph) {
.execute(graph);
}

@Override
public String getName() {
return PropertyTransformation.class.getName();
}

}
@@ -147,9 +147,4 @@ public GraphCollection execute(LogicalGraph iig) {
return iig.getConfig().getGraphCollectionFactory()
.fromDataSets(graphHeads, transVertices.union(masterVertices), btgEdges);
}

@Override
public String getName() {
return BusinessTransactionGraphs.class.getName();
}
}
@@ -248,9 +248,4 @@ private void setMinFrequencies() {
.withBroadcastSet(categoryMinFrequencies, DIMSpanConstants.MIN_FREQUENCY);
}

@Override
public String getName() {
return this.getClass().getSimpleName();
}

}
@@ -125,9 +125,4 @@ public ThinkLikeAnEmbeddingTFSM(FSMConfig fsmConfig) {
.withBroadcastSet(minFrequency, DIMSpanConstants.MIN_FREQUENCY);
}

@Override
public String getName() {
return this.getClass().getSimpleName();
}

}
@@ -72,9 +72,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, NullValue, NullValue> graph)
*/
protected abstract LogicalGraph executeInternal(Graph<GradoopId, NullValue, NullValue> gellyGraph)
throws Exception;

@Override
public String getName() {
return ClusteringCoefficientBase.class.getName();
}
}
@@ -64,9 +64,4 @@ protected LogicalGraph executeInternal(Graph<GradoopId, NullValue, NullValue> ge
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(
resultHead, currentGraph.getVertices(), currentGraph.getEdges());
}

@Override
public String getName() {
return GellyGlobalClusteringCoefficientDirected.class.getName();
}
}
@@ -65,9 +65,4 @@ protected LogicalGraph executeInternal(Graph<GradoopId, NullValue, NullValue> ge
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(
resultHead, currentGraph.getVertices(), currentGraph.getEdges());
}

@Override
public String getName() {
return GellyGlobalClusteringCoefficientUndirected.class.getName();
}
}
@@ -60,9 +60,4 @@ protected LogicalGraph executeInternal(Graph<GradoopId, NullValue, NullValue> ge
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(
currentGraph.getGraphHead(), resultVertices, currentGraph.getEdges());
}

@Override
public String getName() {
return GellyLocalClusteringCoefficientDirected.class.getName();
}
}
@@ -61,9 +61,4 @@ protected LogicalGraph executeInternal(Graph<GradoopId, NullValue, NullValue> ge
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(
currentGraph.getGraphHead(), resultVertices, currentGraph.getEdges());
}

@Override
public String getName() {
return GellyLocalClusteringCoefficientUndirected.class.getName();
}
}
@@ -107,9 +107,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, GradoopId, NullValue> graph)
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(
currentGraph.getGraphHead(), annotatedVertices, edges);
}

@Override
public String getName() {
return AnnotateWeaklyConnectedComponents.class.getName();
}
}
@@ -99,9 +99,4 @@ public ValueWeaklyConnectedComponents(int maxIteration) {
return new ConnectedComponents<Long, Long, NullValue>(maxIteration)
.run(graph).map(new MapVertexIdComponentId());
}

@Override
public String getName() {
return ValueWeaklyConnectedComponents.class.getName();
}
}
@@ -78,9 +78,4 @@ public GraphCollection execute(LogicalGraph graph) {
split.getVertices().map(new PropertyRemover<>(propertyKey)),
split.getEdges().map(new PropertyRemover<>(propertyKey)));
}

@Override
public String getName() {
return WeaklyConnectedComponentsAsCollection.class.getName();
}
}
@@ -114,9 +114,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, NullValue, NullValue> graph)
.fromDataSets(newVertices, currentGraph.getEdges());
}

@Override
public String getName() {
return HITS.class.getName();
}

}
@@ -97,9 +97,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, PropertyValue, NullValue> gr
protected int getMaxIterations() {
return maxIterations;
}

@Override
public String getName() {
return LabelPropagation.class.getName();
}
}
@@ -99,9 +99,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, NullValue, NullValue> graph)
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(
currentGraph.getGraphHead(), newVertices, currentGraph.getEdges());
}

@Override
public String getName() {
return PageRank.class.getName();
}
}
@@ -86,9 +86,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, NullValue, Double> graph)
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(newVertices,
currentGraph.getEdges());
}

@Override
public String getName() {
return SingleSourceShortestPaths.class.getName();
}
}
@@ -65,9 +65,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, NullValue, NullValue> graph)
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(
resultHead, currentGraph.getVertices(), currentGraph.getEdges());
}

@Override
public String getName() {
return GellyTriangleCounting.class.getName();
}
}
@@ -99,9 +99,4 @@ public LogicalGraph executeInGelly(Graph<GradoopId, NullValue, NullValue> graph)
return currentGraph.getConfig().getLogicalGraphFactory().fromDataSets(newVertices,
currentGraph.getEdges());
}

@Override
public String getName() {
return DistinctVertexDegrees.class.getName();
}
}
@@ -21,8 +21,11 @@
public interface Operator {
/**
* Returns the operators name.
* The operator name is the same as the class name, per default.
*
* @return operator name
*/
String getName();
default String getName() {
return this.getClass().getName();
}
}
@@ -100,9 +100,4 @@ public LogicalGraph execute(LogicalGraph graph) {
.filter(AggregateFunction::isEdgeAggregation)
.collect(Collectors.toSet())));
}

@Override
public String getName() {
return Aggregation.class.getName();
}
}
@@ -129,9 +129,4 @@ public GraphCollection executeForTxLayout(GraphCollection collection) {
.filter(AggregateFunction::isEdgeAggregation)
.collect(Collectors.toSet())));
}

@Override
public String getName() {
return ApplyAggregation.class.getName();
}
}
@@ -89,9 +89,4 @@ public LogicalGraph execute(LogicalGraph graph) {
return graph.getConfig().getLogicalGraphFactory()
.fromDataSets(graphHead, vertices, edges);
}

@Override
public String getName() {
return Cloning.class.getName();
}
}
@@ -51,9 +51,4 @@ public LogicalGraph execute(LogicalGraph firstGraph,
return firstGraph.getConfig().getLogicalGraphFactory().fromDataSets(newVertexSet, newEdgeSet);
}

@Override
public String getName() {
return Combination.class.getName();
}

}
@@ -36,9 +36,4 @@ public LogicalGraph execute(GraphCollection collection) {
return collection.getConfig().getLogicalGraphFactory().fromDataSets(
collection.getVertices(), collection.getEdges());
}

@Override
public String getName() {
return ReduceCombination.class.getName();
}
}
@@ -55,9 +55,4 @@
.groupBy(new IdOf0InTuple2<GraphHead, Long>())
.reduceGroup(new RemoveCut<GraphHead>());
}

@Override
public String getName() {
return Difference.class.getName();
}
}
@@ -53,9 +53,4 @@
.withBroadcastSet(identifiers,
GraphsContainmentFilterBroadcast.GRAPH_IDS);
}

@Override
public String getName() {
return DifferenceBroadcast.class.getName();
}
}
@@ -32,9 +32,4 @@ public GraphCollection execute(GraphCollection collection) {
collection.getVertices(),
collection.getEdges());
}

@Override
public String getName() {
return DistinctById.class.getName();
}
}
@@ -49,9 +49,4 @@ public GraphCollection execute(GraphCollection collection) {

return selectVerticesAndEdges(collection, graphHeads);
}

@Override
public String getName() {
return DistinctByIsomorphism.class.getName();
}
}
@@ -75,9 +75,4 @@ public GraphCollection execute(GraphCollection collection) {
return camBuilder
.getGraphHeadStrings(collection);
}

@Override
public String getName() {
return GroupByIsomorphism.class.getName();
}
}
@@ -65,9 +65,4 @@ public CollectionEquality(GraphHeadToString<GraphHead> graphHeadToString,
canonicalAdjacencyMatrixBuilder.execute(secondCollection)
);
}

@Override
public String getName() {
return this.getClass().getSimpleName();
}
}
@@ -60,9 +60,4 @@

return Not.map(Or.reduce(d));
}

@Override
public String getName() {
return this.getClass().getSimpleName();
}
}
@@ -64,9 +64,4 @@ public GraphEquality(GraphHeadToString<GraphHead> graphHeadToString,
return collectionEquality
.execute(collectionFactory.fromGraph(firstGraph), collectionFactory.fromGraph(secondGraph));
}

@Override
public String getName() {
return this.getClass().getSimpleName();
}
}
@@ -78,9 +78,4 @@ public LogicalGraph execute(

return firstGraph.getConfig().getLogicalGraphFactory().fromDataSets(newVertexSet, newEdgeSet);
}

@Override
public String getName() {
return Exclusion.class.getName();
}
}
@@ -75,9 +75,4 @@ public LogicalGraph execute(GraphCollection collection) {

return collection.getConfig().getLogicalGraphFactory().fromDataSets(vertices, edges);
}

@Override
public String getName() {
return ReduceExclusion.class.getName();
}
}
@@ -149,11 +149,4 @@ public LogicalGraph execute(LogicalGraph searchGraph, GraphCollection graphPatte

return searchGraph.getConfig().getLogicalGraphFactory().fromDataSets(gh, vToRet, edges);
}



@Override
public String getName() {
return VertexFusion.class.getName();
}
}
@@ -121,9 +121,4 @@ protected LogicalGraph groupInternal(LogicalGraph graph) {

return config.getLogicalGraphFactory().fromDataSets(superVertices, superEdges);
}

@Override
public String getName() {
return GroupingGroupCombine.class.getName();
}
}
@@ -101,9 +101,4 @@ protected LogicalGraph groupInternal(LogicalGraph graph) {

return config.getLogicalGraphFactory().fromDataSets(superVertices, superEdges);
}

@Override
public String getName() {
return GroupingGroupReduce.class.getName();
}
}
@@ -43,9 +43,4 @@
.groupBy(new Id<GraphHead>())
.reduceGroup(new GroupCountEquals<GraphHead>(2));
}

@Override
public String getName() {
return Intersection.class.getName();
}
}
Oops, something went wrong.

0 comments on commit 3ba0580

Please sign in to comment.