THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public interface KStream<K, V> {
// .. //
KStream<K, V> repartition();
<KR> KStream<KR, V> repartition(final KeyValueMapper<? super K, ? super V, KR> selector);
KStream<K, V> repartition(final Repartitioned<K, V> repartitioned);
<KR> KStream<KR, V> repartition(final KeyValueMapper<? super K, ? super V, KR> selector,
final Repartitioned<KR, V> repartitioned);
// .. //
} |
...