...
| Code Block |
|---|
| language | java |
|---|
| title | Materialized |
|---|
|
/**
* Used when materializing a state store
*/
public class Materialized<K, V, S extends StateStore> {
public static <K, V, S extends StateStore> Materialized<K, V, S> as(final String storeName)
public static <K, V, S extends StateStore> Materialized<K, V, S> as(final StateStoreSupplier<S> supplier)
public Materialized<K, V, S> withValueSerde(final Serde<V> valueSerde)
public Materialized<K, V, S> withKeySerde(final Serde<K> valueSerde)
public Materialized<K, V, S> withLoggingEnabled(final Map<String, String> topicConfig)
public Materialized<K, V, S> withLoggingDisabled()
public Materialized<K, V, S> withCachingEnabled()
public Materialized<K, V, S> withCachingDisabled()
} |
| Code Block |
|---|
| language | java |
|---|
| title | GroupByOptions |
|---|
|
/**
* Optional params that can be passed to groupBy and groupByKey operations
*/
public class GroupByOptions<K, V> {
public static <K, V> GroupByOptions<K, V> serdes(final Serde<K> keySerde, final Serde<V> valueSerde) {
return new GroupByOptions<>();
}
public GroupByOptions<K, V> withKeySerde()
public GroupByOptions<K, V> withValueSerde()
} |
| Code Block |
|---|
| language | java |
|---|
| title | JoinOptions |
|---|
|
/**
* Optional params that can be passed to join, leftJoin, outerJoin operations
*/
public class JoinOptions<K, V, VO> {
public static <K, V, VO> JoinOptions<K, V, VO> serdes(final Serde<K> keySerde, final Serde <V> valueSerde, final Serde<VO> otherValueSerde)
public JoinOptions<K, V, VO> withKeySerde(final Serde<K> keySerde)
public JoinOptions<K, V, VO> withValueSerde(final Serde<V> valueSerde)
public JoinOptions<K, V, VO> withOtherValueSerde(final Serde<VO> otherValueSerde)
} |
Proposed Changes
Describe the new thing you want to do in appropriate detail. This may be fairly extensive and have large subsections of its own. Or it may be a few sentences. Use judgement based on the scope of the change.
...