add subtree-ish sources for 12.0.3

[ceph.git] / ceph / src / rocksdb / java / src / main / java / org / rocksdb / SstFileWriter.java

diff --git a/ceph/src/rocksdb/java/src/main/java/org/rocksdb/SstFileWriter.java b/ceph/src/rocksdb/java/src/main/java/org/rocksdb/SstFileWriter.java
new file mode 100644 (file)
index 0000000..130a496
--- /dev/null
+++ b/ceph/src/rocksdb/java/src/main/java/org/rocksdb/SstFileWriter.java
@@ -0,0 +1,54 @@
+// Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.
+// This source code is licensed under the BSD-style license found in the
+// LICENSE file in the root directory of this source tree. An additional grant
+// of patent rights can be found in the PATENTS file in the same directory.
+
+package org.rocksdb;
+
+public class SstFileWriter extends RocksObject {
+  static {
+    RocksDB.loadLibrary();
+  }
+
+  public SstFileWriter(final EnvOptions envOptions, final Options options,
+      final AbstractComparator<? extends AbstractSlice<?>> comparator) {
+    super(newSstFileWriter(
+        envOptions.nativeHandle_, options.nativeHandle_, comparator.getNativeHandle()));
+  }
+
+  public SstFileWriter(final EnvOptions envOptions, final Options options) {
+    super(newSstFileWriter(
+        envOptions.nativeHandle_, options.nativeHandle_));
+  }
+
+  public void open(final String filePath) throws RocksDBException {
+    open(nativeHandle_, filePath);
+  }
+
+  public void add(final Slice key, final Slice value) throws RocksDBException {
+    add(nativeHandle_, key.getNativeHandle(), value.getNativeHandle());
+  }
+
+  public void add(final DirectSlice key, final DirectSlice value) throws RocksDBException {
+    add(nativeHandle_, key.getNativeHandle(), value.getNativeHandle());
+  }
+
+  public void finish() throws RocksDBException {
+    finish(nativeHandle_);
+  }
+
+  private native static long newSstFileWriter(
+      final long envOptionsHandle, final long optionsHandle, final long userComparatorHandle);
+
+  private native static long newSstFileWriter(final long envOptionsHandle,
+      final long optionsHandle);
+
+  private native void open(final long handle, final String filePath) throws RocksDBException;
+
+  private native void add(final long handle, final long keyHandle, final long valueHandle)
+      throws RocksDBException;
+
+  private native void finish(final long handle) throws RocksDBException;
+
+  @Override protected final native void disposeInternal(final long handle);
+}