Github user darionyaphet closed the pull request at:
https://github.com/apache/incubator-gearpump/pull/228
---
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/228
[GEARPUMP-351] Support executor number in submit
When `ClientContext` submit application to cluster and must add a argument
executors to specifies the executor number use
Github user darionyaphet commented on the issue:
https://github.com/apache/incubator-gearpump/pull/200
maybe not only *gearpump-core* and *gearpump-streaming* should change to
**compile** .
---
If your project is set up for it, you can reply to this email and have your
reply appear
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/199
[GEARPUMP-328] FetchThread fetchSleepMS from Int to Long
currently *KafkaConfig.FETCH_SLEEP_MS_CONFIG* is a INT parameter , move it
into a LONG parameter is better .
You can
Github user darionyaphet commented on the issue:
https://github.com/apache/incubator-gearpump/pull/199
cc @manuzhang Could you make a review when you have time. thanks ~~
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/191
[GEARPUMP-319] Support Sorted Set in Redis
Sorted Set is similar with Set in Redis with unique values .
Each element storage in Sorted Set is associated with a score
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/125
[GEARPUMP-256] Camel-Case as variable name
[Camel-Case as variable
name](https://issues.apache.org/jira/browse/GEARPUMP-256) HBaseSink's naming
and using Camel-Case
Github user darionyaphet commented on the issue:
https://github.com/apache/incubator-gearpump/pull/102
thanks @huafengw
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/102
[GEARPUMP-228] Message's timestamp should be current time stamp
[GEARPUMP-228 Message's timestamp should be current time
stamp](https://issues.apache.org/jira/browse/GEARPUMP-228
Github user darionyaphet closed the pull request at:
https://github.com/apache/incubator-gearpump/pull/89
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/89
GEARPUMP-216 Support Delete and Increment in HBaseSink
[GEARPUMP-216](https://issues.apache.org/jira/browse/GEARPUMP-216) Support
Delete and Increment in HBase Sink.
You can
Github user darionyaphet commented on the issue:
https://github.com/apache/incubator-gearpump/pull/11
@kkasravi @manuzhang `RedisStorage` maybe need more discuss so I have
remove it .
After we have a discuss , I will repush it :)
---
If your project is set up for it, you
Github user darionyaphet commented on the issue:
https://github.com/apache/incubator-gearpump/pull/52
@manuzhang I found storm 1.X have add some function about Blob and
LogConfig . I'm miss it and working .
---
If your project is set up for it, you can reply to this email
Github user darionyaphet commented on the issue:
https://github.com/apache/incubator-gearpump/pull/52
@manuzhang when I try to implement Nimbus method , I found some of them not
implement will throw a UnsupportedOperationException . I want to know which
command we are not support
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/52
[GEARPUMP-152] Upgrade Storm support to 1.0.x
[GEARPUMP-152](https://issues.apache.org/jira/browse/GEARPUMP-152)
Storm 1.0.0 has been released with a lot of changes. We need
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/51
[GEARPUMP-166] Rename sumByValue to sumByKey
[GEARPUMP-166](https://issues.apache.org/jira/browse/GEARPUMP-166)
Streaming org.apache.gearpump.streaming.dsl.Stream have
Github user darionyaphet commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/11#discussion_r65502913
--- Diff:
experiments/redis/src/main/scala/org/apache/gearpump/streaming/redis/RedisMessage.scala
---
@@ -0,0 +1,65
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/20#issuecomment-222503486
@huafengw @manuzhang Could add some comment about this functions ? This
functions is very confuse to others .
---
If your project is set up
Github user darionyaphet closed the pull request at:
https://github.com/apache/incubator-gearpump/pull/20
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user darionyaphet commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/11#discussion_r63819150
--- Diff: project/BuildExample.scala ---
@@ -229,4 +229,20 @@ object BuildExample extends sbt.Build
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/20#issuecomment-219914766
@manuzhang but the method was decorate with `private` .
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/20#issuecomment-219773664
conflicts ?? I can't found any conflicts !
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/20
fix GEARPUMP-141 , remove useless method
[GEARPUMP-141](https://issues.apache.org/jira/browse/GEARPUMP-141)
In external-hbase module , writeObject and readObject seems never used
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/19
fix GEARPUMP-141 , remove useless method
[GEARPUMP-141](https://issues.apache.org/jira/browse/GEARPUMP-141)
In external-hbase module , writeObject and readObject seems
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/11#issuecomment-219225271
# Sorry to reply it with so long .
@manuzhang @huafengw redis examples class name have rename to
`RedisSourceSinkExample
Github user darionyaphet commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/11#discussion_r63278015
--- Diff:
examples/streaming/redis/src/main/scala/org/apache/gearpump/streaming/example/redis/RedisSourceSink.scala
---
@@ -0,0 +1,67
Github user darionyaphet commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/11#discussion_r62852676
--- Diff:
examples/streaming/redis/src/main/scala/org/apache/gearpump/streaming/example/redis/RedisSourceSink.scala
---
@@ -0,0 +1,67
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/11#issuecomment-218355383
Hi @huafengw sure I will rename packages from io.gearpump to
org.apache.gearpump :D
---
If your project is set up for it, you can reply to this email
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/7#issuecomment-217859410
Hi @manuzhang why change datasource API from `List[Message]` to `Message`
?
---
If your project is set up for it, you can reply to this email
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/13#issuecomment-217900186
@manuzhang When I using some processors to build a DAG , it's just to
describe how to process the input stream , parallelism is the attribute
Github user darionyaphet commented on the pull request:
https://github.com/apache/incubator-gearpump/pull/11#issuecomment-217726672
@manuzhang I have add license headers .
@kkasravi I will add some unit tests .
thank you :)
---
If your project is set up
GitHub user darionyaphet opened a pull request:
https://github.com/apache/incubator-gearpump/pull/12
fix #121 DataSourceProcessor and DataSinkProcessor default parallelism
Set DataSourceProcessor and DataSinkProcessor's default parallelism value
to 1.
When user startup
Github user darionyaphet closed the pull request at:
https://github.com/apache/incubator-gearpump/pull/10
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
33 matches
Mail list logo
