THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
/** * 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 |
...