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

[Chris Pettitt (Confluence)]

Title: Message Title

Chris Pettitt commented on a page

Re: SEP-8: Add in-memory system consumer & producer How would users test code that uses triggers deterministically? Beam allows you to advance both the processing time and watermarks as a part of its test stream. Here's an example:   TestStream<String> source = TestStream.create(StringUtf8Coder.of()) .addElements(TimestampedValue.of("this", start)) .addElements(TimestampedValue.of("that", start)) .addElements(TimestampedValue.of("future", start.plus(Duration.standardMinutes(1)))) .advanceProcessingTime(Duration.standardMinutes(3)) .advanceWatermarkToInfinity(); Reply • Like

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