Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-core/pull/452
---
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 davidyan74 opened a pull request:
https://github.com/apache/apex-core/pull/452
APEXCORE-618 #resolve Added com.sun.jersey.client.apache4.ApacheHttpCâ¦
â¦lient4Handler.class in the bundled jars on app launch
You can merge this pull request into a Git repository by
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-core/pull/427
APEXCORE-585 #resolve do not try to calculate latency if the first wiâ¦
â¦ndow has not complete
@vrozov please review and merge
You can merge this pull request into a Git
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/519
APEXMALHAR-2362 #resolve clearing the removedSets at endWindow in
SpillableSetMultimapImpl
@brightchen please review and merge
You can merge this pull request into a Git repository by
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/517
APEXMALHAR-2343 Count fix and accumulation input parameter type change
@brightchen @chinmaykolhatkar @siyuanh Please have a look
You can merge this pull request into a Git repository by
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/516
REVIEW ONLY: Purging time buckets in WindowedStorage
@siyuanh Please review. This is based on the other PR you have #503. I'll
add unit test for purging if this looks good.
You can
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-core/pull/336
---
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 davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/465
REVIEW ONLY: changes to serde for managed state and spillable ds
@brightchen @tweise @siyuanh please review
You can merge this pull request into a Git repository by running:
$ git
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/462
APEXMALHAR-2305 changed javadoc of SessionWindows to reflect the implâ¦
â¦ementation change of SessionWindows
@siyuanh please merge
You can merge this pull request into a Git
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/460
APEXMALHAR-2305 updated documentation on SessionWindow to reflect theâ¦
⦠new proto-session window semantics
@siyuanh please merge
You can merge this pull request into a Git
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/458
APEXMALHAR-2305 #resolve Mirror the proto-session window behavior desâ¦
â¦cribed in the streaming 102 blog
@siyuanh please review and merge
You can merge this pull request into
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/450
APEXMALHAR-2282 First iteration for windowed operator documentation
@tweise please review
You can merge this pull request into a Git repository by running:
$ git pull https
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/449
---
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
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/449
APEXMALHAR-2280 First iteration for windowed operator documentation
@tweise please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-core/pull/409
APEXCORE-552 #resolve added support for application tags
@PramodSSImmaneni please merge
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-core/pull/404
---
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 davidyan74 reopened a pull request:
https://github.com/apache/apex-core/pull/404
APEXCORE-536 #resolve Upgrade Hadoop dependency version from 2.2.0 to 2.6.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/davidyan74
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/442
APEXMALHAR-2280 #resolve added package-info.java to denote interface â¦
â¦stability for all classes that belong to event window processing
@siyuanh please merge
You can merge
GitHub user davidyan74 reopened a pull request:
https://github.com/apache/apex-core/pull/404
APEXCORE-536 #resolve Upgrade Hadoop dependency version from 2.2.0 to 2.6.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/davidyan74
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-core/pull/404
---
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 davidyan74 reopened a pull request:
https://github.com/apache/apex-core/pull/404
APEXCORE-536 #resolve Upgrade Hadoop dependency version from 2.2.0 to 2.6.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/davidyan74
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-core/pull/404
---
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 davidyan74 opened a pull request:
https://github.com/apache/apex-core/pull/404
APEXCORE-536 #resolve Upgrade Hadoop dependency version from 2.2.0 to 2.6.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/davidyan74
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-core/pull/401
APEXCORE-544 #resolve fixed latency calculation when the upstream heartbeat
is processed later than the downstream for a particular window
@tweise please review. this fixes the problem with
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/436
APEXMALHAR-2273 #resolve do not fire retraction trigger if retractionâ¦
⦠value is same as current value and fireOnlyUpdatedPanes is true
@siyuanh please merge
You can merge
GitHub user davidyan74 reopened a pull request:
https://github.com/apache/apex-malhar/pull/431
APEXMALHAR-2267 #resolve renamed spillable data structures to remove the
word "Byte"
@siyuanh please merge
You can merge this pull request into a Git repository by running:
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/431
---
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
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/431
APEXMALHAR-2267 #resolve renamed spillable data structures to remove the
word "Byte"
@siyuanh please merge
You can merge this pull request into a Git repository by running:
GitHub user davidyan74 reopened a pull request:
https://github.com/apache/apex-malhar/pull/424
APEXMALHAR-2130 Spillable implementation for WindowedOperator
@tweise @brightchen @siyuanh Please review and merge
You can merge this pull request into a Git repository by running
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/424
---
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
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/424
APEXMALHAR-2130 Spillable implementation for WindowedOperator
@tweise @brightchen @siyuanh Please review and merge
You can merge this pull request into a Git repository by running
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/345
---
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
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/377
---
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
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/399
---
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
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/405
---
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
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/418
APEXMALHAR-2247 #resolve Added iteration feature in SpillableArrayListImpl
and generalize SerdeListSlice to SerdeCollectionSlice
@siyuanh please review and merge
You can merge this pull
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/417
APEXMALHAR-2246 #resolve use Slice instead of byte[] in the underlying map
of SpillableByteArrayListMultimapImpl
@siyuanh Please review and merge
You can merge this pull request into a Git
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/416
APEXMALHAR-2245 #resolve Add the key in removedKeys even if the key does
not appear in the cache
@siyuanh Please review and merge
You can merge this pull request into a Git repository by
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/408
APEXMALHAR-2130 Added SpillableSet and SpillableSetMultimap implementations
@tweise @siyuanh @ilooner please review
You can merge this pull request into a Git repository by running
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/407
APEXMALHAR-2130 WindowStorage interface changes in preparation of incâ¦
â¦orporating spillable data structures
@siyuanh please review and merge
@tweise @ShunxinLu FYI
You can
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/405
APEXMALHAR-2130 #resolve Added a spillable map that takes two keys with
support of iterating through all entries with a given first key
@siyuanh @tweise @ilooner Please review. This is
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/403
APEXMALHAR-2229 #resolve Added peek and hasNext methods to FileAccess
interface
@tweise please review
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/399
REVIEW ONLY: exposing seeking and iterating of TFile in ManagedState
@chandnisingh @ilooner @tweise @siyuanh Feedback is appreciated. I'll add
the missing unit tests later so hold
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/391
APEXMALHAR-2215 #resolve replace Gutenberg content with Apache web siâ¦
â¦te content because of license concern
@tweise please review
You can merge this pull request into a Git
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/377
*Review Only* APEXMALHAR-2192 Added some spillable method implementations
This is not ready for merge yet. Please do not comment on missing unit
tests, code style, debug statements, etc
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73941677
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/WindowListener.java
---
@@ -0,0 +1,39 @@
+/**
+ * Licensed to the
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73609127
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -180,4 +188,40 @@ public void
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73589696
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -180,4 +188,40 @@ public void
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73583092
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -53,16 +56,16 @@
private static File configFile
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73582886
--- Diff:
engine/src/test/resources/testConfigPackage/testConfigPackageSrc/app/testApp.json
---
@@ -0,0 +1 @@
+{"displayName"
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73582758
--- Diff:
engine/src/test/resources/testAppPackage/mydtapp/src/main/resources/com/example/mydtapp/Application/ExtRes.html
---
@@ -0,0 +1,21
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73582496
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -126,10 +130,14 @@ public void testLaunchAppPackagePropertyPrecedence
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73582122
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -103,8 +107,8 @@ public static void finished()
public void
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73581887
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -180,4 +188,40 @@ public void
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73581539
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -180,4 +188,40 @@ public void
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73581176
--- Diff: engine/src/main/java/com/datatorrent/stram/client/AppPackage.java
---
@@ -49,6 +49,8 @@
import net.lingala.zip4j.exception.ZipException
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73580877
--- Diff:
apex-conf-archetype/src/main/resources/archetype-resources/pom.xml ---
@@ -25,6 +25,7 @@
1..
classpath
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73079896
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableStateStore.java
---
@@ -0,0 +1,33 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73079738
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableStateStore.java
---
@@ -0,0 +1,33 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73075544
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableStateStore.java
---
@@ -0,0 +1,33 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73075245
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableStateStore.java
---
@@ -0,0 +1,33 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73073791
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,292
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73073399
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableStateStore.java
---
@@ -0,0 +1,33 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73031805
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableComplexComponentImpl.java
---
@@ -0,0 +1,202
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032806
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/utils/serde/SerdeListSliceTest.java
---
@@ -16,29 +16,33 @@
* specific language
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032779
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/inmem/InMemorySpillableStateStoreTest.java
---
@@ -0,0 +1,63
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032752
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/WindowBoundedMapCacheTest.java
---
@@ -0,0 +1,119
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032644
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableComplexComponentImplTest.java
---
@@ -0,0 +1,88
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032673
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableTestUtils.java
---
@@ -0,0 +1,134 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032713
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/TimeBasedPriorityQueueTest.java
---
@@ -0,0 +1,134
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032590
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteMapImplTest.java
---
@@ -0,0 +1,487
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032473
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableArrayListImplTest.java
---
@@ -0,0 +1,597
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032527
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImplTest.java
---
@@ -0,0 +1,344
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032414
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/state/spillable/SequentialSpillableIdentifierGeneratorTest.java
---
@@ -0,0 +1,128
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032354
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SliceUtils.java ---
@@ -0,0 +1,70 @@
+/**
+ * Licensed to the Apache
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032285
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerdeStringSlice.java
---
@@ -0,0 +1,51 @@
+/**
+ * Licensed to the
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032245
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerdeListSlice.java
---
@@ -0,0 +1,103 @@
+/**
+ * Licensed to the
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032214
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerdeIntSlice.java
---
@@ -0,0 +1,50 @@
+/**
+ * Licensed to the
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032134
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruByteArraySliceSerde.java
---
@@ -0,0 +1,55
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032033
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/inmem/InMemSpillableStateStore.java
---
@@ -0,0 +1,116
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032183
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruSliceSerde.java
---
@@ -16,30 +16,32 @@
* specific language
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73032099
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/managed/ManagedStateSpillableStateStore.java
---
@@ -16,29 +16,19
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73031950
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/WindowBoundedMapCache.java
---
@@ -0,0 +1,119
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73031909
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/TimeBasedPriorityQueue.java
---
@@ -0,0 +1,128 @@
+package
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73031870
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableStateStore.java
---
@@ -0,0 +1,33 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73031644
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SequentialSpillableIdentifierGenerator.java
---
@@ -0,0 +1,78
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73031608
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteMapImpl.java
---
@@ -0,0 +1,237 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r73031476
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,292
GitHub user davidyan74 reopened a pull request:
https://github.com/apache/apex-malhar/pull/345
APEXMALHAR-2130 REVIEW ONLY (WindowedOperator): incorporating Spillable
data structures
You can merge this pull request into a Git repository by running:
$ git pull https
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/345
---
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
Github user davidyan74 commented on the issue:
https://github.com/apache/apex-core/pull/363
Looks good to me. Will merge once it's squashed
---
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
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72670575
--- Diff:
engine/src/test/resources/testOperators/src/main/java/org/apache/apex/test/DevNull.java
---
@@ -16,25 +16,19 @@
* specific language
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72670501
--- Diff:
engine/src/test/resources/testOperators/src/main/java/org/apache/apex/test/RandomGen.java
---
@@ -16,24 +16,44 @@
* specific language
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72670240
--- Diff:
engine/src/test/java/com/datatorrent/stram/support/StramTestSupport.java ---
@@ -157,21 +160,42 @@ public static void
waitForWindowComplete
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72670019
--- Diff:
engine/src/main/java/com/datatorrent/stram/client/ConfigPackage.java ---
@@ -71,6 +72,7 @@
private final Map properties = new
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72669919
--- Diff: engine/src/main/java/com/datatorrent/stram/cli/ApexCli.java ---
@@ -3850,6 +3908,9 @@ private Option add(Option opt)
final Option
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/345#discussion_r72521168
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/window/SpillableWindowedStorageTest.java
---
@@ -0,0 +1,122 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/345#discussion_r72494611
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedPlainStorage.java
---
@@ -0,0 +1,188
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/345#discussion_r72309272
--- Diff:
library/src/test/java/org/apache/apex/malhar/lib/window/SpillableWindowedStorageTest.java
---
@@ -0,0 +1,122 @@
+/**
+ * Licensed
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r72308835
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,262
1 - 100 of 148 matches
Mail list logo
