[CONF] Apache Samza > SEP-8: Add in-memory system consumer & producer

[Bharath Kumarasubramanian (Confluence)]

Title: Message Title

Bharath Kumarasubramanian edited a page

SEP-8: Add in-memory system consumer & producer ... Code Block language java theme Emacs collapse true /** * Sample test case using collection based system for high level application with durable state. * Note: We don't provide the ability to recover data/bootstrap data for store using in-memory system. It should work seamlessly once we have StoreDecriptor.  */ ... ... ImmutableList<IV> inputA = ... ImmutableList<IV> inputB = ... List<OV> outputData = ... // mutable StreamDescriptor.Input<IK,IV> input = StreamDescriptor.<IK,IV>input("test-stream") .from(ImmutableList.of(inputA, inputB)); StreamDescriptor.Output<OK,OV> output = StreamDescriptor.<OK,OV>output("output-test-stream") .from(outputData); // application logic StreamApplication app = StreamApplication.create(...); app.from(input) .map(...) .sendTo(output); app.run(); app.waitForFinish(); // assertions on outputData   ... View page • Add comment • Like

Stop watching space • Manage notifications This message was sent by Atlassian Confluence 5.8.17