GitHub user vjagadish1989 opened a pull request:
https://github.com/apache/samza/pull/18
Add a basic implementation of a Session Window.
Simplifying assumptions:
- Aggregations are done based on system time. (So, no notion of late
arrivals based on event-time). Sessions can be emitted and immediately expired.
Questions for discussion:
- Can we make SessionWindowStateStoreImpl be a simple KeyValueStore API?
(That could make Impl classes more stateful)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vjagadish1989/samza pull-request-samza-sql
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/18.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #18
----
commit 8971920997485008b9ff760a0ae81b37335ccd9d
Author: vjagadish1989 <[email protected]>
Date: 2016-10-23T21:45:39Z
Got a Thread job working with refactored API. Wired up Adaptor
commit c6df22877453fea40bea5178b677eee32525a398
Author: vjagadish1989 <[email protected]>
Date: 2016-10-24T15:38:07Z
Got a Thread job ACTUALLY working with operators
commit 9a2599a30da07d695c7c42c1f60bd3021c23a331
Author: vjagadish1989 <[email protected]>
Date: 2016-10-30T16:32:43Z
made impl a static inner class. Fixed gradle to make samza-test import
samza-operator. Added math commons
commit 1216f401c170db4ed9f7fe397215a2c7fe97aa03
Author: vjagadish1989 <[email protected]>
Date: 2016-10-31T22:20:10Z
rename mock message to reduce conflicts
commit 92a5abebc3940e252480486720eee28568734fdd
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T18:58:28Z
Fixes for the RB
commit 8525ce26f55fcf694de50d403c2dfc77b5a7e5a5
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T19:30:37Z
Fixes for rb
commit cadcb0f0a02b566acf81742e096e16c8de651041
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T19:52:32Z
Fixes for rb
commit 152d2fcf5de3d48be1b20706e26bae8e807e4517
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T19:58:36Z
add docs for kv store
commit 604f7815bbfebb92a05d7d82a5d95e76f069e605
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T20:02:35Z
add docs for kv store
commit bd1efb917830398f4ed4e53220a330d10317b42b
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T20:11:35Z
add docs for kv store
commit 8ae9ff76b5c9118c53d9d7aca023d97e9602af6c
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T20:13:53Z
add docs for kv store
commit 22fec01284edbafd65d7030b80b9e68bbf4e3e76
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T20:16:57Z
add docs for kv store
commit 6a26815f8ee2292f10a33dc20786a074006b04dd
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T21:44:35Z
add docs for kv store
commit 72b2e3de4de0dce8e091162079ee090adf786813
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T21:53:24Z
add docs for kv store
commit 98b7c2e347b34de1d585a2ae86cb99e5f3e649ed
Author: vjagadish1989 <[email protected]>
Date: 2016-11-07T21:59:36Z
add docs for kv store
----
---
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 is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
