diff --git a/java/org/rocksdb/AbstractComparator.java b/java/org/rocksdb/AbstractComparator.java index 5302f43b3e6c75e56c5772fedf1083c9d7bfd9a5..1abdb4774814d962b246237f6354f7367e336ed3 100644 --- a/java/org/rocksdb/AbstractComparator.java +++ b/java/org/rocksdb/AbstractComparator.java @@ -46,15 +46,18 @@ public abstract class AbstractComparator public abstract int compare(final T a, final T b); /** - * Used to reduce the space requirements - * for internal data structures like index blocks. + *

Used to reduce the space requirements + * for internal data structures like index blocks.

* - * If start < limit, you may return a new start which is a - * shorter string in [start, limit). + *

If start < limit, you may return a new start which is a + * shorter string in [start, limit).

* - * Simple comparator implementations may return null if they + *

Simple comparator implementations may return null if they * wish to use start unchanged. i.e., an implementation of - * this method that does nothing is correct. + * this method that does nothing is correct.

+ * + * @param start String + * @param limit of type T * * @return a shorter start, or null */ @@ -63,15 +66,17 @@ public abstract class AbstractComparator } /** - * Used to reduce the space requirements - * for internal data structures like index blocks. + *

Used to reduce the space requirements + * for internal data structures like index blocks.

* - * You may return a new short key (key1) where - * key1 ≥ key. + *

You may return a new short key (key1) where + * key1 ≥ key.

* - * Simple comparator implementations may return null if they + *

Simple comparator implementations may return null if they * wish to leave the key unchanged. i.e., an implementation of - * this method that does nothing is correct. + * this method that does nothing is correct.

+ * + * @param key String * * @return a shorter key, or null */ diff --git a/java/org/rocksdb/BackupableDB.java b/java/org/rocksdb/BackupableDB.java index 75683f587576c803ffbbaf19294114ef97cd1462..2644fec8fdefaa7271d23e5f2415a770a7d993f8 100644 --- a/java/org/rocksdb/BackupableDB.java +++ b/java/org/rocksdb/BackupableDB.java @@ -23,6 +23,9 @@ public class BackupableDB extends RocksDB { * @param db_path Path to store data to. The path for storing the backup should be * specified in the {@link org.rocksdb.BackupableDBOptions}. * @return BackupableDB reference to the opened database. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public static BackupableDB open( Options opt, BackupableDBOptions bopt, String db_path) @@ -45,7 +48,9 @@ public class BackupableDB extends RocksDB { * * @param flushBeforeBackup if true, then all data will be flushed * before creating backup. - * @throws org.rocksdb.RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void createNewBackup(boolean flushBeforeBackup) throws RocksDBException { @@ -56,7 +61,9 @@ public class BackupableDB extends RocksDB { * Deletes old backups, keeping latest numBackupsToKeep alive. * * @param numBackupsToKeep Number of latest backups to keep. - * @throws org.rocksdb.RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void purgeOldBackups(int numBackupsToKeep) throws RocksDBException { @@ -67,7 +74,9 @@ public class BackupableDB extends RocksDB { * Deletes a specific backup. * * @param backupId of backup to delete. - * @throws org.rocksdb.RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void deleteBackup(int backupId) throws RocksDBException { deleteBackup0(nativeHandle_, backupId); diff --git a/java/org/rocksdb/ColumnFamilyOptionsInterface.java b/java/org/rocksdb/ColumnFamilyOptionsInterface.java index fb04c249a587f7aada569bd1172d4fa60f287796..c1be7f2944bf2815bb624c3abd47fde7b6487008 100644 --- a/java/org/rocksdb/ColumnFamilyOptionsInterface.java +++ b/java/org/rocksdb/ColumnFamilyOptionsInterface.java @@ -152,7 +152,8 @@ public interface ColumnFamilyOptionsInterface { * Default: 4MB * @param writeBufferSize the size of write buffer. * @return the instance of the current Object. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setWriteBufferSize(long writeBufferSize) throws RocksDBException; @@ -223,6 +224,7 @@ public interface ColumnFamilyOptionsInterface { * extract the prefix given a key. * * @param n use the first n bytes of a key as its prefix. + * @return the reference to the current option. */ Object useFixedLengthPrefixExtractor(int n); @@ -415,6 +417,8 @@ public interface ColumnFamilyOptionsInterface { * and total file size for level-3 will be 2GB. * by default 'maxBytesForLevelBase' is 10MB. * + * @param maxBytesForLevelBase maximum bytes for level base. + * * @return the reference to the current option. * @see #setMaxBytesForLevelMultiplier(int) */ @@ -614,7 +618,8 @@ public interface ColumnFamilyOptionsInterface { * * @param arenaBlockSize the size of an arena block * @return the reference to the current option. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setArenaBlockSize(long arenaBlockSize) throws RocksDBException; @@ -762,7 +767,8 @@ public interface ColumnFamilyOptionsInterface { * * @param config the mem-table config. * @return the instance of the current Object. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setMemTableConfig(MemTableConfig config) throws RocksDBException; @@ -826,7 +832,8 @@ public interface ColumnFamilyOptionsInterface { * @param inplaceUpdateNumLocks the number of locks used for * inplace updates. * @return the reference to the current option. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setInplaceUpdateNumLocks(long inplaceUpdateNumLocks) throws RocksDBException; @@ -920,7 +927,8 @@ public interface ColumnFamilyOptionsInterface { * * @param maxSuccessiveMerges the maximum number of successive merges. * @return the reference to the current option. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setMaxSuccessiveMerges(long maxSuccessiveMerges) throws RocksDBException; diff --git a/java/org/rocksdb/DBOptionsInterface.java b/java/org/rocksdb/DBOptionsInterface.java index ca65a61468a13402a2e8c7f012ec31ee4dc65e0b..d3df483cbee2190d3fb508009e61291506546bc8 100644 --- a/java/org/rocksdb/DBOptionsInterface.java +++ b/java/org/rocksdb/DBOptionsInterface.java @@ -123,7 +123,7 @@ public interface DBOptionsInterface { * Default: 5000 * * @param maxOpenFiles the maximum number of open files. - * @return the reference to the current DBOptions. + * @return the instance of the current Object. */ Object setMaxOpenFiles(int maxOpenFiles); @@ -147,6 +147,9 @@ public interface DBOptionsInterface { *

If set to 0 (default), we will dynamically choose the WAL size limit to * be [sum of all write_buffer_size * max_write_buffer_number] * 2

*

Default: 0

+ * + * @param maxTotalWalSize max total wal size. + * @return the instance of the current Object. */ Object setMaxTotalWalSize(long maxTotalWalSize); @@ -197,7 +200,7 @@ public interface DBOptionsInterface { * * @param disableDataSync a boolean flag to specify whether to * disable data sync. - * @return the reference to the current DBOptions. + * @return the instance of the current Object. */ Object setDisableDataSync(boolean disableDataSync); @@ -370,7 +373,8 @@ public interface DBOptionsInterface { * * @param maxLogFileSize the maximum size of a info log file. * @return the instance of the current Object. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setMaxLogFileSize(long maxLogFileSize) throws RocksDBException; @@ -392,7 +396,8 @@ public interface DBOptionsInterface { * * @param logFileTimeToRoll the time interval in seconds. * @return the instance of the current Object. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setLogFileTimeToRoll(long logFileTimeToRoll) throws RocksDBException; @@ -413,7 +418,8 @@ public interface DBOptionsInterface { * * @param keepLogFileNum the maximum number of info log files to be kept. * @return the instance of the current Object. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setKeepLogFileNum(long keepLogFileNum) throws RocksDBException; @@ -584,7 +590,8 @@ public interface DBOptionsInterface { * * @param size the size in byte * @return the instance of the current Object. - * @throws org.rocksdb.RocksDBException + * @throws org.rocksdb.RocksDBException thrown on 32-Bit platforms while + * overflowing the underlying platform specific value. */ Object setManifestPreallocationSize(long size) throws RocksDBException; diff --git a/java/org/rocksdb/HashSkipListMemTableConfig.java b/java/org/rocksdb/HashSkipListMemTableConfig.java index ad2120f18adad31d70e06465b09f86d9afbac669..7dc598fc4fbc8270f14b3469dfa4444d1d7128bb 100644 --- a/java/org/rocksdb/HashSkipListMemTableConfig.java +++ b/java/org/rocksdb/HashSkipListMemTableConfig.java @@ -50,6 +50,8 @@ public class HashSkipListMemTableConfig extends MemTableConfig { /** * Set the height of the skip list. Default = 4. * + * @param height height to set. + * * @return the reference to the current HashSkipListMemTableConfig. */ public HashSkipListMemTableConfig setHeight(int height) { diff --git a/java/org/rocksdb/MemTableConfig.java b/java/org/rocksdb/MemTableConfig.java index deb74f185bf06691cace100ce54c855dbed5798f..853d2977627e6a6422b8585e611c38836b8e9f14 100644 --- a/java/org/rocksdb/MemTableConfig.java +++ b/java/org/rocksdb/MemTableConfig.java @@ -22,6 +22,11 @@ public abstract class MemTableConfig { * that associated with the Java MemTableConfig. * * @see Options#setMemTableConfig(MemTableConfig) + * + * @return native handle address to native memory table instance. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ abstract protected long newMemTableFactoryHandle() throws RocksDBException; diff --git a/java/org/rocksdb/Options.java b/java/org/rocksdb/Options.java index 2d6fa08cd61cd38b4fc37171935b1a3cb49426b7..7307608af786fdb304a248f88c60db94928c82ad 100644 --- a/java/org/rocksdb/Options.java +++ b/java/org/rocksdb/Options.java @@ -61,6 +61,9 @@ public class Options extends RocksObject * Use the specified object to interact with the environment, * e.g. to read/write files, schedule background work, etc. * Default: {@link RocksEnv#getDefault()} + * + * @param env {@link RocksEnv} instance. + * @return the instance of the current Options. */ public Options setEnv(RocksEnv env) { assert(isInitialized()); @@ -69,6 +72,11 @@ public class Options extends RocksObject return this; } + /** + * Returns the set RocksEnv instance. + * + * @return {@link RocksEnv} instance set in the Options. + */ public RocksEnv getEnv() { return env_; } diff --git a/java/org/rocksdb/RateLimiterConfig.java b/java/org/rocksdb/RateLimiterConfig.java index 06f3990d0dd5062225cce3c2aee448180b41a3f4..09d1c7a04afe001a91f33c3b0e6dace642642164 100644 --- a/java/org/rocksdb/RateLimiterConfig.java +++ b/java/org/rocksdb/RateLimiterConfig.java @@ -16,6 +16,8 @@ public abstract class RateLimiterConfig { * with a Java RateLimiterConfig. * * @see org.rocksdb.DBOptions#setRateLimiter(long, long) + * + * @return native handle address to rate limiter instance. */ abstract protected long newRateLimiterHandle(); } diff --git a/java/org/rocksdb/RestoreBackupableDB.java b/java/org/rocksdb/RestoreBackupableDB.java index 207383e431ffb78ec7854477ce1169ff1ff7a2b4..ffbc2e0112f24a676838b5dab9c6abeee81eebe0 100644 --- a/java/org/rocksdb/RestoreBackupableDB.java +++ b/java/org/rocksdb/RestoreBackupableDB.java @@ -40,8 +40,10 @@ public class RestoreBackupableDB extends RocksObject { * @param backupId id pointing to backup * @param dbDir database directory to restore to * @param walDir directory where wal files are located - * @param restoreOptions {@link org.rocksdb.RestoreOptions} instance - * @throws RocksDBException + * @param restoreOptions {@link org.rocksdb.RestoreOptions} instance. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void restoreDBFromBackup(long backupId, String dbDir, String walDir, RestoreOptions restoreOptions) throws RocksDBException { @@ -55,7 +57,9 @@ public class RestoreBackupableDB extends RocksObject { * @param dbDir database directory to restore to * @param walDir directory where wal files are located * @param restoreOptions {@link org.rocksdb.RestoreOptions} instance - * @throws RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void restoreDBFromLatestBackup(String dbDir, String walDir, RestoreOptions restoreOptions) throws RocksDBException { @@ -67,7 +71,9 @@ public class RestoreBackupableDB extends RocksObject { * Deletes old backups, keeping latest numBackupsToKeep alive. * * @param numBackupsToKeep of latest backups to keep - * @throws org.rocksdb.RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void purgeOldBackups(int numBackupsToKeep) throws RocksDBException { purgeOldBackups0(nativeHandle_, numBackupsToKeep); @@ -77,7 +83,9 @@ public class RestoreBackupableDB extends RocksObject { * Deletes a specific backup. * * @param backupId of backup to delete. - * @throws org.rocksdb.RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void deleteBackup(int backupId) throws RocksDBException { deleteBackup0(nativeHandle_, backupId); diff --git a/java/org/rocksdb/RocksDB.java b/java/org/rocksdb/RocksDB.java index c3b8072a2df5f7e74011e3c1e141e5f5938b6ba3..5ebbc609ef9aa8f802adc03b2d02a5ecfb765912 100644 --- a/java/org/rocksdb/RocksDB.java +++ b/java/org/rocksdb/RocksDB.java @@ -95,7 +95,8 @@ public class RocksDB extends RocksObject { * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. * - * @throws org.rocksdb.RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. * @see Options#setCreateIfMissing(boolean) */ public static RocksDB open(String path) throws RocksDBException { @@ -130,7 +131,8 @@ public class RocksDB extends RocksObject { * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. * - * @throws org.rocksdb.RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. * @see DBOptions#setCreateIfMissing(boolean) */ public static RocksDB open(String path, @@ -161,7 +163,9 @@ public class RocksDB extends RocksObject { * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. * - * @throws org.rocksdb.RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. + * * @see Options#setCreateIfMissing(boolean) */ public static RocksDB open(Options options, String path) @@ -206,7 +210,9 @@ public class RocksDB extends RocksObject { * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. * - * @throws org.rocksdb.RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. + * * @see DBOptions#setCreateIfMissing(boolean) */ public static RocksDB open(DBOptions options, String path, @@ -231,7 +237,9 @@ public class RocksDB extends RocksObject { * @param path the path to the RocksDB. * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. - * @throws RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public static RocksDB openReadOnly(String path) throws RocksDBException { @@ -252,7 +260,9 @@ public class RocksDB extends RocksObject { * on open. * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. - * @throws RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public static RocksDB openReadOnly(String path, List columnFamilyDescriptors, @@ -277,7 +287,9 @@ public class RocksDB extends RocksObject { * @param path the path to the RocksDB. * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. - * @throws RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public static RocksDB openReadOnly(Options options, String path) throws RocksDBException { @@ -309,7 +321,9 @@ public class RocksDB extends RocksObject { * on open. * @return a {@link RocksDB} instance on success, null if the specified * {@link RocksDB} can not be opened. - * @throws RocksDBException + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public static RocksDB openReadOnly(DBOptions options, String path, List columnFamilyDescriptors, @@ -336,7 +350,8 @@ public class RocksDB extends RocksObject { * @param path Absolute path to rocksdb database * @return List<byte[]> List containing the column family names * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public static List listColumnFamilies(Options options, String path) throws RocksDBException { @@ -366,7 +381,8 @@ public class RocksDB extends RocksObject { * @param key the specified key to be inserted. * @param value the value associated with the specified key. * - * @see RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void put(byte[] key, byte[] value) throws RocksDBException { put(nativeHandle_, key, key.length, value, value.length); @@ -383,7 +399,8 @@ public class RocksDB extends RocksObject { * * throws IllegalArgumentException if column family is not present * - * @see RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void put(ColumnFamilyHandle columnFamilyHandle, byte[] key, byte[] value) throws RocksDBException { @@ -394,10 +411,12 @@ public class RocksDB extends RocksObject { /** * Set the database entry for "key" to "value". * + * @param writeOpts {@link org.rocksdb.WriteOptions} instance. * @param key the specified key to be inserted. * @param value the value associated with the specified key. * - * @see RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void put(WriteOptions writeOpts, byte[] key, byte[] value) throws RocksDBException { @@ -411,12 +430,14 @@ public class RocksDB extends RocksObject { * * @param columnFamilyHandle {@link org.rocksdb.ColumnFamilyHandle} * instance + * @param writeOpts {@link org.rocksdb.WriteOptions} instance. * @param key the specified key to be inserted. * @param value the value associated with the specified key. * * throws IllegalArgumentException if column family is not present * - * @see RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. * @see IllegalArgumentException */ public void put(ColumnFamilyHandle columnFamilyHandle, WriteOptions writeOpts, @@ -506,7 +527,8 @@ public class RocksDB extends RocksObject { * @param writeOpts WriteOptions instance * @param updates WriteBatch instance * - * @see RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void write(WriteOptions writeOpts, WriteBatch updates) throws RocksDBException { @@ -517,8 +539,11 @@ public class RocksDB extends RocksObject { * Add merge operand for key/value pair. * * @param key the specified key to be merged. - * @param value the value to be nerged with the current value for + * @param value the value to be merged with the current value for * the specified key. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void merge(byte[] key, byte[] value) throws RocksDBException { merge(nativeHandle_, key, key.length, value, value.length); @@ -529,8 +554,11 @@ public class RocksDB extends RocksObject { * * @param columnFamilyHandle {@link ColumnFamilyHandle} instance * @param key the specified key to be merged. - * @param value the value to be nerged with the current value for + * @param value the value to be merged with the current value for * the specified key. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void merge(ColumnFamilyHandle columnFamilyHandle, byte[] key, byte[] value) throws RocksDBException { @@ -545,6 +573,9 @@ public class RocksDB extends RocksObject { * @param key the specified key to be merged. * @param value the value to be merged with the current value for * the specified key. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void merge(WriteOptions writeOpts, byte[] key, byte[] value) throws RocksDBException { @@ -560,6 +591,9 @@ public class RocksDB extends RocksObject { * @param key the specified key to be merged. * @param value the value to be merged with the current value for * the specified key. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void merge(ColumnFamilyHandle columnFamilyHandle, WriteOptions writeOpts, byte[] key, byte[] value) @@ -580,7 +614,8 @@ public class RocksDB extends RocksObject { * be returned. RocksDB.NOT_FOUND will be returned if the value not * found. * - * @see RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public int get(byte[] key, byte[] value) throws RocksDBException { return get(nativeHandle_, key, key.length, value, value.length); @@ -600,7 +635,8 @@ public class RocksDB extends RocksObject { * be returned. RocksDB.NOT_FOUND will be returned if the value not * found. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public int get(ColumnFamilyHandle columnFamilyHandle, byte[] key, byte[] value) throws RocksDBException, IllegalArgumentException { @@ -611,6 +647,7 @@ public class RocksDB extends RocksObject { /** * Get the value associated with the specified key. * + * @param opt {@link org.rocksdb.ReadOptions} instance. * @param key the key to retrieve the value. * @param value the out-value to receive the retrieved value. * @return The size of the actual value that matches the specified @@ -620,7 +657,8 @@ public class RocksDB extends RocksObject { * be returned. RocksDB.NOT_FOUND will be returned if the value not * found. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public int get(ReadOptions opt, byte[] key, byte[] value) throws RocksDBException { @@ -632,6 +670,7 @@ public class RocksDB extends RocksObject { * * @param columnFamilyHandle {@link org.rocksdb.ColumnFamilyHandle} * instance + * @param opt {@link org.rocksdb.ReadOptions} instance. * @param key the key to retrieve the value. * @param value the out-value to receive the retrieved value. * @return The size of the actual value that matches the specified @@ -641,7 +680,8 @@ public class RocksDB extends RocksObject { * be returned. RocksDB.NOT_FOUND will be returned if the value not * found. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public int get(ColumnFamilyHandle columnFamilyHandle, ReadOptions opt, byte[] key, byte[] value) throws RocksDBException { @@ -658,7 +698,8 @@ public class RocksDB extends RocksObject { * @return a byte array storing the value associated with the input key if * any. null if it does not find the specified key. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public byte[] get(byte[] key) throws RocksDBException { return get(nativeHandle_, key, key.length); @@ -675,7 +716,8 @@ public class RocksDB extends RocksObject { * @return a byte array storing the value associated with the input key if * any. null if it does not find the specified key. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public byte[] get(ColumnFamilyHandle columnFamilyHandle, byte[] key) throws RocksDBException { @@ -692,7 +734,8 @@ public class RocksDB extends RocksObject { * @return a byte array storing the value associated with the input key if * any. null if it does not find the specified key. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public byte[] get(ReadOptions opt, byte[] key) throws RocksDBException { return get(nativeHandle_, opt.nativeHandle_, key, key.length); @@ -710,7 +753,8 @@ public class RocksDB extends RocksObject { * @return a byte array storing the value associated with the input key if * any. null if it does not find the specified key. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public byte[] get(ColumnFamilyHandle columnFamilyHandle, ReadOptions opt, byte[] key) throws RocksDBException { @@ -725,7 +769,8 @@ public class RocksDB extends RocksObject { * @return Map where key of map is the key passed by user and value for map * entry is the corresponding value in DB. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public Map multiGet(List keys) throws RocksDBException { @@ -759,8 +804,10 @@ public class RocksDB extends RocksObject { * @return Map where key of map is the key passed by user and value for map * entry is the corresponding value in DB. * - * @throws RocksDBException - * @throws IllegalArgumentException + * @throws RocksDBException thrown if error happens in underlying + * native library. + * @throws IllegalArgumentException thrown if the size of passed keys is not + * equal to the amount of passed column family handles. */ public Map multiGet(List columnFamilyHandleList, List keys) throws RocksDBException, IllegalArgumentException { @@ -792,7 +839,8 @@ public class RocksDB extends RocksObject { * @return Map where key of map is the key passed by user and value for map * entry is the corresponding value in DB. * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public Map multiGet(ReadOptions opt, List keys) throws RocksDBException { @@ -827,8 +875,10 @@ public class RocksDB extends RocksObject { * @return Map where key of map is the key passed by user and value for map * entry is the corresponding value in DB. * - * @throws RocksDBException - * @throws java.lang.IllegalArgumentException + * @throws RocksDBException thrown if error happens in underlying + * native library. + * @throws IllegalArgumentException thrown if the size of passed keys is not + * equal to the amount of passed column family handles. */ public Map multiGet(ReadOptions opt, List columnFamilyHandleList, List keys) @@ -862,7 +912,8 @@ public class RocksDB extends RocksObject { * * @param key Key to delete within database * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void remove(byte[] key) throws RocksDBException { remove(nativeHandle_, key, key.length); @@ -877,7 +928,8 @@ public class RocksDB extends RocksObject { * instance * @param key Key to delete within database * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void remove(ColumnFamilyHandle columnFamilyHandle, byte[] key) throws RocksDBException { @@ -892,7 +944,8 @@ public class RocksDB extends RocksObject { * @param writeOpt WriteOptions to be used with delete operation * @param key Key to delete within database * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void remove(WriteOptions writeOpt, byte[] key) throws RocksDBException { @@ -909,7 +962,8 @@ public class RocksDB extends RocksObject { * @param writeOpt WriteOptions to be used with delete operation * @param key Key to delete within database * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void remove(ColumnFamilyHandle columnFamilyHandle, WriteOptions writeOpt, byte[] key) throws RocksDBException { @@ -940,7 +994,8 @@ public class RocksDB extends RocksObject { * @param property to be fetched. See above for examples * @return property value * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public String getProperty(ColumnFamilyHandle columnFamilyHandle, String property) throws RocksDBException { @@ -967,7 +1022,8 @@ public class RocksDB extends RocksObject { * @param property to be fetched. See above for examples * @return property value * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public String getProperty(String property) throws RocksDBException { return getProperty0(nativeHandle_, property, property.length()); @@ -997,7 +1053,7 @@ public class RocksDB extends RocksObject { *

nullptr will be returned if the DB fails to take a snapshot or does * not support snapshot.

* - * @return Snapshot + * @return Snapshot {@link Snapshot} instance */ public Snapshot getSnapshot() { long snapshotHandle = getSnapshot(nativeHandle_); @@ -1046,7 +1102,8 @@ public class RocksDB extends RocksObject { * @return {@link java.util.List} containing {@link org.rocksdb.RocksIterator} * instances * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public List newIterators( List columnFamilyHandleList) throws RocksDBException { @@ -1066,8 +1123,10 @@ public class RocksDB extends RocksObject { * The ColumnFamilyHandle is automatically disposed with DB disposal. * * @param columnFamilyDescriptor column family to be created. - * @return {@link org.rocksdb.ColumnFamilyHandle} instance - * @see RocksDBException + * @return {@link org.rocksdb.ColumnFamilyHandle} instance. + * + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public ColumnFamilyHandle createColumnFamily( ColumnFamilyDescriptor columnFamilyDescriptor) @@ -1084,7 +1143,8 @@ public class RocksDB extends RocksObject { * @param columnFamilyHandle {@link org.rocksdb.ColumnFamilyHandle} * instance * - * @throws RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void dropColumnFamily(ColumnFamilyHandle columnFamilyHandle) throws RocksDBException, IllegalArgumentException { diff --git a/java/org/rocksdb/RocksEnv.java b/java/org/rocksdb/RocksEnv.java index a9b01ab72640e42d0ad4fa7af21157d2c78b58f1..5bbf4fb3dc425f901fa1681a76cc9411c1d5c95f 100644 --- a/java/org/rocksdb/RocksEnv.java +++ b/java/org/rocksdb/RocksEnv.java @@ -29,6 +29,8 @@ public class RocksEnv extends RocksObject { * belongs to rocksdb c++. As a result, the returned RocksEnv will not * have the ownership of its c++ resource, and calling its dispose() * will be no-op.

+ * + * @return the default {@link org.rocksdb.RocksEnv} instance. */ public static RocksEnv getDefault() { return default_env_; @@ -38,6 +40,10 @@ public class RocksEnv extends RocksObject { *

Sets the number of background worker threads of the flush pool * for this environment.

*

Default number: 1

+ * + * @param num the number of threads + * + * @return current {@link org.rocksdb.RocksEnv} instance. */ public RocksEnv setBackgroundThreads(int num) { return setBackgroundThreads(num, FLUSH_POOL); @@ -52,6 +58,7 @@ public class RocksEnv extends RocksObject { * FLUSH_POOL or COMPACTION_POOL. * *

Default number: 1

+ * @return current {@link org.rocksdb.RocksEnv} instance. */ public RocksEnv setBackgroundThreads(int num, int poolID) { setBackgroundThreads(nativeHandle_, num, poolID); @@ -66,6 +73,8 @@ public class RocksEnv extends RocksObject { * * @param poolID the id to specified a thread pool. Should be either * FLUSH_POOL or COMPACTION_POOL. + * + * @return the thread pool queue length. */ public int getThreadPoolQueueLen(int poolID) { return getThreadPoolQueueLen(nativeHandle_, poolID); diff --git a/java/org/rocksdb/RocksIterator.java b/java/org/rocksdb/RocksIterator.java index acfdd3b8c0a00acd07fb828cde9b869c3f98dfc8..fee3f459dc098e7965277d7e7ad726ccd6ce82c6 100644 --- a/java/org/rocksdb/RocksIterator.java +++ b/java/org/rocksdb/RocksIterator.java @@ -112,6 +112,9 @@ public class RocksIterator extends RocksObject { *

Position at the first key in the source that at or past target * The iterator is valid after this call iff the source contains * an entry that comes at or past target.

+ * + * @param target byte array describing a key or a + * key prefix to seek for. */ public void seek(byte[] target) { assert(isInitialized()); @@ -123,7 +126,8 @@ public class RocksIterator extends RocksObject { * If non-blocking IO is requested and this operation cannot be * satisfied without doing some IO, then this returns Status::Incomplete(). * - * @throws org.rocksdb.RocksDBException + * @throws RocksDBException thrown if error happens in underlying + * native library. */ public void status() throws RocksDBException { assert(isInitialized()); diff --git a/java/org/rocksdb/RocksObject.java b/java/org/rocksdb/RocksObject.java index 51b7fb8908159e6900aae499867a5d13eb07f2de..6e24a13852b33ea12693c11f4261da5c2df2f84a 100644 --- a/java/org/rocksdb/RocksObject.java +++ b/java/org/rocksdb/RocksObject.java @@ -37,7 +37,7 @@ public abstract class RocksObject { * small in that they seems to only hold a long variable. As a result, * they might have low priority in the GC process. To prevent this, * it is suggested to call {@code dispose()} manually. - *

+ *

*

* Note that once an instance of {@code RocksObject} has been disposed, * calling its function will lead undefined behavior. diff --git a/java/org/rocksdb/Slice.java b/java/org/rocksdb/Slice.java index fe5d8d49d4989f788d97f3bfd9fd4069c75077c4..0dfa12ee7761170d9e860ae614055f5ad99fd298 100644 --- a/java/org/rocksdb/Slice.java +++ b/java/org/rocksdb/Slice.java @@ -6,26 +6,26 @@ package org.rocksdb; /** - * Base class for slices which will receive - * byte[] based access to the underlying data. + *

Base class for slices which will receive + * byte[] based access to the underlying data.

* - * byte[] backed slices typically perform better with + *

byte[] backed slices typically perform better with * small keys and values. When using larger keys and - * values consider using @see org.rocksdb.DirectSlice + * values consider using {@link org.rocksdb.DirectSlice}

*/ public class Slice extends AbstractSlice { /** - * Called from JNI to construct a new Java Slice + *

Called from JNI to construct a new Java Slice * without an underlying C++ object set - * at creation time. + * at creation time.

* - * Note: You should be aware that + *

Note: You should be aware that * {@see org.rocksdb.RocksObject#disOwnNativeHandle()} is intentionally * called from the default Slice constructor, and that it is marked as * private. This is so that developers cannot construct their own default * Slice objects (at present). As developers cannot construct their own * Slice objects through this, they are not creating underlying C++ Slice - * objects, and so there is nothing to free (dispose) from Java. + * objects, and so there is nothing to free (dispose) from Java.

*/ private Slice() { super(); @@ -33,9 +33,10 @@ public class Slice extends AbstractSlice { } /** - * Constructs a slice - * where the data is taken from - * a String. + *

Constructs a slice where the data is taken from + * a String.

+ * + * @param str String value. */ public Slice(final String str) { super(); @@ -43,9 +44,11 @@ public class Slice extends AbstractSlice { } /** - * Constructs a slice - * where the data is a copy of - * the byte array from a specific offset. + *

Constructs a slice where the data is a copy of + * the byte array from a specific offset.

+ * + * @param data byte array. + * @param offset offset within the byte array. */ public Slice(final byte[] data, final int offset) { super(); @@ -53,9 +56,10 @@ public class Slice extends AbstractSlice { } /** - * Constructs a slice - * where the data is a copy of - * the byte array. + *

Constructs a slice where the data is a copy of + * the byte array.

+ * + * @param data byte array. */ public Slice(final byte[] data) { super(); @@ -63,8 +67,8 @@ public class Slice extends AbstractSlice { } /** - * Deletes underlying C++ slice pointer - * and any buffered data. + *

Deletes underlying C++ slice pointer + * and any buffered data.

* *

* Note that this function should be called only after all diff --git a/java/org/rocksdb/StatisticsCollector.java b/java/org/rocksdb/StatisticsCollector.java index dc83e7c88dd15277e5faba861d862cae7a1fe1f3..be8f26a1463152bfd72af81608375e61d57e13cd 100644 --- a/java/org/rocksdb/StatisticsCollector.java +++ b/java/org/rocksdb/StatisticsCollector.java @@ -49,6 +49,7 @@ public class StatisticsCollector { * * @param shutdownTimeout Time in milli-seconds to wait for shutdown before * killing the collection process. + * @throws java.lang.InterruptedException thrown if Threads are interrupted. */ public void shutDown(int shutdownTimeout) throws InterruptedException { _isRunning = false; diff --git a/java/org/rocksdb/TableFormatConfig.java b/java/org/rocksdb/TableFormatConfig.java index e5c63411fd5e7bdc7089faefe6934504bc447127..58a533b22a72177a272138288c65d05591e8c64d 100644 --- a/java/org/rocksdb/TableFormatConfig.java +++ b/java/org/rocksdb/TableFormatConfig.java @@ -12,9 +12,11 @@ package org.rocksdb; */ public abstract class TableFormatConfig { /** - * This function should only be called by Options.setTableFormatConfig(), + *

This function should only be called by Options.setTableFormatConfig(), * which will create a c++ shared-pointer to the c++ TableFactory - * that associated with the Java TableFormatConfig. + * that associated with the Java TableFormatConfig.

+ * + * @return native handle address to native table instance. */ abstract protected long newTableFactoryHandle(); } diff --git a/java/org/rocksdb/WriteBatch.java b/java/org/rocksdb/WriteBatch.java index 19984b16c67173873d83ac3e2a742c401b0e01aa..5bd1119dae23b1091ce18c7f35bbb9942b859605 100644 --- a/java/org/rocksdb/WriteBatch.java +++ b/java/org/rocksdb/WriteBatch.java @@ -23,11 +23,19 @@ package org.rocksdb; * external synchronization. */ public class WriteBatch extends RocksObject { + /** + * Constructs a WriteBatch instance. + */ public WriteBatch() { super(); newWriteBatch(0); } + /** + * Constructs a WriteBatch instance with a given size. + * + * @param reserved_bytes reserved size for WriteBatch + */ public WriteBatch(int reserved_bytes) { nativeHandle_ = 0; newWriteBatch(reserved_bytes); @@ -35,19 +43,29 @@ public class WriteBatch extends RocksObject { /** * Returns the number of updates in the batch. + * + * @return number of items in WriteBatch */ public native int count(); /** - * Store the mapping "key->value" in the database. + *

Store the mapping "key->value" in the database.

+ * + * @param key the specified key to be inserted. + * @param value the value associated with the specified key. */ public void put(byte[] key, byte[] value) { put(key, key.length, value, value.length); } /** - * Store the mapping "key->value" within given column - * family. + *

Store the mapping "key->value" within given column + * family.

+ * + * @param columnFamilyHandle {@link org.rocksdb.ColumnFamilyHandle} + * instance + * @param key the specified key to be inserted. + * @param value the value associated with the specified key. */ public void put(ColumnFamilyHandle columnFamilyHandle, byte[] key, byte[] value) { @@ -56,16 +74,25 @@ public class WriteBatch extends RocksObject { } /** - * Merge "value" with the existing value of "key" in the database. - * "key->merge(existing, value)" + *

Merge "value" with the existing value of "key" in the database. + * "key->merge(existing, value)"

+ * + * @param key the specified key to be merged. + * @param value the value to be merged with the current value for + * the specified key. */ public void merge(byte[] key, byte[] value) { merge(key, key.length, value, value.length); } /** - * Merge "value" with the existing value of "key" in given column family. - * "key->merge(existing, value)" + *

Merge "value" with the existing value of "key" in given column family. + * "key->merge(existing, value)"

+ * + * @param columnFamilyHandle {@link ColumnFamilyHandle} instance + * @param key the specified key to be merged. + * @param value the value to be merged with the current value for + * the specified key. */ public void merge(ColumnFamilyHandle columnFamilyHandle, byte[] key, byte[] value) { @@ -74,14 +101,19 @@ public class WriteBatch extends RocksObject { } /** - * If the database contains a mapping for "key", erase it. Else do nothing. + *

If the database contains a mapping for "key", erase it. Else do nothing.

+ * + * @param key Key to delete within database */ public void remove(byte[] key) { remove(key, key.length); } /** - * If column family contains a mapping for "key", erase it. Else do nothing. + *

If column family contains a mapping for "key", erase it. Else do nothing.

+ * + * @param columnFamilyHandle {@link ColumnFamilyHandle} instance + * @param key Key to delete within database */ public void remove(ColumnFamilyHandle columnFamilyHandle, byte[] key) { remove(key, key.length, columnFamilyHandle.nativeHandle_); @@ -98,6 +130,8 @@ public class WriteBatch extends RocksObject { * * Example application: add timestamps to the transaction log for use in * replication. + * + * @param blob binary object to be inserted */ public void putLogData(byte[] blob) { putLogData(blob, blob.length); @@ -166,6 +200,9 @@ public class WriteBatch extends RocksObject { * iteration is halted. Otherwise, it continues * iterating. The default implementation always * returns true. + * + * @return boolean value indicating if the + * iteration is halted. */ public boolean shouldContinue() { return true; diff --git a/java/org/rocksdb/WriteOptions.java b/java/org/rocksdb/WriteOptions.java index d26dbb918c396c6060177eee0375f64f27b8150f..6d7ea4c30ba635ee4c61ffdf7b2c48f942443e0d 100644 --- a/java/org/rocksdb/WriteOptions.java +++ b/java/org/rocksdb/WriteOptions.java @@ -12,6 +12,9 @@ package org.rocksdb; * c++ side memory before a WriteOptions instance runs out of scope. */ public class WriteOptions extends RocksObject { + /** + * Construct WriteOptions instance. + */ public WriteOptions() { super(); newWriteOptions(); @@ -64,6 +67,8 @@ public class WriteOptions extends RocksObject { * crash semantics as the "write()" system call. A DB write * with sync==true has similar crash semantics to a "write()" * system call followed by "fdatasync()". + * + * @return boolean value indicating if sync is active. */ public boolean sync() { return sync(nativeHandle_); @@ -85,6 +90,8 @@ public class WriteOptions extends RocksObject { /** * If true, writes will not first go to the write ahead log, * and the write may got lost after a crash. + * + * @return boolean value indicating if WAL is disabled. */ public boolean disableWAL() { return disableWAL(nativeHandle_); diff --git a/java/org/rocksdb/test/AbstractComparatorTest.java b/java/org/rocksdb/test/AbstractComparatorTest.java index 7f4c47fb3d931c7c5b0fca2267864e8da1d46c8f..339615b4589cf7047354b662530090d36c784461 100644 --- a/java/org/rocksdb/test/AbstractComparatorTest.java +++ b/java/org/rocksdb/test/AbstractComparatorTest.java @@ -36,6 +36,8 @@ public abstract class AbstractComparatorTest { * * @param db_path A path where we can store database * files temporarily + * + * @throws java.io.IOException if IO error happens. */ public void testRoundtrip(final Path db_path) throws IOException { diff --git a/java/org/rocksdb/test/PlatformRandomHelper.java b/java/org/rocksdb/test/PlatformRandomHelper.java index c729c3dc1ac7cb9fcb60ecaef819f8934a68c817..7112fc4f1ba57dcbb82571615c34891614d9573e 100644 --- a/java/org/rocksdb/test/PlatformRandomHelper.java +++ b/java/org/rocksdb/test/PlatformRandomHelper.java @@ -14,6 +14,8 @@ import java.util.Random; public class PlatformRandomHelper { /** * Determine if OS is 32-Bit/64-Bit + * + * @return boolean value indicating if operating system is 64 Bit. */ public static boolean isOs64Bit(){ boolean is64Bit = false; @@ -27,6 +29,8 @@ public class PlatformRandomHelper { /** * Factory to get a platform specific Random instance + * + * @return {@link java.util.Random} instance. */ public static Random getPlatformSpecificRandomFactory(){ if (isOs64Bit()) {