...
Code Block | ||||
---|---|---|---|---|
| ||||
void print(final Printed<K, V> printed);
KStream<K, V> through(final String topic, final Produced<K, V> partitioned);
void to(final String topic, final Produced<V, V> partitioned);
KGroupedStream<K, V> groupByKey(final Serialized<K, V> serialized);
<KR> KGroupedStream<KR, V> groupBy(final KeyValueMapper<? super K, ? super V, KR> selector, Serialized<KR, V> serialized);
<VO, VR> KStream<K, VR> join(final KStream<K, VO> other, final ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final JoinWindows windows, final Joined<K, V, VO> options);
<VT, VR> KStream<K, VR> join(final KTable<K, VT> other, final ValueJoiner<? super V, ? super VT, ? extends VR> joiner, final Joined<K, V, VT> options);
<VO, VR> KStream<K, VR> leftJoin(final KStream<K, VO> other, final ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final JoinWindows windows, final Joined<K, V, VO> options);
<VT, VR> KStream<K, VR> leftJoin(final KTable<K, VT> other, final ValueJoiner<? super V, ? super VT, ? extends VR> joiner, final Joined<K, V, VT> options);
<VO, VR> KStream<K, VR> outerJoin(final KStream<K, VO> other, final ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final JoinWindows windows, final Joined<K, V, VO> options);
<VT, VR> KStream<K, VR> outerJoin(final KTable<K, VT> other, final ValueJoiner<? super V, ? super VT, ? extends VR> joiner, final Joined<K, V, VT> options); |
Code Block | ||||
---|---|---|---|---|
| ||||
<KR, VR> KGroupedTable<KR, VR> groupBy(final KeyValueMapper<? super K, ? super V, KeyValue<KR, VR>> selector, Serialized<KR, VR> serialized); KTable<K, V> filter(final Predicate<? super K, ? super V> predicate, final Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized); KTable<K, V> filterNot(final Predicate<? super K, ? super V> predicate, final Materialized<K, V, KeyValueStore<Bytes[], byte[]>> materialized); <VR> KTable<K, VR> mapValues(final ValueMapper<? super V, ? extends VR> mapper, final Materialized<K, V, KeyValueStore<Bytes[], byte[]>> materialized); void to(final String topic, final Produced<V, V> options); KTable<K, V> through(final String topic, final Materialized<K, V, KeyValueStore<Bytes, byte[]> options); <VO, VR> KTable<K, VR> join(final KTable<K, VO> other, final ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized); <VO, VR> KTable<K, VR> leftJoin(final KTable<K, VO> other, final ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized); <VO, VR> KTable<K, VR> outerJoin(final KTable<K, VO> other, final ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized); |
...
Code Block | ||||
---|---|---|---|---|
| ||||
/**
* Optional params that can be passed to groupBy and groupByKey operations
*/
public class Serialized<K, V> {
public static <K, V> Serialized<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde)
public Serialized<K, V> withKeySerde(final Serde<K> keySerde)
public Serialized<K, V> withValueSerde(final Serde valueSerde)
public Serde<K> keySerde()
public Serde<V> valueSerde()
} |
Code Block | ||||
---|---|---|---|---|
| ||||
/**
* Optional params that can be passed to join, leftJoin, outerJoin operations
*/
public class Joined<K, V, VO> {
public static <K, V, VO> Joined<K, V, VO> with(final Serde<K> keySerde, final Serde <V> valueSerde, final Serde<VO> otherValueSerde)
public static <K, V, VO> Joined<K, V, VO> keySerde(final Serde<K> keySerde)
public static <K, V, VO> Joined<K, V, VO> valueSerde(final Serde<V> valueSerde)
public static <K, V, VO> Joined<K, V, VO> otherValueSerde(final Serde<V> valueSerde)
public Joined<K, V, VO> withKeySerde(final Serde<K> keySerde)
public Joined<K, V, VO> withValueSerde(final Serde<V> valueSerde)
public Joined<K, V, VO> withOtherValueSerde(final Serde<VO> otherValueSerde)
public Serde<K> keySerde()
public Serde<V> valueSerde()
public Serde<VO> otherValueSerde()
} |
Code Block | ||||
---|---|---|---|---|
| ||||
/** * Optional arguments that can be specified when doing to and through operations */ public static <K, V> Produced<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde) public static <K, V> Produced<K, V> with(final Serde<K> keySerde, final Serde<V> valueSerde, final StreamPartitioner<K, V> partitioner) public static <K, V> Produced<K, V> keySerde(final Serde<K> keySerde) public static <K, V> Produced<K, V> valueSerde(final Serde<V> valueSerde) public static <K, V> Produced<K, V> streamPartitioner(final StreamPartitioner<K, V> partitioner) public Produced<K, V> withStreamPartitioner(final StreamPartitioner<K, V> partitioner) public Produced<K, V> withValueSerde(final Serde<V> valueSerde) public Produced<K, V> withKeySerde(final Serde<K> keySerde) public Serde<K> keySerde() public Serde<K> valueSerde() public StreamPartitioner<K, V> streamPartitioner() |
...