diff --git a/java/src/main/java/org/rocksdb/AbstractCompactionFilter.java b/java/src/main/java/org/rocksdb/AbstractCompactionFilter.java index 1f4a5e4a687..45ad20e2cad 100644 --- a/java/src/main/java/org/rocksdb/AbstractCompactionFilter.java +++ b/java/src/main/java/org/rocksdb/AbstractCompactionFilter.java @@ -15,7 +15,6 @@ */ public abstract class AbstractCompactionFilter> extends RocksObject { - /** * Context of the Compaction Filter. */ @@ -58,7 +57,8 @@ public boolean isManualCompaction() { * Constructor to be called by subclasses to set the * handle to the underlying C++ object. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ Compaction Filter. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ Compaction Filter. */ protected AbstractCompactionFilter(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/AbstractCompactionFilterFactory.java b/java/src/main/java/org/rocksdb/AbstractCompactionFilterFactory.java index 231377f516d..53271fc3f5a 100644 --- a/java/src/main/java/org/rocksdb/AbstractCompactionFilterFactory.java +++ b/java/src/main/java/org/rocksdb/AbstractCompactionFilterFactory.java @@ -13,7 +13,6 @@ */ public abstract class AbstractCompactionFilterFactory> extends RocksCallbackObject { - /** * Constructs a new Compaction Filter Factory which has no underlying C++ object. */ diff --git a/java/src/main/java/org/rocksdb/AbstractEventListener.java b/java/src/main/java/org/rocksdb/AbstractEventListener.java index 5c7f58ab6af..5f29024bf06 100644 --- a/java/src/main/java/org/rocksdb/AbstractEventListener.java +++ b/java/src/main/java/org/rocksdb/AbstractEventListener.java @@ -12,12 +12,10 @@ */ @SuppressWarnings("PMD.AvoidDuplicateLiterals") public abstract class AbstractEventListener extends RocksCallbackObject implements EventListener { - /** * Callback events that can be enabled. */ public enum EnabledEventCallback { - /** * Flush completed. */ diff --git a/java/src/main/java/org/rocksdb/AbstractRocksIterator.java b/java/src/main/java/org/rocksdb/AbstractRocksIterator.java index a40587976a1..1a30f745135 100644 --- a/java/src/main/java/org/rocksdb/AbstractRocksIterator.java +++ b/java/src/main/java/org/rocksdb/AbstractRocksIterator.java @@ -29,7 +29,8 @@ public abstract class AbstractRocksIterator

* Constructs an AbstractRocksIterator. * * @param parent the parent object from which the Rocks Iterator was created. - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ RocksIterator. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ RocksIterator. */ protected AbstractRocksIterator(final P parent, final long nativeHandle) { diff --git a/java/src/main/java/org/rocksdb/AbstractSlice.java b/java/src/main/java/org/rocksdb/AbstractSlice.java index 9dad909fdf7..294e64c11ef 100644 --- a/java/src/main/java/org/rocksdb/AbstractSlice.java +++ b/java/src/main/java/org/rocksdb/AbstractSlice.java @@ -27,7 +27,6 @@ * @param the concrete Java type that is wrapped by the subclass of {@link AbstractSlice}. */ public abstract class AbstractSlice extends RocksMutableObject { - /** * Constructs an AbstractSlice. */ @@ -38,7 +37,8 @@ protected AbstractSlice() { /** * Constructs an AbstractSlice. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ Slice. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ Slice. */ protected AbstractSlice(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/AbstractTableFilter.java b/java/src/main/java/org/rocksdb/AbstractTableFilter.java index 0c7f994fbee..b24ce8692dd 100644 --- a/java/src/main/java/org/rocksdb/AbstractTableFilter.java +++ b/java/src/main/java/org/rocksdb/AbstractTableFilter.java @@ -6,7 +6,6 @@ */ public abstract class AbstractTableFilter extends RocksCallbackObject implements TableFilter { - /** * Constructs a new AbstractTableFilter. */ diff --git a/java/src/main/java/org/rocksdb/AbstractTransactionNotifier.java b/java/src/main/java/org/rocksdb/AbstractTransactionNotifier.java index 55818ddf6dd..15156cec6af 100644 --- a/java/src/main/java/org/rocksdb/AbstractTransactionNotifier.java +++ b/java/src/main/java/org/rocksdb/AbstractTransactionNotifier.java @@ -11,7 +11,6 @@ */ public abstract class AbstractTransactionNotifier extends RocksCallbackObject { - /** * Constructs an AbstractTransactionNotifier. */ diff --git a/java/src/main/java/org/rocksdb/AbstractWriteBatch.java b/java/src/main/java/org/rocksdb/AbstractWriteBatch.java index 59e253e75b0..33ca8d23aa2 100644 --- a/java/src/main/java/org/rocksdb/AbstractWriteBatch.java +++ b/java/src/main/java/org/rocksdb/AbstractWriteBatch.java @@ -22,11 +22,11 @@ */ public abstract class AbstractWriteBatch extends RocksObject implements WriteBatchInterface { - /** * Construct an AbstractWriteBatch. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ Write Batch object. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ Write Batch object. */ protected AbstractWriteBatch(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/BackupEngine.java b/java/src/main/java/org/rocksdb/BackupEngine.java index f0c9d516d2d..4f86181d92a 100644 --- a/java/src/main/java/org/rocksdb/BackupEngine.java +++ b/java/src/main/java/org/rocksdb/BackupEngine.java @@ -18,11 +18,11 @@ * time you need to do a backup. */ public class BackupEngine extends RocksObject implements AutoCloseable { - /** * Construct a BackupEngine. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ backup engine object. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ backup engine object. */ protected BackupEngine(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/BlockBasedTableConfig.java b/java/src/main/java/org/rocksdb/BlockBasedTableConfig.java index 82e56873bbf..f667ad81796 100644 --- a/java/src/main/java/org/rocksdb/BlockBasedTableConfig.java +++ b/java/src/main/java/org/rocksdb/BlockBasedTableConfig.java @@ -11,7 +11,6 @@ */ // TODO(AR) should be renamed BlockBasedTableOptions public class BlockBasedTableConfig extends TableFormatConfig { - /** * Constructs a new BlockBasedTableConfig. */ diff --git a/java/src/main/java/org/rocksdb/Cache.java b/java/src/main/java/org/rocksdb/Cache.java index fc814c94bee..c1e4812031d 100644 --- a/java/src/main/java/org/rocksdb/Cache.java +++ b/java/src/main/java/org/rocksdb/Cache.java @@ -5,16 +5,15 @@ package org.rocksdb; - /** * Base class for Cache implementations. */ public abstract class Cache extends RocksObject { - /** * Construct a Cache. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ cache object. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ cache object. */ protected Cache(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/CassandraCompactionFilter.java b/java/src/main/java/org/rocksdb/CassandraCompactionFilter.java index b452a54c3b7..c2705ed4e13 100644 --- a/java/src/main/java/org/rocksdb/CassandraCompactionFilter.java +++ b/java/src/main/java/org/rocksdb/CassandraCompactionFilter.java @@ -14,7 +14,6 @@ */ public class CassandraCompactionFilter extends AbstractCompactionFilter { - /** * Constructs a new CasandraCompactionFilter. * diff --git a/java/src/main/java/org/rocksdb/CassandraValueMergeOperator.java b/java/src/main/java/org/rocksdb/CassandraValueMergeOperator.java index 703d1b86c4d..60686cc5ec2 100644 --- a/java/src/main/java/org/rocksdb/CassandraValueMergeOperator.java +++ b/java/src/main/java/org/rocksdb/CassandraValueMergeOperator.java @@ -12,7 +12,6 @@ * values. */ public class CassandraValueMergeOperator extends MergeOperator { - /** * Constructs a new CassandraValueMergeOperator. * diff --git a/java/src/main/java/org/rocksdb/ClockCache.java b/java/src/main/java/org/rocksdb/ClockCache.java index 784f80db2f5..c285cc9cd57 100644 --- a/java/src/main/java/org/rocksdb/ClockCache.java +++ b/java/src/main/java/org/rocksdb/ClockCache.java @@ -62,8 +62,8 @@ public ClockCache(final long capacity, final int numShardBits) { * @param strictCapacityLimit insert to the cache will fail when cache is full */ @Deprecated - public ClockCache(final long capacity, final int numShardBits, - final boolean strictCapacityLimit) { + public ClockCache( + final long capacity, final int numShardBits, final boolean strictCapacityLimit) { super(newClockCache(capacity, numShardBits, strictCapacityLimit)); } diff --git a/java/src/main/java/org/rocksdb/CompactionJobInfo.java b/java/src/main/java/org/rocksdb/CompactionJobInfo.java index 27f0a45da01..054473cb335 100644 --- a/java/src/main/java/org/rocksdb/CompactionJobInfo.java +++ b/java/src/main/java/org/rocksdb/CompactionJobInfo.java @@ -13,7 +13,6 @@ * Information about a Compaction Job. */ public class CompactionJobInfo extends RocksObject { - /** * Constructs a new CompactionJobInfo. */ diff --git a/java/src/main/java/org/rocksdb/CompactionJobStats.java b/java/src/main/java/org/rocksdb/CompactionJobStats.java index 82ebe19bfd9..6f519109c1f 100644 --- a/java/src/main/java/org/rocksdb/CompactionJobStats.java +++ b/java/src/main/java/org/rocksdb/CompactionJobStats.java @@ -9,7 +9,6 @@ * Statistics about a Compaction Job. */ public class CompactionJobStats extends RocksObject { - /** * Constructs a new CompactionJobStats. */ diff --git a/java/src/main/java/org/rocksdb/CompactionOptions.java b/java/src/main/java/org/rocksdb/CompactionOptions.java index dd6dea6c561..70ff19f8669 100644 --- a/java/src/main/java/org/rocksdb/CompactionOptions.java +++ b/java/src/main/java/org/rocksdb/CompactionOptions.java @@ -13,7 +13,6 @@ * calls. */ public class CompactionOptions extends RocksObject { - /** * Constructs a new CompactionOptions. */ diff --git a/java/src/main/java/org/rocksdb/CompactionOptionsFIFO.java b/java/src/main/java/org/rocksdb/CompactionOptionsFIFO.java index d0c8ccfe9c0..6159f885c8b 100644 --- a/java/src/main/java/org/rocksdb/CompactionOptionsFIFO.java +++ b/java/src/main/java/org/rocksdb/CompactionOptionsFIFO.java @@ -9,7 +9,6 @@ * Options for FIFO Compaction */ public class CompactionOptionsFIFO extends RocksObject { - /** * Constructs a new CompactionOptionsFIFO. */ diff --git a/java/src/main/java/org/rocksdb/CompactionOptionsUniversal.java b/java/src/main/java/org/rocksdb/CompactionOptionsUniversal.java index c18a04cd65d..8d29703464a 100644 --- a/java/src/main/java/org/rocksdb/CompactionOptionsUniversal.java +++ b/java/src/main/java/org/rocksdb/CompactionOptionsUniversal.java @@ -9,7 +9,6 @@ * Options for Universal Compaction */ public class CompactionOptionsUniversal extends RocksObject { - /** * Constructs a new CompactionOptionsUniversal. */ diff --git a/java/src/main/java/org/rocksdb/CompactionReason.java b/java/src/main/java/org/rocksdb/CompactionReason.java index a6050c716a1..68828c3a9ef 100644 --- a/java/src/main/java/org/rocksdb/CompactionReason.java +++ b/java/src/main/java/org/rocksdb/CompactionReason.java @@ -9,7 +9,6 @@ * Reasons for compaction. */ public enum CompactionReason { - /** * Unknown. */ diff --git a/java/src/main/java/org/rocksdb/CompressionOptions.java b/java/src/main/java/org/rocksdb/CompressionOptions.java index eabfef5a13c..97261729211 100644 --- a/java/src/main/java/org/rocksdb/CompressionOptions.java +++ b/java/src/main/java/org/rocksdb/CompressionOptions.java @@ -9,7 +9,6 @@ * Options for Compression */ public class CompressionOptions extends RocksObject { - /** * RocksDB's generic default compression level. Internally it'll be translated * to the default compression level specific to the library being used. @@ -71,7 +70,7 @@ public CompressionOptions setLevel(final int level) { * Get the Compression "level". *

* See {@link #setLevel(int)} - * + * * @return the compression level. */ public int level() { diff --git a/java/src/main/java/org/rocksdb/ConcurrentTaskLimiter.java b/java/src/main/java/org/rocksdb/ConcurrentTaskLimiter.java index 33bbcd5ba41..b07d691380f 100644 --- a/java/src/main/java/org/rocksdb/ConcurrentTaskLimiter.java +++ b/java/src/main/java/org/rocksdb/ConcurrentTaskLimiter.java @@ -13,7 +13,8 @@ public abstract class ConcurrentTaskLimiter extends RocksObject { /** * Constructs a ConcurrentTaskLimiter. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ concurrent task limiter object. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ concurrent task limiter object. */ protected ConcurrentTaskLimiter(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/ConcurrentTaskLimiterImpl.java b/java/src/main/java/org/rocksdb/ConcurrentTaskLimiterImpl.java index 9ce48c27ef3..0de072cc76a 100644 --- a/java/src/main/java/org/rocksdb/ConcurrentTaskLimiterImpl.java +++ b/java/src/main/java/org/rocksdb/ConcurrentTaskLimiterImpl.java @@ -10,7 +10,6 @@ * Concurrent Task Limiter. */ public class ConcurrentTaskLimiterImpl extends ConcurrentTaskLimiter { - /** * Construct a new Concurrent Task Limiter. * diff --git a/java/src/main/java/org/rocksdb/DirectSlice.java b/java/src/main/java/org/rocksdb/DirectSlice.java index b5741fe636b..2b75bf30ac1 100644 --- a/java/src/main/java/org/rocksdb/DirectSlice.java +++ b/java/src/main/java/org/rocksdb/DirectSlice.java @@ -16,7 +16,6 @@ * values consider using @see org.rocksdb.Slice */ public class DirectSlice extends AbstractSlice { - /** * Constant for No Direct Slice. */ diff --git a/java/src/main/java/org/rocksdb/Filter.java b/java/src/main/java/org/rocksdb/Filter.java index b2374676e4a..82a182d8929 100644 --- a/java/src/main/java/org/rocksdb/Filter.java +++ b/java/src/main/java/org/rocksdb/Filter.java @@ -14,11 +14,11 @@ */ //TODO(AR) should be renamed FilterPolicy public abstract class Filter extends RocksObject { - /** * Constructs a filter. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ filter object. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ filter object. */ protected Filter(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/GetStatus.java b/java/src/main/java/org/rocksdb/GetStatus.java index a7ab4902f3f..0c9fbd27f8c 100644 --- a/java/src/main/java/org/rocksdb/GetStatus.java +++ b/java/src/main/java/org/rocksdb/GetStatus.java @@ -12,7 +12,6 @@ * If the target of the fetch is not big enough, this may be bigger than the contents of the target. */ public class GetStatus { - /** * The status of the request to fetch into the buffer. */ diff --git a/java/src/main/java/org/rocksdb/HashLinkedListMemTableConfig.java b/java/src/main/java/org/rocksdb/HashLinkedListMemTableConfig.java index 1ee66c4117c..f20c31459cc 100644 --- a/java/src/main/java/org/rocksdb/HashLinkedListMemTableConfig.java +++ b/java/src/main/java/org/rocksdb/HashLinkedListMemTableConfig.java @@ -15,7 +15,6 @@ * and post a warning in the LOG. */ public class HashLinkedListMemTableConfig extends MemTableConfig { - /** * The default number of buckets. */ diff --git a/java/src/main/java/org/rocksdb/HashSkipListMemTableConfig.java b/java/src/main/java/org/rocksdb/HashSkipListMemTableConfig.java index 6a250d59920..646c5277810 100644 --- a/java/src/main/java/org/rocksdb/HashSkipListMemTableConfig.java +++ b/java/src/main/java/org/rocksdb/HashSkipListMemTableConfig.java @@ -15,7 +15,6 @@ * and post a warning in the LOG. */ public class HashSkipListMemTableConfig extends MemTableConfig { - /** * The default number of buckets. */ diff --git a/java/src/main/java/org/rocksdb/HistogramType.java b/java/src/main/java/org/rocksdb/HistogramType.java index f9feb9439ac..9d3e42873a0 100644 --- a/java/src/main/java/org/rocksdb/HistogramType.java +++ b/java/src/main/java/org/rocksdb/HistogramType.java @@ -171,7 +171,7 @@ public enum HistogramType { /** * BlobDB Put/PutWithTTL/PutUntil/Write latency. - * Measured in microseconds. + * Measured in microseconds. */ BLOB_DB_WRITE_MICROS((byte) 0x23), diff --git a/java/src/main/java/org/rocksdb/ImportColumnFamilyOptions.java b/java/src/main/java/org/rocksdb/ImportColumnFamilyOptions.java index 0c5dea7de6b..100dd6eb897 100644 --- a/java/src/main/java/org/rocksdb/ImportColumnFamilyOptions.java +++ b/java/src/main/java/org/rocksdb/ImportColumnFamilyOptions.java @@ -12,7 +12,6 @@ * ExportImportFilesMetaData)}. */ public class ImportColumnFamilyOptions extends RocksObject { - /** * Constructs an ImportColumnFamilyOptions. */ diff --git a/java/src/main/java/org/rocksdb/IngestExternalFileOptions.java b/java/src/main/java/org/rocksdb/IngestExternalFileOptions.java index 85eccea5a55..2facfb02b88 100644 --- a/java/src/main/java/org/rocksdb/IngestExternalFileOptions.java +++ b/java/src/main/java/org/rocksdb/IngestExternalFileOptions.java @@ -11,7 +11,6 @@ * {@link RocksDB#ingestExternalFile(ColumnFamilyHandle, List, IngestExternalFileOptions)}. */ public class IngestExternalFileOptions extends RocksObject { - /** * Constructs an IngestExternalFileOptions. */ diff --git a/java/src/main/java/org/rocksdb/KeyMayExist.java b/java/src/main/java/org/rocksdb/KeyMayExist.java index 98d176f6d4f..a87af6a05a7 100644 --- a/java/src/main/java/org/rocksdb/KeyMayExist.java +++ b/java/src/main/java/org/rocksdb/KeyMayExist.java @@ -28,7 +28,8 @@ public int hashCode() { } /** - * Part of the return type from {@link RocksDB#keyMayExist(ColumnFamilyHandle, ByteBuffer, ByteBuffer)}. + * Part of the return type from {@link RocksDB#keyMayExist(ColumnFamilyHandle, ByteBuffer, + * ByteBuffer)}. */ public enum KeyMayExistEnum { /** diff --git a/java/src/main/java/org/rocksdb/MergeOperator.java b/java/src/main/java/org/rocksdb/MergeOperator.java index 630c400cfa9..9bf93c8b5a6 100644 --- a/java/src/main/java/org/rocksdb/MergeOperator.java +++ b/java/src/main/java/org/rocksdb/MergeOperator.java @@ -12,13 +12,13 @@ * value. */ public abstract class MergeOperator extends RocksObject { - - /** - * Constructs a MergeOperator. - * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ MergeOperator. - */ - protected MergeOperator(final long nativeHandle) { - super(nativeHandle); - } + /** + * Constructs a MergeOperator. + * + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ MergeOperator. + */ + protected MergeOperator(final long nativeHandle) { + super(nativeHandle); + } } diff --git a/java/src/main/java/org/rocksdb/MutableOptionKey.java b/java/src/main/java/org/rocksdb/MutableOptionKey.java index a46b28fdac9..c5536c08664 100644 --- a/java/src/main/java/org/rocksdb/MutableOptionKey.java +++ b/java/src/main/java/org/rocksdb/MutableOptionKey.java @@ -5,7 +5,6 @@ * Mutable Option keys. */ public interface MutableOptionKey { - /** * Types of values used for Mutable Options, */ diff --git a/java/src/main/java/org/rocksdb/OptimisticTransactionDB.java b/java/src/main/java/org/rocksdb/OptimisticTransactionDB.java index 1f0b2beb3e8..985fa9f28f1 100644 --- a/java/src/main/java/org/rocksdb/OptimisticTransactionDB.java +++ b/java/src/main/java/org/rocksdb/OptimisticTransactionDB.java @@ -207,8 +207,8 @@ public RocksDB getBaseDB() { @Override protected final native void disposeInternal(final long handle); - private static native long open(final long optionsHandle, - final String path) throws RocksDBException; + private static native long open(final long optionsHandle, final String path) + throws RocksDBException; private static native long[] open(final long handle, final String path, final byte[][] columnFamilyNames, final long[] columnFamilyOptions); private static native void closeDatabase(final long handle) throws RocksDBException; diff --git a/java/src/main/java/org/rocksdb/OptimisticTransactionOptions.java b/java/src/main/java/org/rocksdb/OptimisticTransactionOptions.java index 619db91edd3..d04814785f9 100644 --- a/java/src/main/java/org/rocksdb/OptimisticTransactionOptions.java +++ b/java/src/main/java/org/rocksdb/OptimisticTransactionOptions.java @@ -10,7 +10,6 @@ */ public class OptimisticTransactionOptions extends RocksObject implements TransactionalOptions { - /** * Constructs an OptimisticTransactionOptions. */ diff --git a/java/src/main/java/org/rocksdb/PerfContext.java b/java/src/main/java/org/rocksdb/PerfContext.java index e02f5157fe7..fa2f20e888f 100644 --- a/java/src/main/java/org/rocksdb/PerfContext.java +++ b/java/src/main/java/org/rocksdb/PerfContext.java @@ -9,11 +9,11 @@ * Performance Context. */ public class PerfContext extends RocksObject { - /** * Constructs a PerfContext. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ PerfContext. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ PerfContext. */ protected PerfContext(final long nativeHandle) { super(nativeHandle); @@ -608,7 +608,8 @@ public long getEnvReuseWritableFileNanos() { } /** - * Get the time taken in nanoseconds for creating new random access read-write file(s) in the environment. + * Get the time taken in nanoseconds for creating new random access read-write file(s) in the + * environment. * * @return the total time */ @@ -671,7 +672,8 @@ public long getEnvCreateDirNanos() { } /** - * Get the time taken in nanoseconds for creating directories(s) (only if not already existing) in the environment. + * Get the time taken in nanoseconds for creating directories(s) (only if not already existing) in + * the environment. * * @return the total time */ diff --git a/java/src/main/java/org/rocksdb/PersistentCache.java b/java/src/main/java/org/rocksdb/PersistentCache.java index 7b99eaec8a2..a34b206291e 100644 --- a/java/src/main/java/org/rocksdb/PersistentCache.java +++ b/java/src/main/java/org/rocksdb/PersistentCache.java @@ -10,7 +10,6 @@ * cache is specifically designed for persistent read cache. */ public class PersistentCache extends RocksObject { - /** * Constructs a persistent cache. * diff --git a/java/src/main/java/org/rocksdb/PlainTableConfig.java b/java/src/main/java/org/rocksdb/PlainTableConfig.java index 8c06a2120e6..cf4cf9c8eb8 100644 --- a/java/src/main/java/org/rocksdb/PlainTableConfig.java +++ b/java/src/main/java/org/rocksdb/PlainTableConfig.java @@ -13,7 +13,6 @@ *

It also support prefix hash feature.

*/ public class PlainTableConfig extends TableFormatConfig { - /** * Indicates that the key sizew can be variable length. */ diff --git a/java/src/main/java/org/rocksdb/PrepopulateBlobCache.java b/java/src/main/java/org/rocksdb/PrepopulateBlobCache.java index d2a02f6a927..e7317363f9c 100644 --- a/java/src/main/java/org/rocksdb/PrepopulateBlobCache.java +++ b/java/src/main/java/org/rocksdb/PrepopulateBlobCache.java @@ -18,7 +18,6 @@ * system since it involves network traffic and higher latencies.

*/ public enum PrepopulateBlobCache { - /** * Disable pre-populating the blob cache */ diff --git a/java/src/main/java/org/rocksdb/Priority.java b/java/src/main/java/org/rocksdb/Priority.java index ac656f9a350..44026ed67a0 100644 --- a/java/src/main/java/org/rocksdb/Priority.java +++ b/java/src/main/java/org/rocksdb/Priority.java @@ -9,7 +9,6 @@ * The Thread Pool priority. */ public enum Priority { - /** * Bottom most priority. */ diff --git a/java/src/main/java/org/rocksdb/RateLimiter.java b/java/src/main/java/org/rocksdb/RateLimiter.java index 97d9387984b..52c098349b3 100644 --- a/java/src/main/java/org/rocksdb/RateLimiter.java +++ b/java/src/main/java/org/rocksdb/RateLimiter.java @@ -12,7 +12,6 @@ * @since 3.10.0 */ public class RateLimiter extends RocksObject { - /** * The default refill period in microseconds. */ diff --git a/java/src/main/java/org/rocksdb/RateLimiterMode.java b/java/src/main/java/org/rocksdb/RateLimiterMode.java index d0bdc3882b1..68ea265d98e 100644 --- a/java/src/main/java/org/rocksdb/RateLimiterMode.java +++ b/java/src/main/java/org/rocksdb/RateLimiterMode.java @@ -9,7 +9,6 @@ * Mode for {@link RateLimiter#RateLimiter(long, long, int, RateLimiterMode)}. */ public enum RateLimiterMode { - /** * Only rate limit reads. */ diff --git a/java/src/main/java/org/rocksdb/ReadOptions.java b/java/src/main/java/org/rocksdb/ReadOptions.java index 14c42670f42..730d3bd220d 100644 --- a/java/src/main/java/org/rocksdb/ReadOptions.java +++ b/java/src/main/java/org/rocksdb/ReadOptions.java @@ -12,7 +12,6 @@ * become out-of-scope to release the allocated memory in c++. */ public class ReadOptions extends RocksObject { - /** * Constructs a ReadOptions. */ diff --git a/java/src/main/java/org/rocksdb/ReadTier.java b/java/src/main/java/org/rocksdb/ReadTier.java index b200823544c..43dd893c2ed 100644 --- a/java/src/main/java/org/rocksdb/ReadTier.java +++ b/java/src/main/java/org/rocksdb/ReadTier.java @@ -9,7 +9,6 @@ * RocksDB {@link ReadOptions} read tiers. */ public enum ReadTier { - /** * Read all tiers. */ diff --git a/java/src/main/java/org/rocksdb/RemoveEmptyValueCompactionFilter.java b/java/src/main/java/org/rocksdb/RemoveEmptyValueCompactionFilter.java index 935828d0e1d..52d0d90d4f7 100644 --- a/java/src/main/java/org/rocksdb/RemoveEmptyValueCompactionFilter.java +++ b/java/src/main/java/org/rocksdb/RemoveEmptyValueCompactionFilter.java @@ -10,7 +10,6 @@ */ public class RemoveEmptyValueCompactionFilter extends AbstractCompactionFilter { - /** * Constructs a RemoveEmptyValueCompactionFilter. */ diff --git a/java/src/main/java/org/rocksdb/RocksCallbackObject.java b/java/src/main/java/org/rocksdb/RocksCallbackObject.java index 1307911c1ee..7816b8f65da 100644 --- a/java/src/main/java/org/rocksdb/RocksCallbackObject.java +++ b/java/src/main/java/org/rocksdb/RocksCallbackObject.java @@ -22,7 +22,6 @@ */ public abstract class RocksCallbackObject extends AbstractImmutableNativeReference { - /** * An immutable reference to the value of the C++ pointer pointing to some * underlying native RocksDB C++ object that @@ -33,7 +32,8 @@ public abstract class RocksCallbackObject extends /** * Constructs a RocksCallbackObject. * - * @param nativeParameterHandles reference to the value of the C++ pointers pointing to the underlying native RocksDB C++ objects. + * @param nativeParameterHandles reference to the value of the C++ pointers pointing to the + * underlying native RocksDB C++ objects. */ protected RocksCallbackObject(final long... nativeParameterHandles) { super(true); diff --git a/java/src/main/java/org/rocksdb/RocksDB.java b/java/src/main/java/org/rocksdb/RocksDB.java index b44c3355643..4d4cd3f9e56 100644 --- a/java/src/main/java/org/rocksdb/RocksDB.java +++ b/java/src/main/java/org/rocksdb/RocksDB.java @@ -21,7 +21,6 @@ * indicates sth wrong at the RocksDB library side and the call failed. */ public class RocksDB extends RocksObject { - /** * The name of the default column family. */ diff --git a/java/src/main/java/org/rocksdb/RocksIterator.java b/java/src/main/java/org/rocksdb/RocksIterator.java index 993de5d33de..bc3f48f57fd 100644 --- a/java/src/main/java/org/rocksdb/RocksIterator.java +++ b/java/src/main/java/org/rocksdb/RocksIterator.java @@ -23,12 +23,12 @@ * @see org.rocksdb.RocksObject */ public class RocksIterator extends AbstractRocksIterator { - /** * Constructs a RocksIterator. * * @param rocksDb the database. - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ RocksIterator. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ RocksIterator. */ protected RocksIterator(final RocksDB rocksDb, final long nativeHandle) { super(rocksDb, nativeHandle); diff --git a/java/src/main/java/org/rocksdb/RocksMutableObject.java b/java/src/main/java/org/rocksdb/RocksMutableObject.java index 6312634a4d5..3a69f699657 100644 --- a/java/src/main/java/org/rocksdb/RocksMutableObject.java +++ b/java/src/main/java/org/rocksdb/RocksMutableObject.java @@ -31,7 +31,8 @@ protected RocksMutableObject() { /** * Constructs a RocksMutableObject. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ object. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ object. */ protected RocksMutableObject(final long nativeHandle) { this.nativeHandle_ = nativeHandle; @@ -99,7 +100,8 @@ protected void disposeInternal() { * All subclasses of {@code RocksObject} must * implement this to release their underlying native C++ objects. * - * @param handle reference to the value of the C++ pointer pointing to some underlying native RocksDB C++ object. + * @param handle reference to the value of the C++ pointer pointing to some underlying native + * RocksDB C++ object. */ protected abstract void disposeInternal(final long handle); } diff --git a/java/src/main/java/org/rocksdb/RocksObject.java b/java/src/main/java/org/rocksdb/RocksObject.java index a7657224cfd..9af9d41ae7a 100644 --- a/java/src/main/java/org/rocksdb/RocksObject.java +++ b/java/src/main/java/org/rocksdb/RocksObject.java @@ -28,7 +28,8 @@ public abstract class RocksObject extends AbstractImmutableNativeReference { * Constructor to be called by subclasses to set the * handle to the underlying C++ object. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ object. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ object. */ protected RocksObject(final long nativeHandle) { super(true); @@ -48,7 +49,8 @@ protected void disposeInternal() { * All subclasses of {@code RocksObject} must * implement this to release their underlying native C++ objects. * - * @param handle reference to the value of the C++ pointer pointing to some underlying native RocksDB C++ object. + * @param handle reference to the value of the C++ pointer pointing to some underlying native + * RocksDB C++ object. */ protected abstract void disposeInternal(final long handle); } diff --git a/java/src/main/java/org/rocksdb/SanityLevel.java b/java/src/main/java/org/rocksdb/SanityLevel.java index e24671c287b..f8546913a97 100644 --- a/java/src/main/java/org/rocksdb/SanityLevel.java +++ b/java/src/main/java/org/rocksdb/SanityLevel.java @@ -10,7 +10,6 @@ * The Sanity Level. */ public enum SanityLevel { - /** * None. */ diff --git a/java/src/main/java/org/rocksdb/SizeApproximationFlag.java b/java/src/main/java/org/rocksdb/SizeApproximationFlag.java index 3e2759a10bd..e4ed68562d5 100644 --- a/java/src/main/java/org/rocksdb/SizeApproximationFlag.java +++ b/java/src/main/java/org/rocksdb/SizeApproximationFlag.java @@ -10,7 +10,6 @@ * or file stats approximation or both. */ public enum SizeApproximationFlag { - /** * None */ diff --git a/java/src/main/java/org/rocksdb/SkipListMemTableConfig.java b/java/src/main/java/org/rocksdb/SkipListMemTableConfig.java index 2d73baa1a7d..113c5ad1a7c 100644 --- a/java/src/main/java/org/rocksdb/SkipListMemTableConfig.java +++ b/java/src/main/java/org/rocksdb/SkipListMemTableConfig.java @@ -5,7 +5,6 @@ * The config for skip-list memtable representation. */ public class SkipListMemTableConfig extends MemTableConfig { - /** * The default lookahead. */ diff --git a/java/src/main/java/org/rocksdb/SstFileManager.java b/java/src/main/java/org/rocksdb/SstFileManager.java index 24f85292a86..79be3405384 100644 --- a/java/src/main/java/org/rocksdb/SstFileManager.java +++ b/java/src/main/java/org/rocksdb/SstFileManager.java @@ -17,7 +17,6 @@ */ //@ThreadSafe public final class SstFileManager extends RocksObject { - /** * The default bytes-per-sec rate. */ @@ -105,8 +104,7 @@ public SstFileManager(final Env env, /*@Nullable*/ final Logger logger, public SstFileManager(final Env env, /*@Nullable*/ final Logger logger, final long rateBytesPerSec, final double maxTrashDbRatio) throws RocksDBException { - this(env, logger, rateBytesPerSec, maxTrashDbRatio, - DEFAULT_BYTES_MAX_DELETE_CHUNK); + this(env, logger, rateBytesPerSec, maxTrashDbRatio, DEFAULT_BYTES_MAX_DELETE_CHUNK); } /** diff --git a/java/src/main/java/org/rocksdb/SstFileReader.java b/java/src/main/java/org/rocksdb/SstFileReader.java index 65281004a67..7c7e25641ee 100644 --- a/java/src/main/java/org/rocksdb/SstFileReader.java +++ b/java/src/main/java/org/rocksdb/SstFileReader.java @@ -9,7 +9,6 @@ * An SST File Reader. */ public class SstFileReader extends RocksObject { - /** * Constructs an SstFileReader. * diff --git a/java/src/main/java/org/rocksdb/SstFileReaderIterator.java b/java/src/main/java/org/rocksdb/SstFileReaderIterator.java index 78ca0e9addc..0b8d8e8639c 100644 --- a/java/src/main/java/org/rocksdb/SstFileReaderIterator.java +++ b/java/src/main/java/org/rocksdb/SstFileReaderIterator.java @@ -21,12 +21,12 @@ * @see RocksObject */ public class SstFileReaderIterator extends AbstractRocksIterator { - /** * Constructs a SstFileReaderIterator. * * @param reader the SST file reader. - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ SstFileReaderIterator. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ SstFileReaderIterator. */ protected SstFileReaderIterator(final SstFileReader reader, final long nativeHandle) { super(reader, nativeHandle); diff --git a/java/src/main/java/org/rocksdb/SstPartitionerFactory.java b/java/src/main/java/org/rocksdb/SstPartitionerFactory.java index a87cfd75ffa..4e9c72bfdd9 100644 --- a/java/src/main/java/org/rocksdb/SstPartitionerFactory.java +++ b/java/src/main/java/org/rocksdb/SstPartitionerFactory.java @@ -12,7 +12,8 @@ public abstract class SstPartitionerFactory extends RocksObject { /** * Constructs a SstPartitionerFactory. * - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ SstPartitionerFactory. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ SstPartitionerFactory. */ protected SstPartitionerFactory(final long nativeHandle) { super(nativeHandle); diff --git a/java/src/main/java/org/rocksdb/SstPartitionerFixedPrefixFactory.java b/java/src/main/java/org/rocksdb/SstPartitionerFixedPrefixFactory.java index be17459f2d1..efb4940b555 100644 --- a/java/src/main/java/org/rocksdb/SstPartitionerFixedPrefixFactory.java +++ b/java/src/main/java/org/rocksdb/SstPartitionerFixedPrefixFactory.java @@ -9,7 +9,6 @@ * Fixed prefix factory. It partitions SST files using fixed prefix of the key. */ public class SstPartitionerFixedPrefixFactory extends SstPartitionerFactory { - /** * Constructs an SstPartitionerFixedPrefixFactory. * diff --git a/java/src/main/java/org/rocksdb/StateType.java b/java/src/main/java/org/rocksdb/StateType.java index 8151b098cf3..78829dbf557 100644 --- a/java/src/main/java/org/rocksdb/StateType.java +++ b/java/src/main/java/org/rocksdb/StateType.java @@ -12,7 +12,6 @@ * such as reading / writing a file or waiting for a mutex. */ public enum StateType { - /** * Unknown. */ diff --git a/java/src/main/java/org/rocksdb/Statistics.java b/java/src/main/java/org/rocksdb/Statistics.java index 0e404b79523..ee66a1a4d23 100644 --- a/java/src/main/java/org/rocksdb/Statistics.java +++ b/java/src/main/java/org/rocksdb/Statistics.java @@ -12,7 +12,6 @@ * is managed by Options class. */ public class Statistics extends RocksObject { - /** * Constructs a Statistics. */ diff --git a/java/src/main/java/org/rocksdb/Status.java b/java/src/main/java/org/rocksdb/Status.java index fa8e86bc603..11c5ceff027 100644 --- a/java/src/main/java/org/rocksdb/Status.java +++ b/java/src/main/java/org/rocksdb/Status.java @@ -100,7 +100,8 @@ public String getCodeString() { /** * Status Code. *

- * Should stay in sync with /include/rocksdb/status.h:Code and /java/rocksjni/portal.h:toJavaStatusCode + * Should stay in sync with /include/rocksdb/status.h:Code and + * /java/rocksjni/portal.h:toJavaStatusCode */ public enum Code { /** @@ -216,10 +217,10 @@ public byte getValue() { /** * Status Sub-code. *

- * should stay in sync with /include/rocksdb/status.h:SubCode and /java/rocksjni/portal.h:toJavaStatusSubCode + * should stay in sync with /include/rocksdb/status.h:SubCode and + * /java/rocksjni/portal.h:toJavaStatusSubCode */ public enum SubCode { - /** * None. */ @@ -278,7 +279,8 @@ public enum SubCode { * * @return the sub-code * - * @throws IllegalArgumentException if the {@code value} parameter does not represent a sub-code. + * @throws IllegalArgumentException if the {@code value} parameter does not represent a + * sub-code. */ public static SubCode getSubCode(final byte value) { for (final SubCode subCode : SubCode.values()) { diff --git a/java/src/main/java/org/rocksdb/TableFileCreationReason.java b/java/src/main/java/org/rocksdb/TableFileCreationReason.java index f45da28e577..eaa06245a0c 100644 --- a/java/src/main/java/org/rocksdb/TableFileCreationReason.java +++ b/java/src/main/java/org/rocksdb/TableFileCreationReason.java @@ -9,7 +9,6 @@ * Reasons for Table File creation. */ public enum TableFileCreationReason { - /** * Flush. */ diff --git a/java/src/main/java/org/rocksdb/TickerType.java b/java/src/main/java/org/rocksdb/TickerType.java index 381390678de..d42cf2d7cc7 100644 --- a/java/src/main/java/org/rocksdb/TickerType.java +++ b/java/src/main/java/org/rocksdb/TickerType.java @@ -16,919 +16,917 @@ * should descend into negative values until TICKER_ENUM_MAX reaches -128 (-0x80). */ public enum TickerType { - - /** - * total block cache misses - *

- * REQUIRES: BLOCK_CACHE_MISS == BLOCK_CACHE_INDEX_MISS + - * BLOCK_CACHE_FILTER_MISS + - * BLOCK_CACHE_DATA_MISS; - */ - BLOCK_CACHE_MISS((byte) 0x0), - - /** - * total block cache hit - *

- * REQUIRES: BLOCK_CACHE_HIT == BLOCK_CACHE_INDEX_HIT + - * BLOCK_CACHE_FILTER_HIT + - * BLOCK_CACHE_DATA_HIT; - */ - BLOCK_CACHE_HIT((byte) 0x1), - - /** - * Number of blocks added to block cache. - */ - BLOCK_CACHE_ADD((byte) 0x2), - - /** - * Number of failures when adding blocks to block cache. - */ - BLOCK_CACHE_ADD_FAILURES((byte) 0x3), - - /** - * Number of times cache miss when accessing index block from block cache. - */ - BLOCK_CACHE_INDEX_MISS((byte) 0x4), - - /** - * Number of times cache hit when accessing index block from block cache. - */ - BLOCK_CACHE_INDEX_HIT((byte) 0x5), - - /** - * # of index blocks added to block cache. - */ - BLOCK_CACHE_INDEX_ADD((byte) 0x6), - - /** - * # of bytes of index blocks inserted into cache - */ - BLOCK_CACHE_INDEX_BYTES_INSERT((byte) 0x7), - - /** - * Number of times cache miss when accessing filter block from block cache. - */ - BLOCK_CACHE_FILTER_MISS((byte) 0x9), - - /** - * Number of times cache hit when accessing filter block from block cache. - */ - BLOCK_CACHE_FILTER_HIT((byte) 0xA), - - /** - * # of filter blocks added to block cache. - */ - BLOCK_CACHE_FILTER_ADD((byte) 0xB), - - /** - * # of bytes of bloom filter blocks inserted into cache - */ - BLOCK_CACHE_FILTER_BYTES_INSERT((byte) 0xC), - - /** - * Number of times cache miss when accessing data block from block cache. - */ - BLOCK_CACHE_DATA_MISS((byte) 0xE), - - /** - * Number of times cache hit when accessing data block from block cache. - */ - BLOCK_CACHE_DATA_HIT((byte) 0xF), - - /** - * # of data blocks added to block cache. - */ - BLOCK_CACHE_DATA_ADD((byte) 0x10), - - /** - * # of bytes of data blocks inserted into cache - */ - BLOCK_CACHE_DATA_BYTES_INSERT((byte) 0x11), - - /** - * # of bytes read from cache. - */ - BLOCK_CACHE_BYTES_READ((byte) 0x12), - - /** - * # of bytes written into cache. - */ - BLOCK_CACHE_BYTES_WRITE((byte) 0x13), - - /** - * Number of times bloom filter has avoided file reads. - */ - BLOOM_FILTER_USEFUL((byte) 0x14), - - /** - * # persistent cache hit - */ - PERSISTENT_CACHE_HIT((byte) 0x15), - - /** - * # persistent cache miss - */ - PERSISTENT_CACHE_MISS((byte) 0x16), - - /** - * # total simulation block cache hits - */ - SIM_BLOCK_CACHE_HIT((byte) 0x17), - - /** - * # total simulation block cache misses - */ - SIM_BLOCK_CACHE_MISS((byte) 0x18), - - /** - * # of memtable hits. - */ - MEMTABLE_HIT((byte) 0x19), - - /** - * # of memtable misses. - */ - MEMTABLE_MISS((byte) 0x1A), - - /** - * # of Get() queries served by L0 - */ - GET_HIT_L0((byte) 0x1B), - - /** - * # of Get() queries served by L1 - */ - GET_HIT_L1((byte) 0x1C), - - /** - * # of Get() queries served by L2 and up - */ - GET_HIT_L2_AND_UP((byte) 0x1D), - - /** - * Compaction dropped the key because there is a newer entry. - */ - COMPACTION_KEY_DROP_NEWER_ENTRY((byte) 0x1E), - - /** - * Compaction dropped the key because it is obsolete. - * Also includes keys dropped for range del. - */ - COMPACTION_KEY_DROP_OBSOLETE((byte) 0x1F), - - /** - * Compaction dropped the key because it was covered by a range tombstone. - */ - COMPACTION_KEY_DROP_RANGE_DEL((byte) 0x20), - - /** - * User compaction function has dropped the key. - */ - COMPACTION_KEY_DROP_USER((byte) 0x21), - - /** - * Compaction dropped the key as all keys in range were deleted. - */ - COMPACTION_RANGE_DEL_DROP_OBSOLETE((byte) 0x22), - - /** - * Number of keys written to the database via the Put and Write call's. - */ - NUMBER_KEYS_WRITTEN((byte) 0x23), - - /** - * Number of Keys read. - */ - NUMBER_KEYS_READ((byte) 0x24), - - /** - * Number keys updated, if inplace update is enabled - */ - NUMBER_KEYS_UPDATED((byte) 0x25), - - /** - * The number of uncompressed bytes issued by DB::Put(), DB::Delete(),\ - * DB::Merge(), and DB::Write(). - */ - BYTES_WRITTEN((byte) 0x26), - - /** - * The number of uncompressed bytes read from DB::Get(). It could be - * either from memtables, cache, or table files. - *

- * For the number of logical bytes read from DB::MultiGet(), - * please use {@link #NUMBER_MULTIGET_BYTES_READ}. - */ - BYTES_READ((byte) 0x27), - - /** - * The number of calls to seek. - */ - NUMBER_DB_SEEK((byte) 0x28), - - /** - * The number of calls to next. - */ - NUMBER_DB_NEXT((byte) 0x29), - - /** - * The number of calls to prev. - */ - NUMBER_DB_PREV((byte) 0x2A), - - /** - * The number of calls to seek that returned data. - */ - NUMBER_DB_SEEK_FOUND((byte) 0x2B), - - /** - * The number of calls to next that returned data. - */ - NUMBER_DB_NEXT_FOUND((byte) 0x2C), - - /** - * The number of calls to prev that returned data. - */ - NUMBER_DB_PREV_FOUND((byte) 0x2D), - - /** - * The number of uncompressed bytes read from an iterator. - * Includes size of key and value. - */ - ITER_BYTES_READ((byte) 0x2E), - - /** - * The number of calls to open a file. - */ - NO_FILE_OPENS((byte) 0x30), - - /** - * The number of file errors. - */ - NO_FILE_ERRORS((byte) 0x31), - - /** - * Writer has to wait for compaction or flush to finish. - */ - STALL_MICROS((byte) 0x35), - - /** - * The wait time for db mutex. - *

- * Disabled by default. To enable it set stats level to {@link StatsLevel#ALL} - */ - DB_MUTEX_WAIT_MICROS((byte) 0x36), - - /** - * Number of MultiGet calls. - */ - NUMBER_MULTIGET_CALLS((byte) 0x39), - - /** - * Number of MultiGet keys read. - */ - NUMBER_MULTIGET_KEYS_READ((byte) 0x3A), - - /** - * Number of MultiGet bytes read. - */ - NUMBER_MULTIGET_BYTES_READ((byte) 0x3B), - - /** - * Number of merge failures. - */ - NUMBER_MERGE_FAILURES((byte) 0x3D), - - /** - * Number of times the bloom filter was checked before creating iterator on a - * file, and the number of times the check was useful in avoiding - * iterator creation (and thus likely IOPs). - */ - BLOOM_FILTER_PREFIX_CHECKED((byte) 0x3E), - - /** - * Number of times the bloom filter returned false, and so prevented accessing data+index blocks. - */ - BLOOM_FILTER_PREFIX_USEFUL((byte) 0x3F), - - /** - * Number of times we had to reseek inside an iteration to skip - * over large number of keys with same userkey. - */ - NUMBER_OF_RESEEKS_IN_ITERATION((byte) 0x40), - - /** - * Record the number of calls to {@link RocksDB#getUpdatesSince(long)}. Useful to keep track of - * transaction log iterator refreshes. - */ - GET_UPDATES_SINCE_CALLS((byte) 0x41), - - /** - * Number of times WAL sync is done. - */ - WAL_FILE_SYNCED((byte) 0x46), - - /** - * Number of bytes written to WAL. - */ - WAL_FILE_BYTES((byte) 0x47), - - /** - * Writes can be processed by requesting thread or by the thread at the - * head of the writers queue. - */ - WRITE_DONE_BY_SELF((byte) 0x48), - - /** - * Equivalent to writes done for others. - */ - WRITE_DONE_BY_OTHER((byte) 0x49), - - /** - * Number of Write calls that request WAL. - */ - WRITE_WITH_WAL((byte) 0x4B), - - /** - * Bytes read during compaction. - */ - COMPACT_READ_BYTES((byte) 0x4C), - - /** - * Bytes written during compaction. - */ - COMPACT_WRITE_BYTES((byte) 0x4D), - - /** - * Bytes written during flush. - */ - FLUSH_WRITE_BYTES((byte) 0x4E), - - /** - * Number of table's properties loaded directly from file, without creating - * table reader object. - */ - NUMBER_DIRECT_LOAD_TABLE_PROPERTIES((byte) 0x4F), - - /** - * Number of times supervision was acquired. - */ - NUMBER_SUPERVERSION_ACQUIRES((byte) 0x50), - - /** - * Number of times supervision was released. - */ - NUMBER_SUPERVERSION_RELEASES((byte) 0x51), - - /** - * Number of times supervision was cleaned up. - */ - NUMBER_SUPERVERSION_CLEANUPS((byte) 0x52), - - /** - * Number of block compressions executed. - */ - NUMBER_BLOCK_COMPRESSED((byte) 0x53), - - /** - * Number of block de-compressions executed. - */ - NUMBER_BLOCK_DECOMPRESSED((byte) 0x54), - - /** - * Number of blocks not compressed. - */ - @Deprecated - NUMBER_BLOCK_NOT_COMPRESSED((byte) 0x55), - - /** - * Total time spent on merge operations. - */ - MERGE_OPERATION_TOTAL_TIME((byte) 0x56), - - /** - * Total time spent on filter operations. - */ - FILTER_OPERATION_TOTAL_TIME((byte) 0x57), - - /** - * Number of row cache hits. - */ - ROW_CACHE_HIT((byte) 0x58), - - /** - * Number of row cache misses. - */ - ROW_CACHE_MISS((byte) 0x59), - - /** - * Read amplification estimate of total bytes actually used. - *

- * Read amplification can be calculated using this formula - * ({@link #READ_AMP_TOTAL_READ_BYTES} / #READ_AMP_ESTIMATE_USEFUL_BYTES) - *

- * REQUIRES: ReadOptions::read_amp_bytes_per_bit to be enabled - */ - READ_AMP_ESTIMATE_USEFUL_BYTES((byte) 0x5A), - - /** - * Read amplification estimate of total size of loaded data blocks. - *

- * Read amplification can be calculated using this formula - * (READ_AMP_TOTAL_READ_BYTES / {@link #READ_AMP_ESTIMATE_USEFUL_BYTES}) - *

- * REQUIRES: ReadOptions::read_amp_bytes_per_bit to be enabled - */ - READ_AMP_TOTAL_READ_BYTES((byte) 0x5B), - - /** - * Number of refill intervals where rate limiter's bytes are fully consumed. - */ - NUMBER_RATE_LIMITER_DRAINS((byte) 0x5C), - - /** - * Number of internal skipped during iteration - */ - NUMBER_ITER_SKIP((byte) 0x5D), - - /** - * Number of MultiGet keys found (vs number requested) - */ - NUMBER_MULTIGET_KEYS_FOUND((byte) 0x5E), - - // -0x01 to fixate the new value that incorrectly changed TICKER_ENUM_MAX - /** - * Number of iterators created. - */ - NO_ITERATOR_CREATED((byte) -0x01), - - /** - * Number of iterators deleted. - */ - NO_ITERATOR_DELETED((byte) 0x60), - - /** - * Deletions obsoleted before bottom level due to file gap optimization. - */ - COMPACTION_OPTIMIZED_DEL_DROP_OBSOLETE((byte) 0x61), - - /** - * If a compaction was cancelled in sfm to prevent ENOSPC - */ - COMPACTION_CANCELLED((byte) 0x62), - - /** - * Number of times bloom FullFilter has not avoided the reads. - */ - BLOOM_FILTER_FULL_POSITIVE((byte) 0x63), - - /** - * Number of times bloom FullFilter has not avoided the reads and data actually - * exist. - */ - BLOOM_FILTER_FULL_TRUE_POSITIVE((byte) 0x64), - - /** - * BlobDB specific stats - * # of Put/PutTTL/PutUntil to BlobDB. - */ - BLOB_DB_NUM_PUT((byte) 0x65), - - /** - * # of Write to BlobDB. - */ - BLOB_DB_NUM_WRITE((byte) 0x66), - - /** - * # of Get to BlobDB. - */ - BLOB_DB_NUM_GET((byte) 0x67), - - /** - * # of MultiGet to BlobDB. - */ - BLOB_DB_NUM_MULTIGET((byte) 0x68), - - /** - * # of Seek/SeekToFirst/SeekToLast/SeekForPrev to BlobDB iterator. - */ - BLOB_DB_NUM_SEEK((byte) 0x69), - - /** - * # of Next to BlobDB iterator. - */ - BLOB_DB_NUM_NEXT((byte) 0x6A), - - /** - * # of Prev to BlobDB iterator. - */ - BLOB_DB_NUM_PREV((byte) 0x6B), - - /** - * # of keys written to BlobDB. - */ - BLOB_DB_NUM_KEYS_WRITTEN((byte) 0x6C), - - /** - * # of keys read from BlobDB. - */ - BLOB_DB_NUM_KEYS_READ((byte) 0x6D), - - /** - * # of bytes (key + value) written to BlobDB. - */ - BLOB_DB_BYTES_WRITTEN((byte) 0x6E), - - /** - * # of bytes (keys + value) read from BlobDB. - */ - BLOB_DB_BYTES_READ((byte) 0x6F), - - /** - * # of keys written by BlobDB as non-TTL inlined value. - */ - BLOB_DB_WRITE_INLINED((byte) 0x70), - - /** - * # of keys written by BlobDB as TTL inlined value. - */ - BLOB_DB_WRITE_INLINED_TTL((byte) 0x71), - - /** - * # of keys written by BlobDB as non-TTL blob value. - */ - BLOB_DB_WRITE_BLOB((byte) 0x72), - - /** - * # of keys written by BlobDB as TTL blob value. - */ - BLOB_DB_WRITE_BLOB_TTL((byte) 0x73), - - /** - * # of bytes written to blob file. - */ - BLOB_DB_BLOB_FILE_BYTES_WRITTEN((byte) 0x74), - - /** - * # of bytes read from blob file. - */ - BLOB_DB_BLOB_FILE_BYTES_READ((byte) 0x75), - - /** - * Number of times a blob files being synced. - */ - BLOB_DB_BLOB_FILE_SYNCED((byte) 0x76), - - /** - * # of blob index evicted from base DB by BlobDB compaction filter because - * of expiration. - */ - BLOB_DB_BLOB_INDEX_EXPIRED_COUNT((byte) 0x77), - - /** - * Size of blob index evicted from base DB by BlobDB compaction filter - * because of expiration. - */ - BLOB_DB_BLOB_INDEX_EXPIRED_SIZE((byte) 0x78), - - /** - * # of blob index evicted from base DB by BlobDB compaction filter because - * of corresponding file deleted. - */ - BLOB_DB_BLOB_INDEX_EVICTED_COUNT((byte) 0x79), - - /** - * Size of blob index evicted from base DB by BlobDB compaction filter - * because of corresponding file deleted. - */ - BLOB_DB_BLOB_INDEX_EVICTED_SIZE((byte) 0x7A), - - /** - * # of blob files being garbage collected. - */ - BLOB_DB_GC_NUM_FILES((byte) 0x7B), - - /** - * # of blob files generated by garbage collection. - */ - BLOB_DB_GC_NUM_NEW_FILES((byte) 0x7C), - - /** - * # of BlobDB garbage collection failures. - */ - BLOB_DB_GC_FAILURES((byte) 0x7D), - - /** - * # of keys relocated to new blob file by garbage collection. - */ - BLOB_DB_GC_NUM_KEYS_RELOCATED((byte) -0x02), - - /** - * # of bytes relocated to new blob file by garbage collection. - */ - BLOB_DB_GC_BYTES_RELOCATED((byte) -0x05), - - /** - * # of blob files evicted because of BlobDB is full. - */ - BLOB_DB_FIFO_NUM_FILES_EVICTED((byte) -0x06), - - /** - * # of keys in the blob files evicted because of BlobDB is full. - */ - BLOB_DB_FIFO_NUM_KEYS_EVICTED((byte) -0x07), - - /** - * # of bytes in the blob files evicted because of BlobDB is full. - */ - BLOB_DB_FIFO_BYTES_EVICTED((byte) -0x08), - - /** - * These counters indicate a performance issue in WritePrepared transactions. - * We should not seem them ticking them much. - * Number of times prepare_mutex_ is acquired in the fast path. - */ - TXN_PREPARE_MUTEX_OVERHEAD((byte) -0x09), - - /** - * Number of times old_commit_map_mutex_ is acquired in the fast path. - */ - TXN_OLD_COMMIT_MAP_MUTEX_OVERHEAD((byte) -0x0A), - - /** - * Number of times we checked a batch for duplicate keys. - */ - TXN_DUPLICATE_KEY_OVERHEAD((byte) -0x0B), - - /** - * Number of times snapshot_mutex_ is acquired in the fast path. - */ - TXN_SNAPSHOT_MUTEX_OVERHEAD((byte) -0x0C), - - /** - * Number of times ::Get returned TryAgain due to expired snapshot seq - */ - TXN_GET_TRY_AGAIN((byte) -0x0D), - - /** - * # of files marked as trash by delete scheduler - */ - FILES_MARKED_TRASH((byte) -0x0E), - - /** - * # of files deleted immediately by delete scheduler - */ - FILES_DELETED_IMMEDIATELY((byte) -0x0f), - - /** - * Compaction bytes read and marked. - */ - COMPACT_READ_BYTES_MARKED((byte) -0x10), - - /** - * Periodic compaction bytes read. - */ - COMPACT_READ_BYTES_PERIODIC((byte) -0x11), - - /** - * Compaction bytes read for TTL. - */ - COMPACT_READ_BYTES_TTL((byte) -0x12), - - /** - * Compaction bytes written and marked. - */ - COMPACT_WRITE_BYTES_MARKED((byte) -0x13), - - /** - * Periodic compaction bytes written. - */ - COMPACT_WRITE_BYTES_PERIODIC((byte) -0x14), - - /** - * Compaction bytes written for TTL. - */ - COMPACT_WRITE_BYTES_TTL((byte) -0x15), - - /** - * DB error handler error count. - */ - ERROR_HANDLER_BG_ERROR_COUNT((byte) -0x16), - - /** - * DB error handler background I/O error count. - */ - ERROR_HANDLER_BG_IO_ERROR_COUNT((byte) -0x17), - - /** - * DB error handler background retryable I/O error count. - */ - ERROR_HANDLER_BG_RETRYABLE_IO_ERROR_COUNT((byte) -0x18), - - /** - * DB error handler auto-resume count. - */ - ERROR_HANDLER_AUTORESUME_COUNT((byte) -0x19), - - /** - * DB error handler auto-resume retry count. - */ - ERROR_HANDLER_AUTORESUME_RETRY_TOTAL_COUNT((byte) -0x1A), - - /** - * DB error handler auto-resume success count. - */ - ERROR_HANDLER_AUTORESUME_SUCCESS_COUNT((byte) -0x1B), - - /** - * Bytes of raw data (payload) found on memtable at flush time. - * Contains the sum of garbage payload (bytes that are discarded - * at flush time) and useful payload (bytes of data that will - * eventually be written to SSTable). - */ - MEMTABLE_PAYLOAD_BYTES_AT_FLUSH((byte) -0x1C), - /** - * Outdated bytes of data present on memtable at flush time. - */ - MEMTABLE_GARBAGE_BYTES_AT_FLUSH((byte) -0x1D), - - /** - * Number of secondary cache hits - */ - SECONDARY_CACHE_HITS((byte) -0x1E), - - /** - * Bytes read by `VerifyChecksum()` and `VerifyFileChecksums()` APIs. - */ - VERIFY_CHECKSUM_READ_BYTES((byte) -0x1F), - - /** - * Bytes read while creating backups. - */ - BACKUP_READ_BYTES((byte) -0x20), - - /** - * Bytes written while creating backups. - */ - BACKUP_WRITE_BYTES((byte) -0x21), - - /** - * Bytes read by remote compaction. - */ - REMOTE_COMPACT_READ_BYTES((byte) -0x22), - - /** - * Bytes written by remote compaction. - */ - REMOTE_COMPACT_WRITE_BYTES((byte) -0x23), - - /** - * Number of bytes read by tiered storage hot-file(s). - */ - HOT_FILE_READ_BYTES((byte) -0x24), - - /** - * Number of bytes read by tiered storage warm-file(s). - */ - WARM_FILE_READ_BYTES((byte) -0x25), - - /** - * Number of bytes read by tiered storage cold-file(s). - */ - COLD_FILE_READ_BYTES((byte) -0x26), - - /** - * Number of reads on tiered storage hot-file(s). - */ - HOT_FILE_READ_COUNT((byte) -0x27), - - /** - * Number of reads on tiered storage warm-file(s). - */ - WARM_FILE_READ_COUNT((byte) -0x28), - - /** - * Number of reads on tiered storage cold-file(s). - */ - COLD_FILE_READ_COUNT((byte) -0x29), - - /** - * Bytes read from the last level. - */ - LAST_LEVEL_READ_BYTES((byte) -0x2A), - - /** - * Number of reads on the last level. - */ - LAST_LEVEL_READ_COUNT((byte) -0x2B), - - /** - * Bytes read from non-last level(s). - */ - NON_LAST_LEVEL_READ_BYTES((byte) -0x2C), - - /** - * Number of reads from non-last level(s). - */ - NON_LAST_LEVEL_READ_COUNT((byte) -0x2D), - - /** - * Number of block checksum verifications - */ - BLOCK_CHECKSUM_COMPUTE_COUNT((byte) -0x2E), - - /** - * Number of times cache miss when accessing blob from blob cache. - */ - BLOB_DB_CACHE_MISS((byte) -0x2F), - - /** - * Number of times cache hit when accessing blob from blob cache. - */ - BLOB_DB_CACHE_HIT((byte) -0x30), - - /** - * # of data blocks added to blob cache. - */ - BLOB_DB_CACHE_ADD((byte) -0x31), - - /** - * # # of failures when adding blobs to blob cache. - */ - BLOB_DB_CACHE_ADD_FAILURES((byte) -0x32), - - /** - * # of bytes read from blob cache. - */ - BLOB_DB_CACHE_BYTES_READ((byte) -0x33), - - /** - * # of bytes written into blob cache. - */ - BLOB_DB_CACHE_BYTES_WRITE((byte) -0x34), - - /** - * Number of lookup into the prefetched tail (see - * `TABLE_OPEN_PREFETCH_TAIL_READ_BYTES`) - * that can't find its data for table open - */ - TABLE_OPEN_PREFETCH_TAIL_MISS((byte) -0x3A), - - /** - * Number of lookup into the prefetched tail (see - * `TABLE_OPEN_PREFETCH_TAIL_READ_BYTES`) - * that finds its data for table open - */ - TABLE_OPEN_PREFETCH_TAIL_HIT((byte) -0x3B), - - /** - * Number of times RocksDB detected a corruption while verifying a block - * checksum. RocksDB does not remember corruptions that happened during user - * reads so the same block corruption may be detected multiple times. - */ - BLOCK_CHECKSUM_MISMATCH_COUNT((byte) -0x3C), - - /** - * Number of times readahead is trimmed during scans when - * {@link ReadOptions#setReadaheadSize(long)} is set. - */ - READAHEAD_TRIMMED((byte) -0x3D), - - /** - * FIFO compactions that drop files of a maximum size. - */ - FIFO_MAX_SIZE_COMPACTIONS((byte) -0x3E), - - /** - * FIFO compactions that drop files exceeding a TTL. - */ - FIFO_TTL_COMPACTIONS((byte) -0x3F), - - /** - * Number of bytes prefetched during user initiated scan. - */ - PREFETCH_BYTES((byte) -0x40), - - /** - * Number of prefetched bytes that were actually useful. - */ - PREFETCH_BYTES_USEFUL((byte) -0x41), - - /** - * Number of FS reads avoided due to scan prefetching. - */ - PREFETCH_HITS((byte) -0x42), - - /** - * maximum number of ticker types. - */ - TICKER_ENUM_MAX((byte) 0x5F); - - private final byte value; - - TickerType(final byte value) { - this.value = value; - } + /** + * total block cache misses + *

+ * REQUIRES: BLOCK_CACHE_MISS == BLOCK_CACHE_INDEX_MISS + + * BLOCK_CACHE_FILTER_MISS + + * BLOCK_CACHE_DATA_MISS; + */ + BLOCK_CACHE_MISS((byte) 0x0), + + /** + * total block cache hit + *

+ * REQUIRES: BLOCK_CACHE_HIT == BLOCK_CACHE_INDEX_HIT + + * BLOCK_CACHE_FILTER_HIT + + * BLOCK_CACHE_DATA_HIT; + */ + BLOCK_CACHE_HIT((byte) 0x1), + + /** + * Number of blocks added to block cache. + */ + BLOCK_CACHE_ADD((byte) 0x2), + + /** + * Number of failures when adding blocks to block cache. + */ + BLOCK_CACHE_ADD_FAILURES((byte) 0x3), + + /** + * Number of times cache miss when accessing index block from block cache. + */ + BLOCK_CACHE_INDEX_MISS((byte) 0x4), + + /** + * Number of times cache hit when accessing index block from block cache. + */ + BLOCK_CACHE_INDEX_HIT((byte) 0x5), + + /** + * # of index blocks added to block cache. + */ + BLOCK_CACHE_INDEX_ADD((byte) 0x6), + + /** + * # of bytes of index blocks inserted into cache + */ + BLOCK_CACHE_INDEX_BYTES_INSERT((byte) 0x7), + + /** + * Number of times cache miss when accessing filter block from block cache. + */ + BLOCK_CACHE_FILTER_MISS((byte) 0x9), + + /** + * Number of times cache hit when accessing filter block from block cache. + */ + BLOCK_CACHE_FILTER_HIT((byte) 0xA), + + /** + * # of filter blocks added to block cache. + */ + BLOCK_CACHE_FILTER_ADD((byte) 0xB), + + /** + * # of bytes of bloom filter blocks inserted into cache + */ + BLOCK_CACHE_FILTER_BYTES_INSERT((byte) 0xC), + + /** + * Number of times cache miss when accessing data block from block cache. + */ + BLOCK_CACHE_DATA_MISS((byte) 0xE), + + /** + * Number of times cache hit when accessing data block from block cache. + */ + BLOCK_CACHE_DATA_HIT((byte) 0xF), + + /** + * # of data blocks added to block cache. + */ + BLOCK_CACHE_DATA_ADD((byte) 0x10), + + /** + * # of bytes of data blocks inserted into cache + */ + BLOCK_CACHE_DATA_BYTES_INSERT((byte) 0x11), + + /** + * # of bytes read from cache. + */ + BLOCK_CACHE_BYTES_READ((byte) 0x12), + + /** + * # of bytes written into cache. + */ + BLOCK_CACHE_BYTES_WRITE((byte) 0x13), + + /** + * Number of times bloom filter has avoided file reads. + */ + BLOOM_FILTER_USEFUL((byte) 0x14), + + /** + * # persistent cache hit + */ + PERSISTENT_CACHE_HIT((byte) 0x15), + + /** + * # persistent cache miss + */ + PERSISTENT_CACHE_MISS((byte) 0x16), + + /** + * # total simulation block cache hits + */ + SIM_BLOCK_CACHE_HIT((byte) 0x17), + + /** + * # total simulation block cache misses + */ + SIM_BLOCK_CACHE_MISS((byte) 0x18), + + /** + * # of memtable hits. + */ + MEMTABLE_HIT((byte) 0x19), + + /** + * # of memtable misses. + */ + MEMTABLE_MISS((byte) 0x1A), + + /** + * # of Get() queries served by L0 + */ + GET_HIT_L0((byte) 0x1B), + + /** + * # of Get() queries served by L1 + */ + GET_HIT_L1((byte) 0x1C), + + /** + * # of Get() queries served by L2 and up + */ + GET_HIT_L2_AND_UP((byte) 0x1D), + + /** + * Compaction dropped the key because there is a newer entry. + */ + COMPACTION_KEY_DROP_NEWER_ENTRY((byte) 0x1E), + + /** + * Compaction dropped the key because it is obsolete. + * Also includes keys dropped for range del. + */ + COMPACTION_KEY_DROP_OBSOLETE((byte) 0x1F), + + /** + * Compaction dropped the key because it was covered by a range tombstone. + */ + COMPACTION_KEY_DROP_RANGE_DEL((byte) 0x20), + + /** + * User compaction function has dropped the key. + */ + COMPACTION_KEY_DROP_USER((byte) 0x21), + + /** + * Compaction dropped the key as all keys in range were deleted. + */ + COMPACTION_RANGE_DEL_DROP_OBSOLETE((byte) 0x22), + + /** + * Number of keys written to the database via the Put and Write call's. + */ + NUMBER_KEYS_WRITTEN((byte) 0x23), + + /** + * Number of Keys read. + */ + NUMBER_KEYS_READ((byte) 0x24), + + /** + * Number keys updated, if inplace update is enabled + */ + NUMBER_KEYS_UPDATED((byte) 0x25), + + /** + * The number of uncompressed bytes issued by DB::Put(), DB::Delete(),\ + * DB::Merge(), and DB::Write(). + */ + BYTES_WRITTEN((byte) 0x26), + + /** + * The number of uncompressed bytes read from DB::Get(). It could be + * either from memtables, cache, or table files. + *

+ * For the number of logical bytes read from DB::MultiGet(), + * please use {@link #NUMBER_MULTIGET_BYTES_READ}. + */ + BYTES_READ((byte) 0x27), + + /** + * The number of calls to seek. + */ + NUMBER_DB_SEEK((byte) 0x28), + + /** + * The number of calls to next. + */ + NUMBER_DB_NEXT((byte) 0x29), + + /** + * The number of calls to prev. + */ + NUMBER_DB_PREV((byte) 0x2A), + + /** + * The number of calls to seek that returned data. + */ + NUMBER_DB_SEEK_FOUND((byte) 0x2B), + + /** + * The number of calls to next that returned data. + */ + NUMBER_DB_NEXT_FOUND((byte) 0x2C), + + /** + * The number of calls to prev that returned data. + */ + NUMBER_DB_PREV_FOUND((byte) 0x2D), + + /** + * The number of uncompressed bytes read from an iterator. + * Includes size of key and value. + */ + ITER_BYTES_READ((byte) 0x2E), + + /** + * The number of calls to open a file. + */ + NO_FILE_OPENS((byte) 0x30), + + /** + * The number of file errors. + */ + NO_FILE_ERRORS((byte) 0x31), + + /** + * Writer has to wait for compaction or flush to finish. + */ + STALL_MICROS((byte) 0x35), + + /** + * The wait time for db mutex. + *

+ * Disabled by default. To enable it set stats level to {@link StatsLevel#ALL} + */ + DB_MUTEX_WAIT_MICROS((byte) 0x36), + + /** + * Number of MultiGet calls. + */ + NUMBER_MULTIGET_CALLS((byte) 0x39), + + /** + * Number of MultiGet keys read. + */ + NUMBER_MULTIGET_KEYS_READ((byte) 0x3A), + + /** + * Number of MultiGet bytes read. + */ + NUMBER_MULTIGET_BYTES_READ((byte) 0x3B), + + /** + * Number of merge failures. + */ + NUMBER_MERGE_FAILURES((byte) 0x3D), + + /** + * Number of times the bloom filter was checked before creating iterator on a + * file, and the number of times the check was useful in avoiding + * iterator creation (and thus likely IOPs). + */ + BLOOM_FILTER_PREFIX_CHECKED((byte) 0x3E), + + /** + * Number of times the bloom filter returned false, and so prevented accessing data+index blocks. + */ + BLOOM_FILTER_PREFIX_USEFUL((byte) 0x3F), + + /** + * Number of times we had to reseek inside an iteration to skip + * over large number of keys with same userkey. + */ + NUMBER_OF_RESEEKS_IN_ITERATION((byte) 0x40), + + /** + * Record the number of calls to {@link RocksDB#getUpdatesSince(long)}. Useful to keep track of + * transaction log iterator refreshes. + */ + GET_UPDATES_SINCE_CALLS((byte) 0x41), + + /** + * Number of times WAL sync is done. + */ + WAL_FILE_SYNCED((byte) 0x46), + + /** + * Number of bytes written to WAL. + */ + WAL_FILE_BYTES((byte) 0x47), + + /** + * Writes can be processed by requesting thread or by the thread at the + * head of the writers queue. + */ + WRITE_DONE_BY_SELF((byte) 0x48), + + /** + * Equivalent to writes done for others. + */ + WRITE_DONE_BY_OTHER((byte) 0x49), + + /** + * Number of Write calls that request WAL. + */ + WRITE_WITH_WAL((byte) 0x4B), + + /** + * Bytes read during compaction. + */ + COMPACT_READ_BYTES((byte) 0x4C), + + /** + * Bytes written during compaction. + */ + COMPACT_WRITE_BYTES((byte) 0x4D), + + /** + * Bytes written during flush. + */ + FLUSH_WRITE_BYTES((byte) 0x4E), + + /** + * Number of table's properties loaded directly from file, without creating + * table reader object. + */ + NUMBER_DIRECT_LOAD_TABLE_PROPERTIES((byte) 0x4F), + + /** + * Number of times supervision was acquired. + */ + NUMBER_SUPERVERSION_ACQUIRES((byte) 0x50), + + /** + * Number of times supervision was released. + */ + NUMBER_SUPERVERSION_RELEASES((byte) 0x51), + + /** + * Number of times supervision was cleaned up. + */ + NUMBER_SUPERVERSION_CLEANUPS((byte) 0x52), + + /** + * Number of block compressions executed. + */ + NUMBER_BLOCK_COMPRESSED((byte) 0x53), + + /** + * Number of block de-compressions executed. + */ + NUMBER_BLOCK_DECOMPRESSED((byte) 0x54), + + /** + * Number of blocks not compressed. + */ + @Deprecated NUMBER_BLOCK_NOT_COMPRESSED((byte) 0x55), + + /** + * Total time spent on merge operations. + */ + MERGE_OPERATION_TOTAL_TIME((byte) 0x56), + + /** + * Total time spent on filter operations. + */ + FILTER_OPERATION_TOTAL_TIME((byte) 0x57), + + /** + * Number of row cache hits. + */ + ROW_CACHE_HIT((byte) 0x58), + + /** + * Number of row cache misses. + */ + ROW_CACHE_MISS((byte) 0x59), + + /** + * Read amplification estimate of total bytes actually used. + *

+ * Read amplification can be calculated using this formula + * ({@link #READ_AMP_TOTAL_READ_BYTES} / #READ_AMP_ESTIMATE_USEFUL_BYTES) + *

+ * REQUIRES: ReadOptions::read_amp_bytes_per_bit to be enabled + */ + READ_AMP_ESTIMATE_USEFUL_BYTES((byte) 0x5A), + + /** + * Read amplification estimate of total size of loaded data blocks. + *

+ * Read amplification can be calculated using this formula + * (READ_AMP_TOTAL_READ_BYTES / {@link #READ_AMP_ESTIMATE_USEFUL_BYTES}) + *

+ * REQUIRES: ReadOptions::read_amp_bytes_per_bit to be enabled + */ + READ_AMP_TOTAL_READ_BYTES((byte) 0x5B), + + /** + * Number of refill intervals where rate limiter's bytes are fully consumed. + */ + NUMBER_RATE_LIMITER_DRAINS((byte) 0x5C), + + /** + * Number of internal skipped during iteration + */ + NUMBER_ITER_SKIP((byte) 0x5D), + + /** + * Number of MultiGet keys found (vs number requested) + */ + NUMBER_MULTIGET_KEYS_FOUND((byte) 0x5E), + + // -0x01 to fixate the new value that incorrectly changed TICKER_ENUM_MAX + /** + * Number of iterators created. + */ + NO_ITERATOR_CREATED((byte) -0x01), + + /** + * Number of iterators deleted. + */ + NO_ITERATOR_DELETED((byte) 0x60), + + /** + * Deletions obsoleted before bottom level due to file gap optimization. + */ + COMPACTION_OPTIMIZED_DEL_DROP_OBSOLETE((byte) 0x61), + + /** + * If a compaction was cancelled in sfm to prevent ENOSPC + */ + COMPACTION_CANCELLED((byte) 0x62), + + /** + * Number of times bloom FullFilter has not avoided the reads. + */ + BLOOM_FILTER_FULL_POSITIVE((byte) 0x63), + + /** + * Number of times bloom FullFilter has not avoided the reads and data actually + * exist. + */ + BLOOM_FILTER_FULL_TRUE_POSITIVE((byte) 0x64), + + /** + * BlobDB specific stats + * # of Put/PutTTL/PutUntil to BlobDB. + */ + BLOB_DB_NUM_PUT((byte) 0x65), + + /** + * # of Write to BlobDB. + */ + BLOB_DB_NUM_WRITE((byte) 0x66), + + /** + * # of Get to BlobDB. + */ + BLOB_DB_NUM_GET((byte) 0x67), + + /** + * # of MultiGet to BlobDB. + */ + BLOB_DB_NUM_MULTIGET((byte) 0x68), + + /** + * # of Seek/SeekToFirst/SeekToLast/SeekForPrev to BlobDB iterator. + */ + BLOB_DB_NUM_SEEK((byte) 0x69), + + /** + * # of Next to BlobDB iterator. + */ + BLOB_DB_NUM_NEXT((byte) 0x6A), + + /** + * # of Prev to BlobDB iterator. + */ + BLOB_DB_NUM_PREV((byte) 0x6B), + + /** + * # of keys written to BlobDB. + */ + BLOB_DB_NUM_KEYS_WRITTEN((byte) 0x6C), + + /** + * # of keys read from BlobDB. + */ + BLOB_DB_NUM_KEYS_READ((byte) 0x6D), + + /** + * # of bytes (key + value) written to BlobDB. + */ + BLOB_DB_BYTES_WRITTEN((byte) 0x6E), + + /** + * # of bytes (keys + value) read from BlobDB. + */ + BLOB_DB_BYTES_READ((byte) 0x6F), + + /** + * # of keys written by BlobDB as non-TTL inlined value. + */ + BLOB_DB_WRITE_INLINED((byte) 0x70), + + /** + * # of keys written by BlobDB as TTL inlined value. + */ + BLOB_DB_WRITE_INLINED_TTL((byte) 0x71), + + /** + * # of keys written by BlobDB as non-TTL blob value. + */ + BLOB_DB_WRITE_BLOB((byte) 0x72), + + /** + * # of keys written by BlobDB as TTL blob value. + */ + BLOB_DB_WRITE_BLOB_TTL((byte) 0x73), + + /** + * # of bytes written to blob file. + */ + BLOB_DB_BLOB_FILE_BYTES_WRITTEN((byte) 0x74), + + /** + * # of bytes read from blob file. + */ + BLOB_DB_BLOB_FILE_BYTES_READ((byte) 0x75), + + /** + * Number of times a blob files being synced. + */ + BLOB_DB_BLOB_FILE_SYNCED((byte) 0x76), + + /** + * # of blob index evicted from base DB by BlobDB compaction filter because + * of expiration. + */ + BLOB_DB_BLOB_INDEX_EXPIRED_COUNT((byte) 0x77), + + /** + * Size of blob index evicted from base DB by BlobDB compaction filter + * because of expiration. + */ + BLOB_DB_BLOB_INDEX_EXPIRED_SIZE((byte) 0x78), + + /** + * # of blob index evicted from base DB by BlobDB compaction filter because + * of corresponding file deleted. + */ + BLOB_DB_BLOB_INDEX_EVICTED_COUNT((byte) 0x79), + + /** + * Size of blob index evicted from base DB by BlobDB compaction filter + * because of corresponding file deleted. + */ + BLOB_DB_BLOB_INDEX_EVICTED_SIZE((byte) 0x7A), + + /** + * # of blob files being garbage collected. + */ + BLOB_DB_GC_NUM_FILES((byte) 0x7B), + + /** + * # of blob files generated by garbage collection. + */ + BLOB_DB_GC_NUM_NEW_FILES((byte) 0x7C), + + /** + * # of BlobDB garbage collection failures. + */ + BLOB_DB_GC_FAILURES((byte) 0x7D), + + /** + * # of keys relocated to new blob file by garbage collection. + */ + BLOB_DB_GC_NUM_KEYS_RELOCATED((byte) -0x02), + + /** + * # of bytes relocated to new blob file by garbage collection. + */ + BLOB_DB_GC_BYTES_RELOCATED((byte) -0x05), + + /** + * # of blob files evicted because of BlobDB is full. + */ + BLOB_DB_FIFO_NUM_FILES_EVICTED((byte) -0x06), + + /** + * # of keys in the blob files evicted because of BlobDB is full. + */ + BLOB_DB_FIFO_NUM_KEYS_EVICTED((byte) -0x07), + + /** + * # of bytes in the blob files evicted because of BlobDB is full. + */ + BLOB_DB_FIFO_BYTES_EVICTED((byte) -0x08), + + /** + * These counters indicate a performance issue in WritePrepared transactions. + * We should not seem them ticking them much. + * Number of times prepare_mutex_ is acquired in the fast path. + */ + TXN_PREPARE_MUTEX_OVERHEAD((byte) -0x09), + + /** + * Number of times old_commit_map_mutex_ is acquired in the fast path. + */ + TXN_OLD_COMMIT_MAP_MUTEX_OVERHEAD((byte) -0x0A), + + /** + * Number of times we checked a batch for duplicate keys. + */ + TXN_DUPLICATE_KEY_OVERHEAD((byte) -0x0B), + + /** + * Number of times snapshot_mutex_ is acquired in the fast path. + */ + TXN_SNAPSHOT_MUTEX_OVERHEAD((byte) -0x0C), + + /** + * Number of times ::Get returned TryAgain due to expired snapshot seq + */ + TXN_GET_TRY_AGAIN((byte) -0x0D), + + /** + * # of files marked as trash by delete scheduler + */ + FILES_MARKED_TRASH((byte) -0x0E), + + /** + * # of files deleted immediately by delete scheduler + */ + FILES_DELETED_IMMEDIATELY((byte) -0x0f), + + /** + * Compaction bytes read and marked. + */ + COMPACT_READ_BYTES_MARKED((byte) -0x10), + + /** + * Periodic compaction bytes read. + */ + COMPACT_READ_BYTES_PERIODIC((byte) -0x11), + + /** + * Compaction bytes read for TTL. + */ + COMPACT_READ_BYTES_TTL((byte) -0x12), + + /** + * Compaction bytes written and marked. + */ + COMPACT_WRITE_BYTES_MARKED((byte) -0x13), + + /** + * Periodic compaction bytes written. + */ + COMPACT_WRITE_BYTES_PERIODIC((byte) -0x14), + + /** + * Compaction bytes written for TTL. + */ + COMPACT_WRITE_BYTES_TTL((byte) -0x15), + + /** + * DB error handler error count. + */ + ERROR_HANDLER_BG_ERROR_COUNT((byte) -0x16), + + /** + * DB error handler background I/O error count. + */ + ERROR_HANDLER_BG_IO_ERROR_COUNT((byte) -0x17), + + /** + * DB error handler background retryable I/O error count. + */ + ERROR_HANDLER_BG_RETRYABLE_IO_ERROR_COUNT((byte) -0x18), + + /** + * DB error handler auto-resume count. + */ + ERROR_HANDLER_AUTORESUME_COUNT((byte) -0x19), + + /** + * DB error handler auto-resume retry count. + */ + ERROR_HANDLER_AUTORESUME_RETRY_TOTAL_COUNT((byte) -0x1A), + + /** + * DB error handler auto-resume success count. + */ + ERROR_HANDLER_AUTORESUME_SUCCESS_COUNT((byte) -0x1B), + + /** + * Bytes of raw data (payload) found on memtable at flush time. + * Contains the sum of garbage payload (bytes that are discarded + * at flush time) and useful payload (bytes of data that will + * eventually be written to SSTable). + */ + MEMTABLE_PAYLOAD_BYTES_AT_FLUSH((byte) -0x1C), + /** + * Outdated bytes of data present on memtable at flush time. + */ + MEMTABLE_GARBAGE_BYTES_AT_FLUSH((byte) -0x1D), + + /** + * Number of secondary cache hits + */ + SECONDARY_CACHE_HITS((byte) -0x1E), + + /** + * Bytes read by `VerifyChecksum()` and `VerifyFileChecksums()` APIs. + */ + VERIFY_CHECKSUM_READ_BYTES((byte) -0x1F), + + /** + * Bytes read while creating backups. + */ + BACKUP_READ_BYTES((byte) -0x20), + + /** + * Bytes written while creating backups. + */ + BACKUP_WRITE_BYTES((byte) -0x21), + + /** + * Bytes read by remote compaction. + */ + REMOTE_COMPACT_READ_BYTES((byte) -0x22), + + /** + * Bytes written by remote compaction. + */ + REMOTE_COMPACT_WRITE_BYTES((byte) -0x23), + + /** + * Number of bytes read by tiered storage hot-file(s). + */ + HOT_FILE_READ_BYTES((byte) -0x24), + + /** + * Number of bytes read by tiered storage warm-file(s). + */ + WARM_FILE_READ_BYTES((byte) -0x25), + + /** + * Number of bytes read by tiered storage cold-file(s). + */ + COLD_FILE_READ_BYTES((byte) -0x26), + + /** + * Number of reads on tiered storage hot-file(s). + */ + HOT_FILE_READ_COUNT((byte) -0x27), + + /** + * Number of reads on tiered storage warm-file(s). + */ + WARM_FILE_READ_COUNT((byte) -0x28), + + /** + * Number of reads on tiered storage cold-file(s). + */ + COLD_FILE_READ_COUNT((byte) -0x29), + + /** + * Bytes read from the last level. + */ + LAST_LEVEL_READ_BYTES((byte) -0x2A), + + /** + * Number of reads on the last level. + */ + LAST_LEVEL_READ_COUNT((byte) -0x2B), + + /** + * Bytes read from non-last level(s). + */ + NON_LAST_LEVEL_READ_BYTES((byte) -0x2C), + + /** + * Number of reads from non-last level(s). + */ + NON_LAST_LEVEL_READ_COUNT((byte) -0x2D), + + /** + * Number of block checksum verifications + */ + BLOCK_CHECKSUM_COMPUTE_COUNT((byte) -0x2E), + + /** + * Number of times cache miss when accessing blob from blob cache. + */ + BLOB_DB_CACHE_MISS((byte) -0x2F), + + /** + * Number of times cache hit when accessing blob from blob cache. + */ + BLOB_DB_CACHE_HIT((byte) -0x30), + + /** + * # of data blocks added to blob cache. + */ + BLOB_DB_CACHE_ADD((byte) -0x31), + + /** + * # # of failures when adding blobs to blob cache. + */ + BLOB_DB_CACHE_ADD_FAILURES((byte) -0x32), + + /** + * # of bytes read from blob cache. + */ + BLOB_DB_CACHE_BYTES_READ((byte) -0x33), + + /** + * # of bytes written into blob cache. + */ + BLOB_DB_CACHE_BYTES_WRITE((byte) -0x34), + + /** + * Number of lookup into the prefetched tail (see + * `TABLE_OPEN_PREFETCH_TAIL_READ_BYTES`) + * that can't find its data for table open + */ + TABLE_OPEN_PREFETCH_TAIL_MISS((byte) -0x3A), + + /** + * Number of lookup into the prefetched tail (see + * `TABLE_OPEN_PREFETCH_TAIL_READ_BYTES`) + * that finds its data for table open + */ + TABLE_OPEN_PREFETCH_TAIL_HIT((byte) -0x3B), + + /** + * Number of times RocksDB detected a corruption while verifying a block + * checksum. RocksDB does not remember corruptions that happened during user + * reads so the same block corruption may be detected multiple times. + */ + BLOCK_CHECKSUM_MISMATCH_COUNT((byte) -0x3C), + + /** + * Number of times readahead is trimmed during scans when + * {@link ReadOptions#setReadaheadSize(long)} is set. + */ + READAHEAD_TRIMMED((byte) -0x3D), + + /** + * FIFO compactions that drop files of a maximum size. + */ + FIFO_MAX_SIZE_COMPACTIONS((byte) -0x3E), + + /** + * FIFO compactions that drop files exceeding a TTL. + */ + FIFO_TTL_COMPACTIONS((byte) -0x3F), + + /** + * Number of bytes prefetched during user initiated scan. + */ + PREFETCH_BYTES((byte) -0x40), + + /** + * Number of prefetched bytes that were actually useful. + */ + PREFETCH_BYTES_USEFUL((byte) -0x41), + + /** + * Number of FS reads avoided due to scan prefetching. + */ + PREFETCH_HITS((byte) -0x42), + + /** + * maximum number of ticker types. + */ + TICKER_ENUM_MAX((byte) 0x5F); + + private final byte value; + + TickerType(final byte value) { + this.value = value; + } /** * Returns the byte value of the enumerations value diff --git a/java/src/main/java/org/rocksdb/Transaction.java b/java/src/main/java/org/rocksdb/Transaction.java index 28c3fa3a5c9..1fc0c7a3174 100644 --- a/java/src/main/java/org/rocksdb/Transaction.java +++ b/java/src/main/java/org/rocksdb/Transaction.java @@ -2845,12 +2845,12 @@ public enum TransactionState { /** * Old misspelled variable as alias for {@link #COMMITTED}. - * Tip from https://stackoverflow.com/a/37092410/454544 + * Tip from https://stackoverflow.com/a/37092410/454544 * * @deprecated use {@link #COMMITTED} instead. */ - @Deprecated - public static final TransactionState COMMITED = COMMITTED; + @Deprecated public static final TransactionState COMMITED = COMMITTED; private final byte value; diff --git a/java/src/main/java/org/rocksdb/TransactionDBOptions.java b/java/src/main/java/org/rocksdb/TransactionDBOptions.java index 92c9fe56e0d..3b742fe7b61 100644 --- a/java/src/main/java/org/rocksdb/TransactionDBOptions.java +++ b/java/src/main/java/org/rocksdb/TransactionDBOptions.java @@ -9,7 +9,6 @@ * Options for TransactionDB. */ public class TransactionDBOptions extends RocksObject { - /** * Constructs a TransactionDB. */ @@ -117,12 +116,10 @@ public TransactionDBOptions setTransactionLockTimeout( /** * The wait timeout in milliseconds when writing a key * OUTSIDE of a transaction (ie by calling {@link RocksDB#put(byte[], byte[])}, - * {@link RocksDB#merge(byte[], byte[])}, {@link RocksDB#delete(WriteOptions, byte[])} or {@link RocksDB#write(WriteOptions, WriteBatch)} - * directly). - *

- * If 0, no waiting is done if a lock cannot instantly be acquired. - * If negative, there is no timeout and will block indefinitely when acquiring - * a lock. + * {@link RocksDB#merge(byte[], byte[])}, {@link RocksDB#delete(WriteOptions, byte[])} or {@link + * RocksDB#write(WriteOptions, WriteBatch)} directly).

If 0, no waiting is done if a lock + * cannot instantly be acquired. If negative, there is no timeout and will block indefinitely when + * acquiring a lock. * * @return the timeout in milliseconds when writing a key outside of the transaction */ @@ -134,20 +131,13 @@ public long getDefaultLockTimeout() { /** * If positive, specifies the wait timeout in milliseconds when writing a key * OUTSIDE of a transaction (ie by calling {@link RocksDB#put(byte[], byte[])}, - * {@link RocksDB#merge(byte[], byte[])}, {@link RocksDB#delete(byte[])} or {@link RocksDB#write(WriteOptions, WriteBatch)} - * directly). - *

- * If 0, no waiting is done if a lock cannot instantly be acquired. - * If negative, there is no timeout and will block indefinitely when acquiring - * a lock. - *

- * Not using a timeout can lead to deadlocks. Currently, there - * is no deadlock-detection to recover from a deadlock. While DB writes - * cannot deadlock with other DB writes, they can deadlock with a transaction. - * A negative timeout should only be used if all transactions have a small - * expiration set. - *

- * Default: 1000 + * {@link RocksDB#merge(byte[], byte[])}, {@link RocksDB#delete(byte[])} or {@link + * RocksDB#write(WriteOptions, WriteBatch)} directly).

If 0, no waiting is done if a lock + * cannot instantly be acquired. If negative, there is no timeout and will block indefinitely when + * acquiring a lock.

Not using a timeout can lead to deadlocks. Currently, there is no + * deadlock-detection to recover from a deadlock. While DB writes cannot deadlock with other DB + * writes, they can deadlock with a transaction. A negative timeout should only be used if all + * transactions have a small expiration set.

Default: 1000 * * @param defaultLockTimeout the timeout in milliseconds when writing a key * outside of the transaction diff --git a/java/src/main/java/org/rocksdb/TransactionOptions.java b/java/src/main/java/org/rocksdb/TransactionOptions.java index 9755724f128..926db348347 100644 --- a/java/src/main/java/org/rocksdb/TransactionOptions.java +++ b/java/src/main/java/org/rocksdb/TransactionOptions.java @@ -10,7 +10,6 @@ */ public class TransactionOptions extends RocksObject implements TransactionalOptions { - /** * Constructs a TransactionOptions. */ diff --git a/java/src/main/java/org/rocksdb/UInt64AddOperator.java b/java/src/main/java/org/rocksdb/UInt64AddOperator.java index b028bcc45df..c50aac7623e 100644 --- a/java/src/main/java/org/rocksdb/UInt64AddOperator.java +++ b/java/src/main/java/org/rocksdb/UInt64AddOperator.java @@ -10,12 +10,12 @@ * integer value. */ public class UInt64AddOperator extends MergeOperator { - /** - * Constructs a UInt64AddOperator. - */ - public UInt64AddOperator() { - super(newSharedUInt64AddOperator()); - } + /** + * Constructs a UInt64AddOperator. + */ + public UInt64AddOperator() { + super(newSharedUInt64AddOperator()); + } private static native long newSharedUInt64AddOperator(); @Override protected final native void disposeInternal(final long handle); diff --git a/java/src/main/java/org/rocksdb/VectorMemTableConfig.java b/java/src/main/java/org/rocksdb/VectorMemTableConfig.java index 9bbf8eed56f..d42173c81bd 100644 --- a/java/src/main/java/org/rocksdb/VectorMemTableConfig.java +++ b/java/src/main/java/org/rocksdb/VectorMemTableConfig.java @@ -5,7 +5,6 @@ * The config for vector memtable representation. */ public class VectorMemTableConfig extends MemTableConfig { - /** * The default reserved size for the Vector Mem Table. */ diff --git a/java/src/main/java/org/rocksdb/WBWIRocksIterator.java b/java/src/main/java/org/rocksdb/WBWIRocksIterator.java index 1bc51627dba..0e66fdacff6 100644 --- a/java/src/main/java/org/rocksdb/WBWIRocksIterator.java +++ b/java/src/main/java/org/rocksdb/WBWIRocksIterator.java @@ -18,7 +18,8 @@ public class WBWIRocksIterator * Constructs a WBWIRocksIterator. * * @param wbwi the write batch with index. - * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native RocksDB C++ WBWIRocksIterator. + * @param nativeHandle reference to the value of the C++ pointer pointing to the underlying native + * RocksDB C++ WBWIRocksIterator. */ protected WBWIRocksIterator(final WriteBatchWithIndex wbwi, final long nativeHandle) { @@ -79,7 +80,6 @@ final native void seekForPrevByteArray0( * that created the record in the Write Batch */ public enum WriteType { - /** * Put. */ @@ -127,11 +127,12 @@ public enum WriteType { * * @return the WriteType * - * @throws IllegalArgumentException if the {@code value} parameter does not represent a WriteType. + * @throws IllegalArgumentException if the {@code value} parameter does not represent a + * WriteType. */ public static WriteType fromId(final byte value) { for(final WriteType wt : WriteType.values()) { - if(value == wt.id) { + if (value == wt.id) { return wt; } } diff --git a/java/src/main/java/org/rocksdb/WalFilter.java b/java/src/main/java/org/rocksdb/WalFilter.java index eac7b657f18..3b04eafaca0 100644 --- a/java/src/main/java/org/rocksdb/WalFilter.java +++ b/java/src/main/java/org/rocksdb/WalFilter.java @@ -60,7 +60,6 @@ LogRecordFoundResult logRecordFound(final long logNumber, * LogFoundResult. */ class LogRecordFoundResult { - /** * Constant for continuing processing unchanged. */ diff --git a/java/src/main/java/org/rocksdb/WriteBatch.java b/java/src/main/java/org/rocksdb/WriteBatch.java index 1ac3c472da5..a46e2abb114 100644 --- a/java/src/main/java/org/rocksdb/WriteBatch.java +++ b/java/src/main/java/org/rocksdb/WriteBatch.java @@ -547,7 +547,8 @@ public long getContentFlags() { * Determines if {@link #clear()} was * called. * - * @return true if {@link #clear()} was called and the save point remains empty, false otherwise. + * @return true if {@link #clear()} was called and the save point remains empty, false + * otherwise. */ public boolean isCleared() { return (size | count | contentFlags) == 0; diff --git a/java/src/main/java/org/rocksdb/WriteBufferManager.java b/java/src/main/java/org/rocksdb/WriteBufferManager.java index 08970b158eb..0677bdf37b9 100644 --- a/java/src/main/java/org/rocksdb/WriteBufferManager.java +++ b/java/src/main/java/org/rocksdb/WriteBufferManager.java @@ -28,12 +28,12 @@ public WriteBufferManager( this.allowStall_ = allowStall; } - /** - * Construct a new instance of WriteBufferManager. - * - * @param bufferSizeBytes the buffer size in bytes. - * @param cache the cache to use. - */ + /** + * Construct a new instance of WriteBufferManager. + * + * @param bufferSizeBytes the buffer size in bytes. + * @param cache the cache to use. + */ public WriteBufferManager(final long bufferSizeBytes, final Cache cache) { this(bufferSizeBytes, cache, false); } diff --git a/java/src/main/java/org/rocksdb/WriteStallCondition.java b/java/src/main/java/org/rocksdb/WriteStallCondition.java index c91310374b1..2c011bc2e39 100644 --- a/java/src/main/java/org/rocksdb/WriteStallCondition.java +++ b/java/src/main/java/org/rocksdb/WriteStallCondition.java @@ -9,7 +9,6 @@ * Conditions that caused Write Stalls. */ public enum WriteStallCondition { - /** * Delayed. */ diff --git a/java/src/main/java/org/rocksdb/util/BufferUtil.java b/java/src/main/java/org/rocksdb/util/BufferUtil.java index 4c23cfba86e..dccf71ce236 100644 --- a/java/src/main/java/org/rocksdb/util/BufferUtil.java +++ b/java/src/main/java/org/rocksdb/util/BufferUtil.java @@ -10,7 +10,6 @@ * Utility functions for working with buffers. */ public class BufferUtil { - /** * Check the bounds for an operation on a buffer. * diff --git a/java/src/main/java/org/rocksdb/util/ByteUtil.java b/java/src/main/java/org/rocksdb/util/ByteUtil.java index 8c32668ca8b..b5139b86da3 100644 --- a/java/src/main/java/org/rocksdb/util/ByteUtil.java +++ b/java/src/main/java/org/rocksdb/util/ByteUtil.java @@ -33,7 +33,8 @@ public static byte[] bytes(final String str) { * is lexically greater than {@code y}. Note that lexical order is determined * as if comparing unsigned char arrays. *

- * Similar to memcmp.c. + * Similar to memcmp.c. * * @param x the first value to compare with * @param y the second value to compare against diff --git a/java/src/main/java/org/rocksdb/util/BytewiseComparator.java b/java/src/main/java/org/rocksdb/util/BytewiseComparator.java index fb32db3be0d..acb76c255b9 100644 --- a/java/src/main/java/org/rocksdb/util/BytewiseComparator.java +++ b/java/src/main/java/org/rocksdb/util/BytewiseComparator.java @@ -22,7 +22,6 @@ * {@link org.rocksdb.BuiltinComparator#BYTEWISE_COMPARATOR} */ public final class BytewiseComparator extends AbstractComparator { - /** * Constructs a new BytewiseComparator. * diff --git a/java/src/main/java/org/rocksdb/util/Environment.java b/java/src/main/java/org/rocksdb/util/Environment.java index f6b2fa50565..f1bbcfe927e 100644 --- a/java/src/main/java/org/rocksdb/util/Environment.java +++ b/java/src/main/java/org/rocksdb/util/Environment.java @@ -258,7 +258,6 @@ private static String getLibcPostfix() { return "-" + libcName; } - /** * Get the name as that of a JNI library. *

diff --git a/java/src/main/java/org/rocksdb/util/IntComparator.java b/java/src/main/java/org/rocksdb/util/IntComparator.java index cf3c6423f08..142e81c3a21 100644 --- a/java/src/main/java/org/rocksdb/util/IntComparator.java +++ b/java/src/main/java/org/rocksdb/util/IntComparator.java @@ -24,7 +24,6 @@ * or testing. */ public final class IntComparator extends AbstractComparator { - /** * Constructs an IntComparator. * diff --git a/java/src/main/java/org/rocksdb/util/ReverseBytewiseComparator.java b/java/src/main/java/org/rocksdb/util/ReverseBytewiseComparator.java index e145184eac6..4d0708ca077 100644 --- a/java/src/main/java/org/rocksdb/util/ReverseBytewiseComparator.java +++ b/java/src/main/java/org/rocksdb/util/ReverseBytewiseComparator.java @@ -23,7 +23,6 @@ * {@link BuiltinComparator#REVERSE_BYTEWISE_COMPARATOR} */ public final class ReverseBytewiseComparator extends AbstractComparator { - /** * Constructs a ReverseBytewiseComparator. * diff --git a/java/src/main/java/org/rocksdb/util/SizeUnit.java b/java/src/main/java/org/rocksdb/util/SizeUnit.java index 8582bb15436..89938558f24 100644 --- a/java/src/main/java/org/rocksdb/util/SizeUnit.java +++ b/java/src/main/java/org/rocksdb/util/SizeUnit.java @@ -9,7 +9,6 @@ * Simple factors of byte sizes. */ public interface SizeUnit { - /** * 1 Kilobyte. */ diff --git a/java/src/test/java/org/rocksdb/SstFileManagerTest.java b/java/src/test/java/org/rocksdb/SstFileManagerTest.java index 96c5627096d..1984b8ed35f 100644 --- a/java/src/test/java/org/rocksdb/SstFileManagerTest.java +++ b/java/src/test/java/org/rocksdb/SstFileManagerTest.java @@ -47,7 +47,8 @@ public void trackedFiles() throws RocksDBException { @Test public void deleteRateBytesPerSecond() throws RocksDBException { try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { - assertThat(sstFileManager.getDeleteRateBytesPerSecond()).isEqualTo(SstFileManager.DEFAULT_RATE_BYTES_PER_SEC); + assertThat(sstFileManager.getDeleteRateBytesPerSecond()) + .isEqualTo(SstFileManager.DEFAULT_RATE_BYTES_PER_SEC); final long ratePerSecond = 1024 * 1024 * 52; sstFileManager.setDeleteRateBytesPerSecond(ratePerSecond); assertThat(sstFileManager.getDeleteRateBytesPerSecond()).isEqualTo(ratePerSecond); @@ -57,7 +58,8 @@ public void deleteRateBytesPerSecond() throws RocksDBException { @Test public void maxTrashDBRatio() throws RocksDBException { try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { - assertThat(sstFileManager.getMaxTrashDBRatio()).isEqualTo(SstFileManager.DEFAULT_MAX_TRASH_DB_RATIO); + assertThat(sstFileManager.getMaxTrashDBRatio()) + .isEqualTo(SstFileManager.DEFAULT_MAX_TRASH_DB_RATIO); final double trashRatio = 0.2; sstFileManager.setMaxTrashDBRatio(trashRatio); assertThat(sstFileManager.getMaxTrashDBRatio()).isEqualTo(trashRatio); diff --git a/java/src/test/java/org/rocksdb/util/ByteBufferAllocator.java b/java/src/test/java/org/rocksdb/util/ByteBufferAllocator.java index c3309d78787..90f301c39fc 100644 --- a/java/src/test/java/org/rocksdb/util/ByteBufferAllocator.java +++ b/java/src/test/java/org/rocksdb/util/ByteBufferAllocator.java @@ -12,7 +12,6 @@ * Allocates for creating new buffers. */ public interface ByteBufferAllocator { - /** * Allocate a new ByteBuffer. *