Skip to content

Commit b5ce4e7

Browse files
Update streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStoreWithHeaders.java
Co-authored-by: TengYao Chi <kitingiao@gmail.com>
1 parent daba6fc commit b5ce4e7

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStoreWithHeaders.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,10 @@ public class RocksDBTimestampedStoreWithHeaders extends RocksDBStore implements
4343

4444
private static final Logger log = LoggerFactory.getLogger(RocksDBTimestampedStoreWithHeaders.class);
4545

46-
// Legacy column family name - must match RocksDBTimestampedStore.TIMESTAMPED_VALUES_COLUMN_FAMILY_NAME
46+
/**
47+
* Legacy column family name - must match {@code RocksDBTimestampedStore#TIMESTAMPED_VALUES_COLUMN_FAMILY_NAME}
48+
*/
49+
4750
private static final byte[] LEGACY_TIMESTAMPED_CF_NAME =
4851
"keyValueWithTimestamp".getBytes(StandardCharsets.UTF_8);
4952

0 commit comments

Comments
 (0)