samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bharathkk <...@git.apache.org>
Subject [GitHub] samza pull request #459: Initial version for in memory system.
Date Wed, 28 Mar 2018 19:21:28 GMT
GitHub user bharathkk opened a pull request:

    https://github.com/apache/samza/pull/459

    Initial version for in memory system.

    Getting the PR out to unblock sanil.
    Pending tasks
     1. Add documentation
     2. Add more tests
     3. Currently initialization of the stream happens using createStream on admin. We need
to find a way to expose the same functionality to low level users.
     4. To populate the initial stream, clients need to get a handle on producer and produce
the messages. Alternatively, we can support serialization of source data and pass it as config
to the system to initialize. We have a hook in place for this but not implemented it completely.
      5. Clean up consumed data on the buffer based on the lowest offsets of the consumers.
    
    I will create JIRAs for all the pending tasks and fix them iteratively.
    
    @xinyuiscool ^^

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/bharathkk/samza single-node-testing

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/samza/pull/459.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 #459
    
----
commit 3580632fbd955a101060ea390994856c0802d68f
Author: Bharath Kumarasubramanian <bkumaras@...>
Date:   2018-02-16T01:42:23Z

    Initial version for in memory system.

----


---

Mime
View raw message