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

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

[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&focusedCommentId=15126231#comment-15126231 ] PJ Van Aeken edited comment on FLINK-2055 at 2/1/16 2:22 PM: -

[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&focusedCommentId=15126231#comment-15126231 ] PJ Van Aeken edited comment on FLINK-2055 at 2/1/16 2:11 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126231#comment-15126231 ] PJ Van Aeken commented on FLINK-2055: - Indeed the example that you described uses 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&focusedCommentId=15126027#comment-15126027 ] PJ Van Aeken commented on FLINK-2055: - For Flink batch, I think HFileOutputFormat2 is

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

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

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

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

[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&focusedCommentId=14964914#comment-14964914 ] PJ Van Aeken commented on FLINK-2033: - Totally forgot about this one, sorry. Yes it's

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14580225#comment-14580225 ] PJ Van Aeken commented on FLINK-2033: - If the PR for FLINK-1962 gets accepted, this ca

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

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

[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&focusedCommentId=14559213#comment-14559213 ] PJ Van Aeken commented on FLINK-2033: - I will add overloaded methods to the Java API o

[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 G

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

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

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

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

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

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

[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-tabpanel&focusedCommentId=14547776#comment-14547776 ] PJ Van Aeken edited comment on FLINK-2023 at 5/18/15 9:46 AM: --

[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-tabpanel&focusedCommentId=14547776#comment-14547776 ] PJ Van Aeken commented on FLINK-2023: - Indeed you are right. In the Java API, keyType

[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-tabpanel&focusedCommentId=14547747#comment-14547747 ] PJ Van Aeken commented on FLINK-2023: - So this works, I'm just not entirely sure this

[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-tabpanel&focusedCommentId=14547666#comment-14547666 ] PJ Van Aeken commented on FLINK-2023: - The thing is that the Scala DataSet API reimple

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545217#comment-14545217 ] PJ Van Aeken commented on FLINK-1962: - https://github.com/PieterJanVanAeken/flink/blob

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541635#comment-14541635 ] PJ Van Aeken commented on FLINK-1962: - I suspect the casting in this line does not cha

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14539441#comment-14539441 ] PJ Van Aeken edited comment on FLINK-1962 at 5/12/15 7: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-tabpanel&focusedCommentId=14539441#comment-14539441 ] PJ Van Aeken commented on FLINK-1962: - Is there a specific reason why Flink has custom

[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-tabpanel&focusedCommentId=14537797#comment-14537797 ] PJ Van Aeken edited comment on FLINK-1962 at 5/11/15 11:30 AM: -

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14537797#comment-14537797 ] PJ Van Aeken commented on FLINK-1962: - The combination of both pull requests did the t

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14530519#comment-14530519 ] PJ Van Aeken commented on FLINK-1962: - Here's what I have so far in terms of wrapping

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14530225#comment-14530225 ] PJ Van Aeken commented on FLINK-1962: - I did a new commit to my personal Github, whic

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14526557#comment-14526557 ] PJ Van Aeken commented on FLINK-1962: - In terms of maintainability, you are undoubtedl

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

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

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

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