From 85ed23f3ae6a6825492efb4d6d6b6f5a798ce230 Mon Sep 17 00:00:00 2001 From: Jendrik Poloczek Date: Sun, 26 Feb 2017 12:53:18 +0100 Subject: [PATCH] improved documentation for windowStateTable --- README.md | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/README.md b/README.md index b00d2b4..c534f85 100644 --- a/README.md +++ b/README.md @@ -70,14 +70,14 @@ When you define your state stores via .stores(stores: Seq[String]) since 1.2 and props.put(StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG, classOf[TimestampExtractors.CustomTimestampExtractor].getName) - val builder = MockedStreams() - .topology(topology1WindowOutput) + val mstreams = MockedStreams() + .topology { builder => builder.stream(...) [...] } .input("in-a", strings, ints, inputA) .stores(Seq("store-name")) .config(props) - builder.windowStateTable("store-name", "x") shouldEqual someMapX - builder.windowStateTable("store-name", "y") shouldEqual someMapY + mstreams.windowStateTable("store-name", "x") shouldEqual someMapX + mstreams.windowStateTable("store-name", "y") shouldEqual someMapY ## Custom Streams Configuration