THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
/**
* 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)
} |
| Code Block | ||||
|---|---|---|---|---|
| ||||
/**
* Optional arguments that can be specified when doing to and through operations
*/
public class TopicOptions<K, V> {
public static <K, V> TopicOptions<K, V> serdes(final Serde<K> keySerde, final Serde<V> valueSerde) {
return new TopicOptions<K, V>().withKeySerde(keySerde).withValueSerde(valueSerde);
}
public static <K, V> TopicOptions<K, V> options(final StreamPartitioner<K, V> partitioner, final Serde<K> keySerde, final Serde<V> valueSerde) {
return new TopicOptions<K, V>().withKeySerde(keySerde).withValueSerde(valueSerde).withStreamPartitioner(partitioner);
}
public TopicOptions<K, V> withStreamPartitioner(final StreamPartitioner<K, V> partitioner) {
return null;
}
public TopicOptions<K, V> withValueSerde(final Serde<V> valueSerde) {
return null;
}
public TopicOptions<K, V> withKeySerde(final Serde<K> keySerde) {
return null;
}
} |
| Code Block |
|---|
/**
* options that can be used when printing to stdout our writing to a file
*/
public class PrintOptions<K, V> {
public static <K, V> PrintOptions<K, V> labeled(final String label)
public static <K, V> PrintOptions<K, V> toFile(final String filepath)
public static <K, V> PrintOptions<K, V> sysOut(final KeyValueMapper<? super K, ? super V, String> mapper, final Serde<K> keySerde, final Serde<V> valSerde, final String label)
public static <K, V> PrintOptions<K, V> toFile(final String filePath, final KeyValueMapper<? super K, ? super V, String> mapper, final Serde<K> keySerde, final Serde<V> valSerde, final String label)
public PrintOptions<K, V> withLabel(final String label)
public PrintOptions<K, V> withFile(final String filepath)
public PrintOptions<K, V> withKeySerde(final Serde<K> keySerde)
public PrintOptions<K, V> withValueSerde(final Serde<V> keySerde)
public PrintOptions<K, V> withKeyValueMapper(final KeyValueMapper<? super K, ? super V, String> mapper)
} |
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.
...