Liking cljdoc? Tell your friends :D

jackdaw.streams

Kafka streams protocols.

Kafka streams protocols.
raw docstring

aggregateclj

(aggregate kgrouped initializer-fn adder-fn)
(aggregate kgrouped initializer-fn aggregator-fn subtractor-fn-or-topic-config)
(aggregate kgrouped
           initializer-fn
           adder-fn
           subtractor-or-merger-fn
           topic-config)

Aggregates values by key into a new KTable.

Aggregates values by key into a new KTable.
raw docstring

branchclj

(branch kstream predicate-fns)

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

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

closeclj

(close kafka-streams)

Stops the kafka streams.

Stops the kafka streams.
raw docstring

countclj

(count kgrouped)
(count kgrouped name)

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

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

filterclj

(filter kstream predicate-fn)

filter-notclj

(filter-not kstream predicate-fn)

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

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

flat-mapclj

(flat-map kstream key-value-mapper-fn)

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 messages
returned by calling `key-value-mapper-fn` on each key/value pair in the
input stream.
raw docstring

flat-map-valuesclj

(flat-map-values kstream value-mapper-fn)

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.

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.
raw docstring

for-each!clj

(for-each! kstream foreach-fn)

Performs an action on each element of KStream.

Performs an action on each element of KStream.
raw docstring

global-ktableclj

(global-ktable streams-builder topic-config)

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

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

global-ktable*clj

(global-ktable* globalktable)

Returns the underlying GlobalKTable

Returns the underlying GlobalKTable
raw docstring

group-byclj

(group-by ktable key-value-mapper-fn)
(group-by ktable key-value-mapper-fn topic-config)

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

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

group-by-keyclj

(group-by-key kstream)
(group-by-key kstream topic-config)

Groups records with the same key into a KGroupedStream.

Groups records with the same key into a KGroupedStream.
raw docstring

joinclj

(join kstream-or-ktable ktable value-joiner-fn)

Combines the values of the KStream-or-KTable and the KTable that share the same key using an inner join.

Combines the values of the KStream-or-KTable and the KTable that
share the same key using an inner join.
raw docstring

join-globalclj

(join-global kstream global-ktable kv-mapper joiner)

join-windowedclj

(join-windowed kstream other-kstream value-joiner-fn windows)
(join-windowed kstream
               other-kstream
               value-joiner-fn
               windows
               this-topic-config
               other-topic-config)

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

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

kafka-streamsclj

(kafka-streams builder opts)

Makes a Kafka Streams object.

Makes a Kafka Streams object.
raw docstring

kgroupedstream*clj

(kgroupedstream* kgroupedstream)

Returns the underlying KGroupedStream object.

Returns the underlying KGroupedStream object.
raw docstring

kgroupedtable*clj

(kgroupedtable* kgroupedtable)

Returns the underlying KGroupedTable object.

Returns the underlying KGroupedTable object.
raw docstring

kstreamclj

(kstream streams-builder topic-config)
(kstream streams-builder topic-config topic-pattern)

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

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

kstream*clj

(kstream* kstream)

Returns the underlying KStream object.

Returns the underlying KStream object.
raw docstring

kstreamsclj

(kstreams streams-builder topic-configs)

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

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

ktableclj

(ktable streams-builder topic-config)
(ktable streams-builder topic-config store-name)

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

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

ktable*clj

(ktable* ktable)

Returns the underlying KTable object.

Returns the underlying KTable object.
raw docstring

left-joinclj

(left-join kstream ktable value-joiner-fn)
(left-join kstream ktable value-joiner-fn this-topic-config other-topic-config)

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 from the result of calling `value-joiner-fn` with
each element in the KStream and the value in the KTable with the same
key.
raw docstring

left-join-globalclj

(left-join-global kstream global-ktable kv-mapper joiner)

left-join-windowedclj

(left-join-windowed kstream other-kstream value-joiner-fn windows)
(left-join-windowed kstream
                    other-kstream
                    value-joiner-fn
                    windows
                    this-topic-config
                    other-topic-config)

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

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

mapclj

(map kstream key-value-mapper-fn)

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 consists of the result of applying
`key-value-mapper-fn` to each key/value pair in the input stream.
raw docstring

map-valuesclj

(map-values kstream value-mapper-fn)

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

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

mergeclj

(merge kstream other)

outer-joinclj

(outer-join ktable other-ktable value-joiner-fn)

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

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

outer-join-windowedclj

(outer-join-windowed kstream other-kstream value-joiner-fn windows)
(outer-join-windowed kstream
                     other-kstream
                     value-joiner-fn
                     windows
                     this-topic-config
                     other-topic-config)

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

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

peekclj

(peek kstream peek-fn)

Performs the action defined by peek-fn on each element of the input KStream, returning that stream untransformed.

Performs the action defined by `peek-fn` on each element of the input
KStream, returning that stream untransformed.
raw docstring

print!clj

(print! kstream)

Prints the elements of the stream to out.

Prints the elements of the stream to *out*.
raw docstring

process!clj

(process! kstream processor-fn state-store-names)

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

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

reduceclj

(reduce kgrouped reducer-fn)
(reduce kgrouped reducer-fn subtractor-fn-or-topic-config)
(reduce kgrouped adder-fn subtractor-fn topic-config)

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

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

select-keyclj

(select-key kstream select-key-value-mapper-fn)

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))

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))```
raw docstring

source-topicsclj

(source-topics streams-builder)

Gets the names of source topics for the topology.

Gets the names of source topics for the topology.
raw docstring

startclj

(start kafka-streams)

Starts processing.

Starts processing.
raw docstring

stateclj

(state k-streams)

state->keywordclj

(state->keyword state)

streams-builderclj

(streams-builder)

streams-builder*clj

(streams-builder* streams-builder)

Returns the underlying KStreamBuilder.

Returns the underlying KStreamBuilder.
raw docstring

suppressclj

(suppress ktable suppressed)

Suppress some updates from this changelog stream

Suppress some updates from this changelog stream
raw docstring

throughclj

(through kstream topic-config)

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

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

toclj

(to kstream topic-config)

Materializes a stream to a topic.

Materializes a stream to a topic.
raw docstring

to-kstreamclj

(to-kstream ktable)
(to-kstream ktable key-value-mapper-fn)

Converts a KTable to a KStream.

Converts a KTable to a KStream.
raw docstring

transformclj

(transform kstream transformer-supplier-fn)
(transform kstream transformer-supplier-fn state-store-names)

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 key/value in the input stream.
raw docstring

transform-valuesclj

(transform-values kstream value-transformer-supplier-fn)
(transform-values kstream value-transformer-supplier-fn state-store-names)

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 the results of applying the transformer
to each value in the input stream.
raw docstring

window-by-sessionclj

(window-by-session kgroupedstream window)

Windows the KStream

Windows the KStream
raw docstring

window-by-timeclj

(window-by-time kgroupedstream window)

Windows the KStream

Windows the KStream
raw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close