From 402f2c1ece929dec3a89647a3ac1a044015d772b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=B6nke=20Liebau?= Date: Thu, 23 Apr 2020 11:44:36 +0200 Subject: [PATCH] MINOR: Some html fixes in Streams DSL documentation (#8503) * Minor: Some html fixes Streams DSL documentation: - duplicate id - duplicate opening element - surplus closing tag * Replaced opening/closing quotation mark codes with " (they caused w3c validation to complain). * Replaced right arrow that wasn't rendered correctly with → Reviewers: Mickael Maison --- docs/streams/developer-guide/dsl-api.html | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index 5708966f4d577..db4940fb27322 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -28,8 +28,8 @@ Run Demo App Tutorial: Write App - - + +
@@ -49,7 +49,7 @@
  • Join co-partitioning requirements
  • KStream-KStream Join
  • KTable-KTable Equi-Join
    • -
  • KTable-KTable Foreign-Key Join
    • +
  • KTable-KTable Foreign-Key Join
  • KStream-KTable Join
  • KStream-GlobalKTable Join
    • @@ -1114,7 +1114,7 @@

    .withValueSerde(Serdes.Long())); // Aggregating with session-based windowing (here: with an inactivity gap of 5 minutes) -KTable<Windowed<String>, Long> sessionizedAggregatedStream = groupedStream.windowedBy(SessionWindows.with(Duration.ofMinutes(5)). +KTable<Windowed<String>, Long> sessionizedAggregatedStream = groupedStream.windowedBy(SessionWindows.with(Duration.ofMinutes(5)). aggregate( new Initializer<Long>() { /* initializer */ @Override @@ -2153,7 +2153,7 @@

    Performs an INNER JOIN of this table with another table. - The result is an ever-updating KTable that represents the “current” result of the join. + The result is an ever-updating KTable that represents the "current" result of the join. (details)

    Data must be co-partitioned: The input data for both sides must be co-partitioned.

    KTable<String, Long> left = ...;
@@ -2430,7 +2430,7 @@