GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/503
APEXMALHAR-2301 Refactor Timebucketassigner
Refactor timebucketassigner to add a simple timebucket assigner and change
the bucket metadata datastructure from array to map to handle unbounded
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/495
APEXMALHAR-2271 Implement a multimap with time extract from value
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/siyuanh/apex-malhar
Github user siyuanh closed the pull request at:
https://github.com/apache/apex-malhar/pull/461
---
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, or if the feature
GitHub user siyuanh reopened a pull request:
https://github.com/apache/apex-malhar/pull/461
APEXMALHAR-2203 support control tuple and watermark in high-level API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/siyuanh/apex
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/413
APEXMALHAR-2230 simplify the kafka input operator test
OK, this change doesn't fix the intermittent error directly, but it
simplifies the test to make it easier to debug in the future
You can
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/394
APEXMALHAR-2142 #comment Fix content in test resource file
FYI
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/siyuanh/apex-malhar master
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/387
APEXMALHAR-2199 fix chroot path for 0.8 kafka input operator support
Simplify the zookeeper url parser to use whatever user specified and
support chroot path
You can merge this pull request
GitHub user siyuanh reopened a pull request:
https://github.com/apache/apex-malhar/pull/365
APEXMALHAR-2028 #resolve #comment add stderr for ConsoleOperator
Add stderr to ConsleOutputOperator
You can merge this pull request into a Git repository by running:
$ git pull https
Github user siyuanh closed the pull request at:
https://github.com/apache/apex-malhar/pull/365
---
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, or if the feature
GitHub user siyuanh reopened a pull request:
https://github.com/apache/apex-malhar/pull/365
APEXMALHAR-2028 #resolve #comment add stderr for ConsoleOperator
Add stderr to ConsleOutputOperator
You can merge this pull request into a Git repository by running:
$ git pull https
Github user siyuanh closed the pull request at:
https://github.com/apache/apex-malhar/pull/365
---
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, or if the feature
GitHub user siyuanh reopened a pull request:
https://github.com/apache/apex-malhar/pull/339
APEXMALHAR-2142 Windowed Stream First Implementation
This is for review only, please ignore all checkstyle violations, format
issue etc.
For windowed operator changes, refer
Github user siyuanh closed the pull request at:
https://github.com/apache/apex-malhar/pull/339
---
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, or if the feature
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/365
APEXMALHAR-2028 #resolve #comment add stderr for ConsoleOperator
Add stderr to ConsleOutputOperator
You can merge this pull request into a Git repository by running:
$ git pull https
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/351#discussion_r73811155
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
---
@@ -834,17 +840,16 @@ private boolean
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/351#discussion_r73647730
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
---
@@ -188,6 +188,8 @@
@Min(1)
private int
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71914879
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/341
APEXMALHAR-2148 #resolve #comment Skip some noisy loggings from kafka
Skip some noisy loggings from kafka
You can merge this pull request into a Git repository by running:
$ git pull
Github user siyuanh closed the pull request at:
https://github.com/apache/apex-malhar/pull/327
---
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, or if the feature
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r70109068
--- Diff: kafka/src/test/resources/log4j.properties ---
@@ -47,3 +47,4 @@ log4j.logger.org.apache.apex=INFO
log4j.logger.org.apacke.kafka=WARN
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/321#discussion_r68420530
--- Diff:
kafka/src/test/java/org/apache/apex/malhar/kafka/KafkaInputOperatorTest.java ---
@@ -264,49 +336,57 @@ public void testInputOperator(boolean
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/327
Review-Only WindowedStream API
This is for review only, please ignore all checkstyle violations, format
issue etc.
For windowed operator changes, refer to
https://github.com/apache
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68180895
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68180501
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68179972
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68179198
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68179058
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68178863
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/323#discussion_r67949068
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
---
@@ -203,6 +204,14 @@ public
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/321#discussion_r67780118
--- Diff: kafka/pom.xml ---
@@ -198,7 +198,7 @@
org.apache.kafka
kafka_2.11
- 0.9.0.0
--- End diff
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/321#discussion_r67774397
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -129,6 +130,11 @@ public void
emitImmediately(Map
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/321#discussion_r67774142
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -74,7 +75,7 @@
private static final Logger
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/321#discussion_r67770746
--- Diff: kafka/pom.xml ---
@@ -198,7 +198,7 @@
org.apache.kafka
kafka_2.11
- 0.9.0.0
--- End diff
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/320#discussion_r67769627
--- Diff: kafka/pom.xml ---
@@ -198,7 +198,7 @@
org.apache.kafka
kafka_2.11
- 0.9.0.0
+ 0.9.0.1
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/323#discussion_r67717267
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
---
@@ -203,6 +204,14 @@ public
GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/316
High-level WindowedStream API (Review only)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/siyuanh/incubator-apex-malhar stream
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/338#discussion_r65421945
--- Diff: engine/src/main/java/com/datatorrent/stram/webapp/TypeGraph.java
---
@@ -355,7 +356,8 @@ public int size()
}
Set
37 matches
Mail list logo
