Kafka streams protocols.
Kafka streams protocols.
(aggregate kgrouped initializer-fn adder-fn)
(aggregate kgrouped initializer-fn aggregator-fn subtractor-fn-or-topic-config)
(aggregate kgrouped initializer-fn adder-fn subtractor-fn topic-config)
Aggregates values by key into a new KTable.
Aggregates values by key into a new KTable.
(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.
(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.
(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.
(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.
(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.
(for-each! kstream foreach-fn)
Performs an action on each element of KStream.
Performs an action on each element of KStream.
(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.
(global-ktable* globalktable)
Returns the underlying GlobalKTable
Returns the underlying GlobalKTable
(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.
(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.
(join ktable other-ktable value-joiner-fn)
Combines the values of the two KTables that share the same key using an inner join.
Combines the values of the two KTables that share the same key using an inner join.
(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.
(kafka-streams builder opts)
Makes a Kafka Streams object.
Makes a Kafka Streams object.
(kgroupedstream* kgroupedstream)
Returns the underlying KGroupedStream object.
Returns the underlying KGroupedStream object.
(kgroupedtable* kgroupedtable)
Returns the underlying KGroupedTable object.
Returns the underlying KGroupedTable object.
(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.
(kstream* kstream)
Returns the underlying KStream object.
Returns the underlying KStream object.
(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.
(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.
(ktable* ktable)
Returns the underlying KTable object.
Returns the underlying KTable object.
(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.
(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.
(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.
(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.
(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.
(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.
(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.
(print! kstream)
Prints the elements of the stream to out.
Prints the elements of the stream to *out*.
(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.
(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.
(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))```
(source-topics streams-builder)
Gets the names of source topics for the topology.
Gets the names of source topics for the topology.
(streams-builder* streams-builder)
Returns the underlying KStreamBuilder.
Returns the underlying KStreamBuilder.
(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.
(to kstream topic-config)
Materializes a stream to a topic.
Materializes a stream to a topic.
(to-kstream ktable)
(to-kstream ktable key-value-mapper-fn)
Converts a KTable to a KStream.
Converts a KTable to a KStream.
(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.
(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.
(window-by-session kgroupedstream window)
Windows the KStream
Windows the KStream
(window-by-time kgroupedstream window)
Windows the KStream
Windows the KStream
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close