[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126027#comment-15126027 ] PJ Van Aeken commented on FLINK-2055: - For Flink batch, I think HFileOutputFormat2 is a valid

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126231#comment-15126231 ] PJ Van Aeken commented on FLINK-2055: - Indeed the example that you described uses the native client

[jira] [Comment Edited] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126231#comment-15126231 ] PJ Van Aeken edited comment on FLINK-2055 at 2/1/16 2:11 PM: - Indeed the

[jira] [Comment Edited] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126231#comment-15126231 ] PJ Van Aeken edited comment on FLINK-2055 at 2/1/16 2:22 PM: - Indeed the

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126287#comment-15126287 ] PJ Van Aeken commented on FLINK-2055: - There appears to be a version mismatch which is why we are not

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15119736#comment-15119736 ] PJ Van Aeken commented on FLINK-2055: - What is the latest news on this? Having read through the

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15119821#comment-15119821 ] PJ Van Aeken commented on FLINK-2055: - It appears I was wrong in my first comment. HBase provides two

[jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14964914#comment-14964914 ] PJ Van Aeken commented on FLINK-2033: - Totally forgot about this one, sorry. Yes it's ok now. Gelly

[jira] [Assigned] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged

[ https://issues.apache.org/jira/browse/FLINK-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PJ Van Aeken reassigned FLINK-2277: --- Assignee: PJ Van Aeken In Scala API delta Iterations can not be set to unmanaged

[jira] [Commented] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

[ https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14624724#comment-14624724 ] PJ Van Aeken commented on FLINK-2023: - I am back as of today ;-) Adding the overloaded

[jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580225#comment-14580225 ] PJ Van Aeken commented on FLINK-2033: - If the PR for FLINK-1962 gets accepted, this

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14570601#comment-14570601 ] PJ Van Aeken commented on FLINK-1962: - [~ssc], you can find an implementation to play

[jira] [Assigned] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PJ Van Aeken reassigned FLINK-2033: --- Assignee: PJ Van Aeken Add overloaded methods with explicit TypeInformation parameters to

[jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559213#comment-14559213 ] PJ Van Aeken commented on FLINK-2033: - I will add overloaded methods to the Java API

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559203#comment-14559203 ] PJ Van Aeken commented on FLINK-1962: - Thanks for merging. I would like to get some

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552289#comment-14552289 ] PJ Van Aeken commented on FLINK-1962: - There are no blocking issues at the moment. I

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552501#comment-14552501 ] PJ Van Aeken commented on FLINK-1962: - Ok cool. One more thing perhaps, if you could

[jira] [Commented] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

[ https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547747#comment-14547747 ] PJ Van Aeken commented on FLINK-2023: - So this works, I'm just not entirely sure this

[jira] [Created] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

PJ Van Aeken created FLINK-2033: --- Summary: Add overloaded methods with explicit TypeInformation parameters to Gelly Key: FLINK-2033 URL: https://issues.apache.org/jira/browse/FLINK-2033 Project: Flink

[jira] [Commented] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

[ https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547776#comment-14547776 ] PJ Van Aeken commented on FLINK-2023: - Indeed you are right. In the Java API, keyType

[jira] [Comment Edited] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

[ https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547776#comment-14547776 ] PJ Van Aeken edited comment on FLINK-2023 at 5/18/15 9:46 AM: --

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545102#comment-14545102 ] PJ Van Aeken commented on FLINK-1962: - Don't worry about it. I'm just glad we got it

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545170#comment-14545170 ] PJ Van Aeken commented on FLINK-1962: - I spoke a little bit too soon. The syntactic

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545434#comment-14545434 ] PJ Van Aeken commented on FLINK-1962: - So the fix works for the syntactic sugar. I

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541783#comment-14541783 ] PJ Van Aeken commented on FLINK-1962: - So the line I mentioned is definitely the

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14539441#comment-14539441 ] PJ Van Aeken commented on FLINK-1962: - Is there a specific reason why Flink has custom

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14539558#comment-14539558 ] PJ Van Aeken commented on FLINK-1962: - I suspect there is some IDE shannanigans going

[jira] [Comment Edited] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537797#comment-14537797 ] PJ Van Aeken edited comment on FLINK-1962 at 5/11/15 10:33 AM:

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537797#comment-14537797 ] PJ Van Aeken commented on FLINK-1962: - The combination of both pull requests did the

[jira] [Comment Edited] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537797#comment-14537797 ] PJ Van Aeken edited comment on FLINK-1962 at 5/11/15 11:30 AM:

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532224#comment-14532224 ] PJ Van Aeken commented on FLINK-1962: - If there are no problems, feel free to push it.

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530225#comment-14530225 ] PJ Van Aeken commented on FLINK-1962: - I did a new commit to my personal Github,

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530317#comment-14530317 ] PJ Van Aeken commented on FLINK-1962: - Update : Using implicit conversions, I managed

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530353#comment-14530353 ] PJ Van Aeken commented on FLINK-1962: - [~StephanEwen] I think that removing the

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526329#comment-14526329 ] PJ Van Aeken commented on FLINK-1962: - I am working on one right now which implements

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526402#comment-14526402 ] PJ Van Aeken commented on FLINK-1962: - Actually I am currently building the Scala