[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14590556#comment-14590556
]
ASF GitHub Bot commented on FLINK-1520:
---------------------------------------
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/847#discussion_r32672805
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -282,6 +282,58 @@ public void flatMap(Edge<K, EV> edge,
Collector<Tuple1<K>> out) {
}
/**
+ * Creates a graph from CSV files.
+ *
+ * Vertices with value are created from a CSV file with 2 fields
+ * Edges with value are created from a CSV file with 3 fields
+ * from Tuple3.
+ *
+ * @param path1 path to a CSV file with the Vertices data.
+ * @param path2 path to a CSV file with the Edges data
+ * @param context the flink execution environment.
+ * @return An instance of {@link org.apache.flink.graph.GraphCsvReader}
, which on calling types() method to specify types of the
+ * Vertex ID, Vertex Value and Edge value returns a Graph
+ */
+
+ public static GraphCsvReader fromCsvReader(String path1, String path2,
ExecutionEnvironment context){
+ return (new GraphCsvReader(path1,path2,context));
--- End diff --
parentheses not needed
> Read edges and vertices from CSV files
> --------------------------------------
>
> Key: FLINK-1520
> URL: https://issues.apache.org/jira/browse/FLINK-1520
> Project: Flink
> Issue Type: New Feature
> Components: Gelly
> Reporter: Vasia Kalavri
> Assignee: Shivani Ghatge
> Priority: Minor
> Labels: easyfix, newbie
>
> Add methods to create Vertex and Edge Datasets directly from CSV file inputs.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
