Returns the underlying GlobalKTable

Aggregates values by key into a new KTable.

Counts the number of records by key into a new KTable.

Combines values of a stream by key into a new KTable.

Returns the underlying KGroupedStream object.

Returns the underlying KGroupedTable object.

Returns a list of KStreams, one for each of the `predicate-fns`
provided.

Creates a KStream that will consist of the concatenation of messages
returned by calling `key-value-mapper-fn` on each key/value pair in the
input stream.

Creates a KStream that will consist of the concatenation of the values
returned by calling `value-mapper-fn` on each value in the input stream.

Performs an action on each element of KStream.

Groups records with the same key into a KGroupedStream.

Combines the values of two streams that share the same key using a
windowed inner join.

Returns the underlying KStream object.

Combines the values of two streams that share the same key using a
windowed left join.

Creates a KStream that consists of the result of applying
`key-value-mapper-fn` to each key/value pair in the input stream.

Creates a KStream that has the records from both streams.

Combines the values of two streams that share the same key using a
windowed outer join.

Prints the elements of the stream to *out*.

Applies `processor-fn` to each item in the input stream.

Create a new key from the current key and value.

`select-key-value-mapper-fn` should be a function that takes a key-value
pair, and returns the value of the new key. Here is example multiplies each
key by 10:

```(fn [[k v]] (* 10 k))```

Materializes a stream to a topic, and returns a new KStream that will
consume messages from the topic.

Materializes a stream to a topic.

Creates a KStream that consists of the results of applying the transformer
to each key/value in the input stream.

Creates a KStream that consists of the results of applying the transformer
to each value in the input stream.

Creates a KStream that consists of all elements that satisfy a
predicate.

Creates a KStream that consists of all elements that do not satisfy a
predicate.

Groups the records of this KStream/KTable using the key-value-mapper-fn.

Creates a KStream from the result of calling `value-joiner-fn` with
each element in the KStream and the value in the KTable with the same
key.

Creates a KStream that is the result of calling `value-mapper-fn` on each
element of the input stream.

Performs `peek-fn` on each element of the input stream.

Writes the elements of a stream to a file at the given path.

Combines the values of the two KTables that share the same key using an
inner join.

Returns the underlying KTable object.

Combines the values of two KTables that share the same key using an outer
join.

Converts a KTable to a KStream.

Returns the underlying SessionWindowedKStream object.

Creates a GlobalKTable that will consist of data from the specified
topic.

Creates a KStream that will consume messages from the specified topic.

Creates a KStream that will consume messages from the specified topics.

Creates a KTable that will consist of data from the specified topic.

Gets the names of source topics for the topology.

Returns the underlying KStreamBuilder.

Returns the underlying TimeWindowedKStream object.