+ * Given a label and a list of property keys, this operator will find all vertices of that label and condense + * duplicates to one vertex. Two (or more) vertices are considered duplicates if all property values, + * respective to the list of given keys, are equal.
+ * Other attributes of the vertices are ignored, the new (condensed) vertex will have the attributes of some + * (random) vertex of its duplicates. + *
+ * This will create no new elements and retain the graph head.
+ *
+ * @param
+ * The mapping will be extracted from elements annotated with the {@link MarkDuplicatesInGroup#PROPERTY_KEY}
+ * property key. The first pair entry will be the ID of the element and the second the value of the property.
+ *
+ * @param
+ * This will take a list of property keys and return a list of property values for each element. The order
+ * will be the same for both keys and values.
+ * Unset properties will be returned as {@link PropertyValue#NULL_VALUE}.
+ *
+ * @param
+ * Note that this will delete unnecessary properties from duplicate elements.
+ *
+ * @param
+ * This provides an example on how to use the {@link KeyedGrouping} operator with label-specific grouping + * as well as a custom (user-defined) key-function. + *
+ * Using the social network graph {@link SocialNetworkGraph}, the program will: + *
+ * This key-function is extracting the property and dividing it by {@code 10}, rounding it.
+ * We assume that the age divided by {@code 10} fits in a {@link Byte} value (it's range is
+ * {@value Byte#MIN_VALUE} to {@value Byte#MAX_VALUE}).
+ *
+ * @param
+ * We implement this method to store our grouping-key on super-elements. This is useful in most cases,
+ * since the user want's to know which group is represented by a super-element. In our case we multiply
+ * the key by {@code 10}, since it was divided by {@code 10} in the {@link #getKey(Attributed)} method.
+ * The key is stored as a property with key {@code age_rounded}, we also make sure to ignore the default
+ * key, since {@code -10} would not be a correct age and is just used internally as the default value.
+ *
+ * @param element The element where the key should be stored.
+ * @param key The key to store on the element. A {@link Byte} in this case.
+ */
+ @Override
+ public void addKeyToElement(E element, Object key) {
+ // Manually checking the type is technically not required, but is recommended to avoid hard to find bugs.
+ if (!(key instanceof Byte)) {
+ throw new IllegalArgumentException("Invalid type for key; " + key);
+ }
+ if (getDefaultKey().equals(key)) {
+ return;
+ }
+ final int actualKey = 10 * (byte) key;
+ element.setProperty("age_rounded", actualKey);
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * We have to provide type infos about the keys extracted by this function.
+ * Flink provides commonly used (mostly primitive) types in this class. In most other cases the
+ * {@link TypeInformation#of(Class)} should suffice.
+ *
+ * @return The type information about keys extracted by this class, {@link Byte} in this case.
+ */
+ @Override
+ public TypeInformation
+ * We have to provide a default value if we want to use this key-function with label-specific grouping.
+ * This value is used for labels other than the one for which this function is to be used.
+ *
+ * @return A default value, in this case {@code -1}.
+ */
+ @Override
+ public Byte getDefaultKey() {
+ return -1;
+ }
+}
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/cypher/capf/result/package-info.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/keyedgrouping/functions/package-info.java
similarity index 74%
rename from gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/cypher/capf/result/package-info.java
rename to gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/keyedgrouping/functions/package-info.java
index 25d94c0d5c6d..16ceaa2820cc 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/operators/cypher/capf/result/package-info.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/keyedgrouping/functions/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -14,6 +14,6 @@
* limitations under the License.
*/
/**
- * Contains implementations for the handling of results returned by CAPF
+ * Custom (key-) functions used by this {@code KeyedGrouping} example.
*/
-package org.gradoop.flink.model.impl.operators.cypher.capf.result;
+package org.gradoop.examples.keyedgrouping.functions;
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/io/impl/table/package-info.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/keyedgrouping/package-info.java
similarity index 76%
rename from gradoop-flink/src/main/java/org/gradoop/flink/io/impl/table/package-info.java
rename to gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/keyedgrouping/package-info.java
index 460fd4d82701..6ce5b9ae21ff 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/io/impl/table/package-info.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/keyedgrouping/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -14,6 +14,6 @@
* limitations under the License.
*/
/**
- * Contains all classes related to the input and output of Flink tables.
+ * A runnable example for the {@code KeyedGrouping} operator.
*/
-package org.gradoop.flink.io.impl.table;
+package org.gradoop.examples.keyedgrouping;
diff --git a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/CypherQueryExample.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/CypherQueryExample.java
deleted file mode 100644
index 4930b4e5fa29..000000000000
--- a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/CypherQueryExample.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.gradoop.examples.patternmatch;
-
-import org.apache.flink.api.java.ExecutionEnvironment;
-import org.gradoop.examples.common.SocialNetworkGraph;
-import org.gradoop.flink.model.impl.epgm.GraphCollection;
-import org.gradoop.flink.model.impl.epgm.LogicalGraph;
-import org.gradoop.flink.util.FlinkAsciiGraphLoader;
-import org.gradoop.flink.util.GradoopFlinkConfig;
-
-/**
- * A self-contained example on how to use the query engine in Gradoop.
- *
- * The example uses the graph in dev-support/social-network.pdf
- */
-public class CypherQueryExample {
-
- /**
- * Runs the program on the example data graph.
- *
- * The example provides an overview over the usage of the {@link LogicalGraph#cypher(String)}
- * method. It showcases how a user defined (cypher) query can be applied to a graph.
- * Documentation and usage examples can be found in the projects wiki.
- *
- * Using the social network graph {@link SocialNetworkGraph}, the program will:
- *
- * In this overloaded function, the property maps are constructed automatically. This is
- * a lot slower and actually requires the job to be split in two parts to collect the property maps.
- *
- * @param query the query string
- * @return the result, containing a flink table and possibly a GraphCollection
- * @throws Exception on failure
- */
- CAPFQueryResult cypher(String query) throws Exception;
-
/**
* Creates a new graph from a randomly chosen subset of nodes and their associated edges.
*
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/epgm/package-info.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/epgm/package-info.java
index 84f56374913e..bbffda6a09d8 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/epgm/package-info.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/epgm/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateDefaultValue.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateDefaultValue.java
index 76efcc4e0a32..e79982b0934f 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateDefaultValue.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateDefaultValue.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateFunction.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateFunction.java
index ccadb18e1730..4741c7f1e8c5 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateFunction.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/AggregateFunction.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/EdgeAggregateFunction.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/EdgeAggregateFunction.java
index 27acccf59a9e..889b6430ba76 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/EdgeAggregateFunction.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/EdgeAggregateFunction.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/Function.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/Function.java
index df6f1137d75e..860d40a62f33 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/Function.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/Function.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/GraphHeadReduceFunction.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/GraphHeadReduceFunction.java
index 0ebfb6be35b6..ae7c57f0f0da 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/GraphHeadReduceFunction.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/GraphHeadReduceFunction.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunction.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunction.java
index 9eceb7663a25..25ff8682d720 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunction.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunction.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunctionWithDefaultValue.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunctionWithDefaultValue.java
index e3cb4275c2a2..f5ce538c406c 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunctionWithDefaultValue.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/KeyFunctionWithDefaultValue.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/TransformationFunction.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/TransformationFunction.java
index cf272101f4bb..6ae6230ccbee 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/TransformationFunction.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/TransformationFunction.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/VertexAggregateFunction.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/VertexAggregateFunction.java
index 009ae4777df0..9a9e630f4133 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/VertexAggregateFunction.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/VertexAggregateFunction.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/package-info.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/package-info.java
index f1749927ded5..6df61dc4c286 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/package-info.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/functions/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/BaseLayoutFactory.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/BaseLayoutFactory.java
index d1e5ce63a673..fd27290aec30 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/BaseLayoutFactory.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/BaseLayoutFactory.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayout.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayout.java
index c04c0e1360d8..dc490b081011 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayout.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayout.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayoutFactory.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayoutFactory.java
index 0d9513eed8b3..5f41b1962918 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayoutFactory.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/GraphCollectionLayoutFactory.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/Layout.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/Layout.java
index c9a693e73cb5..5936f5c3789a 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/Layout.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/Layout.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayout.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayout.java
index 620fc8b8354e..85402df88a79 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayout.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayout.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayoutFactory.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayoutFactory.java
index fd99ac386916..6033dad2c9d6 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayoutFactory.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/LogicalGraphLayoutFactory.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/package-info.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/package-info.java
index d86ee458aa05..8a76292eb086 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/package-info.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/layouts/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ApplicableUnaryBaseGraphToBaseGraphOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ApplicableUnaryBaseGraphToBaseGraphOperator.java
index 9d1594425ca7..b23fb42dbf58 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ApplicableUnaryBaseGraphToBaseGraphOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ApplicableUnaryBaseGraphToBaseGraphOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToBaseGraphCollectionOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToBaseGraphCollectionOperator.java
index 89e1fd99959a..1536d0fe8136 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToBaseGraphCollectionOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToBaseGraphCollectionOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToValueOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToValueOperator.java
index 56bb0316c9a0..f39f999f19c8 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToValueOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphCollectionToValueOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToBaseGraphOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToBaseGraphOperator.java
index 2d28f3237974..f92edaeefe97 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToBaseGraphOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToBaseGraphOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToValueOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToValueOperator.java
index ffd05405ef89..ddd13e490ebb 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToValueOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/BinaryBaseGraphToValueOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphCollectionGenerator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphCollectionGenerator.java
index fc5ed23ee804..f5ad98a6320d 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphCollectionGenerator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphCollectionGenerator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphGenerator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphGenerator.java
index 1449fe24c5e9..688062d5aa50 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphGenerator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphGenerator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsGenerator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsGenerator.java
index b8b53350b493..9c1177883369 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsGenerator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsGenerator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsOperators.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsOperators.java
index d5792d412d3e..a0f026d4f85e 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsOperators.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphTransactionsOperators.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphsToGraphOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphsToGraphOperator.java
index e0bf2a14bda3..2c2cba748117 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphsToGraphOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/GraphsToGraphOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/Operator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/Operator.java
index 87ede4ed830f..f20b010d8ce2 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/Operator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/Operator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ReducibleBinaryBaseGraphToBaseGraphOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ReducibleBinaryBaseGraphToBaseGraphOperator.java
index b221fb5ca54c..144f303d71c4 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ReducibleBinaryBaseGraphToBaseGraphOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/ReducibleBinaryBaseGraphToBaseGraphOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphCollectionOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphCollectionOperator.java
index f0054c304e70..d838d85a1e50 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphCollectionOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphCollectionOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphOperator.java
index c36abe471820..31bb7d581f33 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToBaseGraphOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToValueOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToValueOperator.java
index edd537f23f9e..d5032fd2b77a 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToValueOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphCollectionToValueOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphCollectionOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphCollectionOperator.java
index 32444fd19652..a9b24226ca5e 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphCollectionOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphCollectionOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphOperator.java
index b4d9d8ac728c..4fc43f7e677d 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToBaseGraphOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToValueOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToValueOperator.java
index 2927afadd5c0..74e91c3dfaac 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToValueOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryBaseGraphToValueOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryCollectionToCollectionOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryCollectionToCollectionOperator.java
index 693a14243e18..1bf9065b1e26 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryCollectionToCollectionOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryCollectionToCollectionOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToCollectionOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToCollectionOperator.java
index 3e70ee77b002..bf40d135b940 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToCollectionOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToCollectionOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToGraphOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToGraphOperator.java
index 6c1b4cb97c7d..9412f84561ff 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToGraphOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToGraphOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToValueOperator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToValueOperator.java
index 15e07c446ba2..88733540dffc 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToValueOperator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/UnaryGraphToValueOperator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/package-info.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/package-info.java
index c54a7c1706de..d9d3a58d6042 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/package-info.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/operators/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/Countable.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/Countable.java
index 651bf5d6da3e..00405221c9fd 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/Countable.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/Countable.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/package-info.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/package-info.java
index 051a3ea85669..f675d58f6250 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/package-info.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/api/tuples/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/ElementIdComparator.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/ElementIdComparator.java
index 5d9d643a6c16..9d8b5e4b8d80 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/ElementIdComparator.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/ElementIdComparator.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/package-info.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/package-info.java
index a059f678757f..68d00951c6ea 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/package-info.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/comparators/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollection.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollection.java
index 4fda2ebee196..eacc31f2f5b1 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollection.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollection.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollectionFactory.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollectionFactory.java
index 0d989fae7704..00fe77debe03 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollectionFactory.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/GraphCollectionFactory.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/LogicalGraph.java b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/LogicalGraph.java
index 20683f0ceb81..29fa9da31cab 100644
--- a/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/LogicalGraph.java
+++ b/gradoop-flink/src/main/java/org/gradoop/flink/model/impl/epgm/LogicalGraph.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -17,7 +17,6 @@
import com.google.common.collect.Lists;
import org.apache.flink.api.java.DataSet;
-import org.gradoop.common.model.impl.metadata.MetaData;
import org.gradoop.common.model.impl.pojo.EPGMEdge;
import org.gradoop.common.model.impl.pojo.EPGMGraphHead;
import org.gradoop.common.model.impl.pojo.EPGMVertex;
@@ -33,8 +32,6 @@
import org.gradoop.flink.model.api.operators.GraphsToGraphOperator;
import org.gradoop.flink.model.api.operators.UnaryBaseGraphToValueOperator;
import org.gradoop.flink.model.impl.functions.epgm.PropertyGetter;
-import org.gradoop.flink.model.impl.operators.cypher.capf.query.CAPFQuery;
-import org.gradoop.flink.model.impl.operators.cypher.capf.result.CAPFQueryResult;
import org.gradoop.flink.model.impl.operators.rollup.EdgeRollUp;
import org.gradoop.flink.model.impl.operators.rollup.VertexRollUp;
import org.gradoop.flink.model.impl.operators.sampling.SamplingAlgorithm;
@@ -145,21 +142,6 @@ public DataSet
- * The output is an edge with updated source id.
+ * source in its first field and the id of the new edge source vertex in its second.
+ * The output is an edge with updated source id.
+ * If the tuple is {@code null}, then the edge is not changed.
*
- * @param
+ * The output is an edge with updated target id.
+ * If the tuple is {@code null}, then the edge is not changed.
*
- * @param
* See {@link LogicalGraph#groupBy(List, List, List, List, GroupingStrategy)}
*/
public static final String LABEL_SYMBOL = ":label";
@@ -123,23 +128,30 @@ public abstract class Grouping<
*/
private final List
- *
- *
- * @param args no arguments provided
- * @see
- * Gradoop Wiki
- * @throws Exception in case sth goes wrong
- */
- public static void main(String[] args) throws Exception {
- // create flink execution environment
- ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
-
- // create loader
- FlinkAsciiGraphLoader loader = new FlinkAsciiGraphLoader(GradoopFlinkConfig.createConfig(env));
-
- // load data
- loader.initDatabaseFromString(SocialNetworkGraph.getGraphGDLString());
-
- // load graph
- LogicalGraph socialNetwork = loader.getLogicalGraph();
-
- // run a Cypher query (vertex homomorphism, edge isomorphism)
- // the result is a graph collection containing all matching subgraphs
- GraphCollection matches = socialNetwork.cypher(
- "MATCH (u1:Person)<-[:hasModerator]-(f:Forum)," +
- "(u2:Person)<-[:hasMember]-(f)" +
- "WHERE u1.name = \"Alice\"" +
- "RETURN *").getGraphs();
-
- // print found matches
- matches.print();
- }
-}
diff --git a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/GDLQueryExample.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/GDLQueryExample.java
index 903f1c7e2581..0995c1042a31 100644
--- a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/GDLQueryExample.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/GDLQueryExample.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/package-info.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/package-info.java
index f37539ba73b4..94f630c61dda 100644
--- a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/package-info.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/patternmatch/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/QuickstartExample.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/QuickstartExample.java
index 6e316d99c1ce..c034c617ee37 100644
--- a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/QuickstartExample.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/QuickstartExample.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/QuickstartData.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/QuickstartData.java
index 523b15aec2c8..e3b0e822b2de 100644
--- a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/QuickstartData.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/QuickstartData.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/package-info.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/package-info.java
index 695d07192bcb..1a9809845a5b 100644
--- a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/package-info.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/data/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/package-info.java b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/package-info.java
index 819c748b99ab..481e77cd7e59 100644
--- a/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/package-info.java
+++ b/gradoop-examples/gradoop-examples-operators/src/main/java/org/gradoop/examples/quickstart/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright © 2014 - 2019 Leipzig University (Database Research Group)
+ * Copyright © 2014 - 2020 Leipzig University (Database Research Group)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/gradoop-examples/gradoop-examples-temporal/pom.xml b/gradoop-examples/gradoop-examples-temporal/pom.xml
index 79297daa22b3..fcdc55739c39 100644
--- a/gradoop-examples/gradoop-examples-temporal/pom.xml
+++ b/gradoop-examples/gradoop-examples-temporal/pom.xml
@@ -8,7 +8,7 @@