-
Notifications
You must be signed in to change notification settings - Fork 13k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-1520] [gelly] Create a Graph from CSV files #1149
Conversation
.map(new MapFunction<Tuple2<K, K>, Tuple3<K, K, NullValue>>() { | ||
|
||
public Tuple3<K, K, NullValue> map(Tuple2<K, K> edge) { | ||
return new Tuple3<K, K, NullValue>(edge.f0, edge.f1, NullValue.getInstance()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Shouldn't you have a forwarded fields annotation here?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
good catch! thnx!
Hi @vasia, As you said, I already reviewed this :P. I left a couple of comments inline. Please reverify the forwarded fields annotations. If you put them there for one mapper, add them for the others too. Apart from that, it's good to merge. |
Thanks @andralungu! I'll address your comments and merge later. |
…a new file for tests. Made appropriate changes in gelly_guide.md
…om CSV input, with and without vertex/edge values. Changes the examples and the tests accordingly.
… the graph csv reader This squashes the following commits: [FLINK-1520] [gelly] add named types methods for reading a Graph from CSV input, with and without vertex/edge values. Change the examples and the tests accordingly. [FLINK-1520] [gelly] corrections in Javadocs; updated documentation This closes apache#1149
… the graph csv reader This squashes the following commits: [FLINK-1520] [gelly] add named types methods for reading a Graph from CSV input, with and without vertex/edge values. Change the examples and the tests accordingly. [FLINK-1520] [gelly] corrections in Javadocs; updated documentation This closes apache#1149
… the graph csv reader This squashes the following commits: [FLINK-1520] [gelly] add named types methods for reading a Graph from CSV input, with and without vertex/edge values. Change the examples and the tests accordingly. [FLINK-1520] [gelly] corrections in Javadocs; updated documentation This closes apache#1149
This builds on @shghatge's work in #847.
I addressed the remaining issues, rebased, and edited the docs.
@andralungu, you've already reviewed this, but if you could give it one more look, that'd be great :)
Thanks!