mjsax commented on code in PR #18703:
URL: https://github.com/apache/kafka/pull/18703#discussion_r1929493781
##########
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:
##########
@@ -156,98 +123,30 @@ public interface KStream<K, V> {
* }
* });
* }</pre>
- * Setting a new key might result in an internal data redistribution if a
key based operator (like an aggregation or
- * join) is applied to the result {@code KStream}.
+ * Setting a new key might result in an internal data redistribution if a
key based operator (like an aggregation
+ * or join) is applied to the result {@code KStream}.
+ *
+ * @param mapper
+ * a {@link KeyValueMapper} that computes a new key for each input
record
+ *
+ * @param <KOut> the new key type of the result stream
+ *
+ * @return A {@code KStream} that contains records with new key (possibly
of a different type) and unmodified value.
*
- * @param mapper a {@link KeyValueMapper} that computes a new key for each
record
- * @param named a {@link Named} config used to name the processor in the
topology
- * @param <KR> the new key type of the result stream
- * @return a {@code KStream} that contains records with new key (possibly
of different type) and unmodified value
* @see #map(KeyValueMapper)
- * @see #flatMap(KeyValueMapper)
* @see #mapValues(ValueMapper)
- * @see #mapValues(ValueMapperWithKey)
- * @see #flatMapValues(ValueMapper)
- * @see #flatMapValues(ValueMapperWithKey)
- */
- <KR> KStream<KR, V> selectKey(final KeyValueMapper<? super K, ? super V, ?
extends KR> mapper,
Review Comment:
As above...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
