From 23394102767e95e9966d50abc5efcef28f019eae Mon Sep 17 00:00:00 2001 From: zentol Date: Tue, 26 Apr 2016 13:26:48 +0200 Subject: [PATCH] [FLINK-3818] Remove Guava dependency from flink-gelly-examples --- flink-libraries/flink-gelly-examples/pom.xml | 5 ----- .../flink/graph/examples/data/SummarizationData.java | 7 +++---- 2 files changed, 3 insertions(+), 9 deletions(-) diff --git a/flink-libraries/flink-gelly-examples/pom.xml b/flink-libraries/flink-gelly-examples/pom.xml index 5ed0fa4157cac..864b4b914f5bb 100644 --- a/flink-libraries/flink-gelly-examples/pom.xml +++ b/flink-libraries/flink-gelly-examples/pom.xml @@ -63,11 +63,6 @@ ${project.version} test - - com.google.guava - guava - ${guava.version} - diff --git a/flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/SummarizationData.java b/flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/SummarizationData.java index c14d5ded5dc53..ea60ea0699b34 100644 --- a/flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/SummarizationData.java +++ b/flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/SummarizationData.java @@ -18,8 +18,6 @@ package org.apache.flink.graph.examples.data; -import com.google.common.collect.Lists; - import org.apache.flink.api.common.functions.MapFunction; import org.apache.flink.api.java.DataSet; import org.apache.flink.api.java.ExecutionEnvironment; @@ -27,6 +25,7 @@ import org.apache.flink.graph.Vertex; import org.apache.flink.types.NullValue; +import java.util.ArrayList; import java.util.List; /** @@ -83,7 +82,7 @@ private SummarizationData() {} * @return vertex data set with string values */ public static DataSet> getVertices(ExecutionEnvironment env) { - List> vertices = Lists.newArrayListWithExpectedSize(6); + List> vertices = new ArrayList<>(6); vertices.add(new Vertex<>(0L, "A")); vertices.add(new Vertex<>(1L, "A")); vertices.add(new Vertex<>(2L, "B")); @@ -101,7 +100,7 @@ public static DataSet> getVertices(ExecutionEnvironment env * @return edge data set with string values */ public static DataSet> getEdges(ExecutionEnvironment env) { - List> edges = Lists.newArrayListWithExpectedSize(10); + List> edges = new ArrayList<>(10); edges.add(new Edge<>(0L, 1L, "A")); edges.add(new Edge<>(1L, 0L, "A")); edges.add(new Edge<>(1L, 2L, "A"));