[jira] [Commented] (KAFKA-9290) Update IQ related JavaDocs
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012517#comment-17012517 ] Demitri Swan commented on KAFKA-9290: - I'm okay with pulling my PR/Ticket out if that makes things easier. > Update IQ related JavaDocs > -- > > Key: KAFKA-9290 > URL: https://issues.apache.org/jira/browse/KAFKA-9290 > Project: Kafka > Issue Type: Improvement > Components: streams >Reporter: Matthias J. Sax >Priority: Minor > Labels: beginner, newbie > > In Kafka 2.1.0 we deprecated couple of methods (KAFKA-7277) to pass in > timestamps via IQ API via Duration/Instance parameters instead of plain longs. > In Kafka 2.3.0 we introduced TimestampedXxxStores (KAFKA-3522) and allow IQ > to return the stored timestamp. > However, we never update our JavaDocs that contain code snippets to > illustrate how a local store can be queries. For example > `KGroupedStream#count(Materialized)` > ([https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java#L116-L122]): > > {code:java} > * {@code * KafkaStreams streams = ... // counting words > * String queryableStoreName = "storeName"; // the store name should be the > name of the store as defined by the Materialized instance > * ReadOnlyKeyValueStore localStore = > streams.store(queryableStoreName, QueryableStoreTypes. Long>keyValueStore()); > * String key = "some-word"; > * Long countForWord = localStore.get(key); // key must be local (application > state is shared over all running Kafka Streams instances) > * } > {code} > We should update all JavaDocs to use `TimestampedXxxStore` and the new > Duration/Instance methods in all those code snippets. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore
[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997865#comment-16997865 ] Demitri Swan commented on KAFKA-9243: - Thanks for adding me as a contributor. Looking forward to helping out. Would someone please provide an example and more clarification? Of the regions of code where I see `TimestampedKeyValueStore` referenced in the method signatures I do not see incorrect references to `KeyValueStores` in the Javadocs. Also, the [current KTables JavaDoc|https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/kstream/KTable.html] does reference KeyValueStores within the Javadocs, but they're also referenced in the method signatures. _Caveat: I'm new to the codebase_ > Update the javadocs from KeyValueStore to TimestampKeyValueStore > > > Key: KAFKA-9243 > URL: https://issues.apache.org/jira/browse/KAFKA-9243 > Project: Kafka > Issue Type: Improvement > Components: streams >Affects Versions: 2.3.0 >Reporter: Walker Carlson >Assignee: Demitri Swan >Priority: Minor > Labels: beginner, newbie > > As of version 2.3, the DSL uses `TimestampedStores` to represent KTables. > However, the JavaDocs of all table-related operators still refer to plain > `KeyValueStores` etc instead of `TimestampedKeyValueStore` etc. Hence, all > those JavaDocs should be updated (the JavaDocs are technically not incorrect, > because one can access a TimestampedKeyValueStore as a KeyValueStore, too – > hence this ticket is not a "bug" but an improvement. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore
[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Demitri Swan reassigned KAFKA-9243: --- Assignee: Demitri Swan > Update the javadocs from KeyValueStore to TimestampKeyValueStore > > > Key: KAFKA-9243 > URL: https://issues.apache.org/jira/browse/KAFKA-9243 > Project: Kafka > Issue Type: Improvement > Components: streams >Affects Versions: 2.3.0 >Reporter: Walker Carlson >Assignee: Demitri Swan >Priority: Minor > Labels: beginner, newbie > > As of version 2.3, the DSL uses `TimestampedStores` to represent KTables. > However, the JavaDocs of all table-related operators still refer to plain > `KeyValueStores` etc instead of `TimestampedKeyValueStore` etc. Hence, all > those JavaDocs should be updated (the JavaDocs are technically not incorrect, > because one can access a TimestampedKeyValueStore as a KeyValueStore, too – > hence this ticket is not a "bug" but an improvement. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore
[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997491#comment-16997491 ] Demitri Swan commented on KAFKA-9243: - I am available to take this one. > Update the javadocs from KeyValueStore to TimestampKeyValueStore > > > Key: KAFKA-9243 > URL: https://issues.apache.org/jira/browse/KAFKA-9243 > Project: Kafka > Issue Type: Improvement > Components: streams >Affects Versions: 2.3.0 >Reporter: Walker Carlson >Priority: Minor > Labels: beginner, newbie > > As of version 2.3, the DSL uses `TimestampedStores` to represent KTables. > However, the JavaDocs of all table-related operators still refer to plain > `KeyValueStores` etc instead of `TimestampedKeyValueStore` etc. Hence, all > those JavaDocs should be updated (the JavaDocs are technically not incorrect, > because one can access a TimestampedKeyValueStore as a KeyValueStore, too – > hence this ticket is not a "bug" but an improvement. -- This message was sent by Atlassian Jira (v8.3.4#803005)