[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612537#comment-14612537
]
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_r33823849
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java
---
@@ -52,16 +72,13 @@ public void testWithDoubleValueMapper() throws
Exception {
Graph<Long, Double, Long> graph =
Graph.fromDataSet(TestGraphUtils.getLongLongEdgeData(env),
new AssignDoubleValueMapper(), env);
- DataSet<Vertex<Long,Double>> data = graph.getVertices();
- List<Vertex<Long,Double>> result= data.collect();
-
+ graph.getVertices().writeAsCsv(resultPath);
--- End diff --
Same here.. We changed the tests to use `collect()` instead of files in
#863. Please don't change it back ;)
> 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)
