[jira] [Created] (BEAM-1946) Add IO module for restful api
JiJun Tang created BEAM-1946: Summary: Add IO module for restful api Key: BEAM-1946 URL: https://issues.apache.org/jira/browse/BEAM-1946 Project: Beam Issue Type: New Feature Components: sdk-java-extensions Reporter: JiJun Tang Assignee: Davor Bonaci Create a RestIO for read or write data by resful api. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BEAM-1946) Add IO module for restful api
[ https://issues.apache.org/jira/browse/BEAM-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980604#comment-15980604 ] JiJun Tang commented on BEAM-1946: -- Another example: http://sberyozkin.blogspot.com/2016/09/cxf-jax-rs-20-perfect-http-spark.html > Add IO module for restful api > - > > Key: BEAM-1946 > URL: https://issues.apache.org/jira/browse/BEAM-1946 > Project: Beam > Issue Type: New Feature > Components: sdk-java-extensions >Reporter: JiJun Tang >Assignee: Jean-Baptiste Onofré > Labels: IO, features, restful > > Create a RestIO for read or write data by resful api. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (BEAM-1664) Support Kafka0.8.x client in KakaIO
JiJun Tang created BEAM-1664: Summary: Support Kafka0.8.x client in KakaIO Key: BEAM-1664 URL: https://issues.apache.org/jira/browse/BEAM-1664 Project: Beam Issue Type: Improvement Components: sdk-java-extensions Reporter: JiJun Tang Assignee: Davor Bonaci kafka-0.8 is not supported yet, these's a big change from 0.8 to 0.9. So we need to create a specific KafkaIO moudle for 0.8. After complete this moudle,we will consider to extract common code to kafkaio-common moudle. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Updated] (BEAM-1664) Support Kafka0.8.x client in KakaIO
[ https://issues.apache.org/jira/browse/BEAM-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JiJun Tang updated BEAM-1664: - Description: Kafka-0.8 is not supported yet, these's a big change from 0.8 to 0.9. So we need to create a specific KafkaIO moudle for 0.8. After complete this moudle,we will consider to extract common code to kafkaio-common moudle. (was: kafka-0.8 is not supported yet, these's a big change from 0.8 to 0.9. So we need to create a specific KafkaIO moudle for 0.8. After complete this moudle,we will consider to extract common code to kafkaio-common moudle.) > Support Kafka0.8.x client in KakaIO > > > Key: BEAM-1664 > URL: https://issues.apache.org/jira/browse/BEAM-1664 > Project: Beam > Issue Type: Improvement > Components: sdk-java-extensions >Reporter: JiJun Tang >Assignee: Davor Bonaci > > Kafka-0.8 is not supported yet, these's a big change from 0.8 to 0.9. So we > need to create a specific KafkaIO moudle for 0.8. After complete this > moudle,we will consider to extract common code to kafkaio-common moudle. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BEAM-1899) JStorm runner
[ https://issues.apache.org/jira/browse/BEAM-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960065#comment-15960065 ] JiJun Tang commented on BEAM-1899: -- Hello, An Apache Storm runner or JStrom runner for Apache Beam would be great for us who are quite used to using Storm for very fast processing. For now, we are using Apache Eagle which is powered by Strom.If Apache JStorm runner were already available, then we could rewrite Apache Eagle code by Beam API. Migrate from Apache Storm to Apache Beam will be helpful to the community. > JStorm runner > - > > Key: BEAM-1899 > URL: https://issues.apache.org/jira/browse/BEAM-1899 > Project: Beam > Issue Type: New Feature > Components: runner-ideas >Reporter: Pei He >Assignee: Pei He > > Implement a runner for JStorm https://github.com/alibaba/jstorm -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Comment Edited] (BEAM-1899) JStorm runner
[ https://issues.apache.org/jira/browse/BEAM-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960065#comment-15960065 ] JiJun Tang edited comment on BEAM-1899 at 4/7/17 1:18 AM: -- Hello, An Apache Storm runner or JStorm runner for Apache Beam would be great for us who are quite used to using Storm for very fast processing. For now, we are using Apache Eagle which is powered by Storm.If Apache JStorm runner were already available, then we could rewrite Apache Eagle code by Beam API. Migrate from Apache Storm to Apache Beam will be helpful to the community. was (Author: r7raul): Hello, An Apache Storm runner or JStrom runner for Apache Beam would be great for us who are quite used to using Storm for very fast processing. For now, we are using Apache Eagle which is powered by Strom.If Apache JStorm runner were already available, then we could rewrite Apache Eagle code by Beam API. Migrate from Apache Storm to Apache Beam will be helpful to the community. > JStorm runner > - > > Key: BEAM-1899 > URL: https://issues.apache.org/jira/browse/BEAM-1899 > Project: Beam > Issue Type: New Feature > Components: runner-ideas >Reporter: Pei He >Assignee: Pei He > > Implement a runner for JStorm https://github.com/alibaba/jstorm -- This message was sent by Atlassian JIRA (v6.3.15#6346)
