Repository: incubator-apex-core
Updated Branches:
refs/heads/master b12e8b01c -> ae46b47cd
APEXCORE-463 : fixed condtion to include modules without input port
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit:
Merge branch 'APEXMALHAR-2121-kafka-emit-update' of
github.com:DT-Priyanka/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/719cf952
Tree:
Repository: apex-malhar
Updated Branches:
refs/heads/master 883153fad -> 67b84dda4
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/7a77274a/library/src/test/resources/wordcount.txt
--
diff --git
APEXMALHAR-2085 windowed operator interfaces and implementation
addressing PR comments
Added trigger unit tests
Fixed sliding window bug, added unit tests
Fixed session window bug; added more unit tests
Gives window a chance to trigger before purging because of lateness
added more unit tests
Repository: apex-malhar
Updated Branches:
refs/heads/master 37cb58484 -> 3316d6a78
APEXMALHAR-2168 #resolve #comment Bug fixed in JdbcPOJOInputOperator. Modified
JdbcOperatorTest.
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit:
Merge branch 'APEXMALHAR-2168' of github.com:ShunxinLu/apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/3316d6a7
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/3316d6a7
Diff:
Repository: apex-malhar
Updated Branches:
refs/heads/master c528980a9 -> 170072533
APEXMALHAR-2154 Update the Kafka Input Operator to use
CheckpointNotificationListener
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit:
Merge branch 'APEXMALHAR-2154' of
https://github.com/chaithu14/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/17007253
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/17007253
APEXMALHAR-2180 Kafka partitions to be unchanged in the case of dynamic
scalling of ONE_TO_MANY strategy
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/37fa01e7
Tree:
Merge branch 'APEXMALHAR-2169-Kafka-DP-many' of
https://github.com/chaithu14/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/ef42c52a
Tree:
Repository: apex-malhar
Updated Branches:
refs/heads/master b811e3356 -> 9f9da0ee1
APEXMALHAR-2130 WindowStorage interface changes in preparation of incorporating
spillable data structures
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit:
Merge branch 'APEXMALHAR-2280' of
https://github.com/davidyan74/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/791383bd
Tree:
Merge branch 'master' of github.com:apache/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/efe58763
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/efe58763
Diff:
Merge branch 'APEXMALHAR-2247' of
https://github.com/davidyan74/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/0a924ada
Tree:
Repository: apex-malhar
Updated Branches:
refs/heads/master d713e521e -> 7ac4a0ed7
APEXMALHAR-2248 #resolve Added interfaces and implementations of SpillableSet
and SpillableSetMultimap
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit:
Merge branch 'APEXMALHAR-2134-NP-LB' of
https://github.com/chaithu14/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/da3b4317
Tree:
Repository: apex-malhar
Updated Branches:
refs/heads/master c19c80d88 -> f5f1943d2
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/f5f1943d/library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImplTest.java
Repository: apex-malhar
Updated Branches:
refs/heads/master 6ddefd02a -> c89e63621
fixes two issues - pick the metadata consumer properties and setting the
consumer properties from Properties.xml for kafka inputoperator not working
added test case
Removed trailing spaces
Removed unused
APEXMALHAR-2343 #resolve #comment Count Accumulation should only increase one
for each tuple
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/e4763344
Tree:
19 matches
Mail list logo