Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r124015120
--- Diff:
examples/streaming/state/src/main/scala/org/apache/gearpump/streaming/examples/state/refactor/SumProcessor.scala
---
@@ -0,0 +1,92
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r124014378
--- Diff:
examples/streaming/state/src/main/scala/org/apache/gearpump/streaming/examples/state/refactor/SumProcessor.scala
---
@@ -0,0 +1,92
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429407
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429421
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428717
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428767
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428739
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428752
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429442
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123430323
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/heap/HeapStateInternals.scala
---
@@ -0,0 +1,316 @@
+/*
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429491
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123430243
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/InMemoryGlobalStateInternals.scala
---
@@ -0,0 +1,276 @@
GitHub user yanghua opened a pull request:
https://github.com/apache/incubator-gearpump/pull/190
[Gearpump 311] refactor state management
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the commit message
13 matches
Mail list logo
