Package net.quasardb.qdb.jni
Class qdb
java.lang.Object
net.quasardb.qdb.jni.qdb
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic int
attach_tag
(long handle, String alias, String tag) static int
batch_read_blob_compare_and_swap
(long handle, long batch, int index, String alias, Reference<ByteBuffer> originalContent) static int
batch_read_blob_get
(long handle, long batch, int index, String alias, Reference<ByteBuffer> content) static int
batch_read_blob_get_and_update
(long handle, long batch, int index, String alias, Reference<ByteBuffer> content) static int
batch_read_blob_put
(long handle, long batch, int index, String alias) static int
batch_read_blob_update
(long handle, long batch, int index, String alias) static void
batch_write_blob_compare_and_swap
(long batch, int index, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry) static void
batch_write_blob_get
(long batch, int index, String alias) static void
batch_write_blob_get_and_update
(long batch, int index, String alias, ByteBuffer content, long expiry) static void
batch_write_blob_put
(long handle, long batch, int index, String alias, ByteBuffer content, long expiry) static void
batch_write_blob_update
(long handle, long batch, int index, String alias, ByteBuffer content, long expiry) static void
batch_write_double_put
(long handle, long batch, int index, String alias, double content, long expiry) static void
batch_write_double_update
(long handle, long batch, int index, String alias, double content, long expiry) static void
batch_write_int_put
(long handle, long batch, int index, String alias, long content, long expiry) static void
batch_write_int_update
(long handle, long batch, int index, String alias, long content, long expiry) static void
batch_write_string_put
(long handle, long batch, int index, String alias, String content, long expiry) static void
batch_write_string_update
(long handle, long batch, int index, String alias, String content, long expiry) static void
batch_write_timestamp_put
(long handle, long batch, int index, String alias, Timespec content, long expiry) static void
batch_write_timestamp_update
(long handle, long batch, int index, String alias, Timespec content, long expiry) static int
blob_compare_and_swap
(long handle, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry, Reference<ByteBuffer> originalContent) static int
blob_get
(long handle, String alias, Reference<ByteBuffer> content) static int
blob_get_and_remove
(long handle, String alias, Reference<ByteBuffer> content) static int
blob_get_and_update
(long handle, String alias, ByteBuffer newContent, long expiry, Reference<ByteBuffer> originalContent) static int
blob_put
(long handle, String alias, ByteBuffer content, long expiry) static int
blob_remove_if
(long handle, String alias, ByteBuffer comparand) static int
blob_update
(long handle, String alias, ByteBuffer content, long expiry) static String
build()
static int
clear_performance_traces
(long handle) static int
close
(long handle) static int
commit_batch_fast
(long handle, long batch, int count) static int
commit_batch_transactional
(long handle, long batch, int count) static int
static int
delete_batch
(long handle, long batch) static int
detach_tag
(long handle, String alias, String tag) static int
disable_performance_trace
(long handle) static double
double_get
(long handle, String alias) static void
double_put
(long handle, String alias, double content) static boolean
double_update
(long handle, String alias, double content) static int
enable_performance_trace
(long handle) static boolean
entry_exists
(long handle, String alias) static String
error_message
(int code) static int
expires_at
(long handle, String alias, long expiry_time) static int
get_expiry_time
(long handle, String alias, Reference<Long> expiry) static int
static int
get_metadata
(long handle, String alias, ByteBuffer metadata) static int
get_performance_traces
(long handle, Reference<PerformanceTrace.Trace[]> traces) static int
static int
static int
static long
init_batch
(long handle, int count) static int
init_operations
(long handle, int count, Reference<Long> batch) static int
static int
static int
static int
int_update
(long handle, String alias, long value, long expiry) static int
node_config
(long handle, String uri, Reference<String> content) static int
node_status
(long handle, String uri, Reference<String> content) static int
static int
node_topology
(long handle, String uri, Reference<String> content) static long
open_tcp()
static int
option_client_tidy_memory
(long handle) static long
option_get_client_max_batch_load
(long handle) static long
option_get_client_max_in_buf_size
(long handle) static long
option_get_client_max_parallelism
(long handle) static String
option_get_client_memory_info
(long handle) static long
option_get_connection_per_address_soft_limit
(long handle) static int
option_set_client_max_batch_load
(long handle, long batchLoad) static int
option_set_client_max_in_buf_size
(long handle, long size) static int
option_set_client_max_parallelism
(long handle, long threadCount) static int
option_set_client_soft_memory_limit
(long handle, long threadCount) static int
option_set_compression
(long handle, int compressionMode) static int
option_set_connection_per_address_soft_limit
(long handle, long limit) static int
option_set_timeout
(long handle, int millis) static int
purge_all
(long handle, int timeout) static long
qdb_string_from_bytes
(byte[] xs) Converts a java byte[] and returns an off-heap qdb_string_t *static int
query_execute
(long handle, String query, Reference<Result> result) static void
release
(long handle, ByteBuffer buffer) static void
release_batch
(long handle, long batch, int count) static void
release_qdb_string
(long ptr) static int
static int
run_batch
(long handle, long batch, int count) static int
secure_connect
(long handle, String uri, qdb_cluster_security_options securityOptions) static String
string_get
(long handle, String alias) static void
string_put
(long handle, String alias, String content) static boolean
string_update
(long handle, String alias, String content) static String
tag_iterator_alias
(long iterator) static int
tag_iterator_begin
(long handle, String tag, Reference<Long> iterator) static int
tag_iterator_close
(long iterator) static int
tag_iterator_next
(long iterator) static int
tag_iterator_type
(long iterator) static Timespec
timestamp_get
(long handle, String alias) static void
timestamp_put
(long handle, String alias, Timespec value) static boolean
timestamp_update
(long handle, String alias, Timespec value) static int
trim_all
(long handle, int pause, int timeout) static int
ts_batch_push
(long handle, long batchTable) static int
ts_batch_push_async
(long handle, long batchTable) static int
ts_batch_push_fast
(long handle, long batchTable) static int
ts_batch_push_truncate
(long handle, long batchTable, TimeRange[] ranges) static int
ts_batch_release_columns_memory
(long handle, long batchTable) static int
ts_batch_row_set_blob
(long batchTable, long index, ByteBuffer value) static int
ts_batch_row_set_double
(long batchTable, long index, double value) static int
ts_batch_row_set_int64
(long batchTable, long index, long value) static int
ts_batch_row_set_string
(long batchTable, long index, byte[] value) static int
ts_batch_row_set_timestamp
(long batchTable, long index, long sec, long nsec) static int
ts_batch_start_row
(long timestamp, long sec, long nsec) static void
ts_batch_table_release
(long handle, long batchTable) static int
static long
ts_exp_batch_prepare
(long handle, long[] rowCount, long[] columnCount) Allocates all data structures in one big allocation.static long
ts_exp_batch_push
(long handle, int pushMode, long batchTables, long tableCount) static void
ts_exp_batch_release
(long handle, long batchTables, long tableCount) static void
ts_exp_batch_set_column_from_blob
(long handle, long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values) static void
ts_exp_batch_set_column_from_double
(long handle, long batchTables, long tableNum, long columnNum, String name, double[] values) static void
ts_exp_batch_set_column_from_int64
(long handle, long batchTables, long tableNum, long columnNum, String name, long[] values) static void
ts_exp_batch_set_column_from_string
(long handle, long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values) static void
ts_exp_batch_set_column_from_timestamp
(long handle, long batchTables, long tableNum, long columnNum, String name, Timespecs values) static void
ts_exp_batch_set_table_data
(long handle, long batchTables, long tableNum, String tableName, Timespecs timespecs) static void
ts_exp_batch_table_set_drop_duplicate_columns
(long handle, long batchTables, long tableNum, String[] columns) static void
ts_exp_batch_table_set_drop_duplicates
(long batchTables, long tableNum) static void
ts_exp_batch_table_set_truncate_ranges
(long handle, long batchTables, long tableNum, TimeRange[] ranges) static void
ts_exp_batch_timestamps_release
(long xs) static int
ts_insert_columns
(long handle, String alias, Column[] columns) static Column[]
ts_list_columns
(long handle, String alias) static long
ts_local_table_init
(long handle, String alias, Column[] columns) static void
ts_local_table_release
(long handle, long localTable) static Points.Data
ts_point_get_ranges
(long handle, String tableName, String columnName, int valueType, TimeRange[] ranges) static int
ts_point_insert
(long handle, String tableName, String columnName, Timespecs timespecs, int valueType, Object values) static int
static long
ts_shard_size
(long handle, String alias) static int
ts_table_get_ranges
(long handle, long localTable, TimeRange[] ranges) static WritableRow
ts_table_next_row
(long handle, long localTable, Column[] columns) static String
version()
static int
wait_for_stabilization
(long handle, int timeout)
-
Constructor Details
-
qdb
public qdb()
-
-
Method Details
-
build
-
version
-
error_message
-
open_tcp
public static long open_tcp() -
connect
-
secure_connect
public static int secure_connect(long handle, String uri, qdb_cluster_security_options securityOptions) -
close
public static int close(long handle) -
release
-
qdb_string_from_bytes
public static long qdb_string_from_bytes(byte[] xs) Converts a java byte[] and returns an off-heap qdb_string_t * -
release_qdb_string
public static void release_qdb_string(long ptr) -
option_set_timeout
public static int option_set_timeout(long handle, int millis) -
option_set_client_max_in_buf_size
public static int option_set_client_max_in_buf_size(long handle, long size) -
option_get_client_max_in_buf_size
public static long option_get_client_max_in_buf_size(long handle) -
option_set_client_max_parallelism
public static int option_set_client_max_parallelism(long handle, long threadCount) -
option_get_client_max_parallelism
public static long option_get_client_max_parallelism(long handle) -
option_set_client_max_batch_load
public static int option_set_client_max_batch_load(long handle, long batchLoad) -
option_get_client_max_batch_load
public static long option_get_client_max_batch_load(long handle) -
option_set_connection_per_address_soft_limit
public static int option_set_connection_per_address_soft_limit(long handle, long limit) -
option_get_connection_per_address_soft_limit
public static long option_get_connection_per_address_soft_limit(long handle) -
option_set_compression
public static int option_set_compression(long handle, int compressionMode) -
option_set_client_soft_memory_limit
public static int option_set_client_soft_memory_limit(long handle, long threadCount) -
option_get_client_memory_info
-
option_client_tidy_memory
public static int option_client_tidy_memory(long handle) -
purge_all
public static int purge_all(long handle, int timeout) -
trim_all
public static int trim_all(long handle, int pause, int timeout) -
wait_for_stabilization
public static int wait_for_stabilization(long handle, int timeout) -
remove
-
expires_at
-
get_expiry_time
-
get_type
-
get_metadata
-
entry_exists
-
blob_compare_and_swap
public static int blob_compare_and_swap(long handle, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry, Reference<ByteBuffer> originalContent) -
blob_put
-
blob_get
-
blob_get_and_remove
-
blob_get_and_update
public static int blob_get_and_update(long handle, String alias, ByteBuffer newContent, long expiry, Reference<ByteBuffer> originalContent) -
blob_remove_if
-
blob_update
-
timestamp_put
-
timestamp_get
-
timestamp_update
-
string_put
-
string_get
-
string_update
-
double_put
-
double_get
-
double_update
-
int_put
-
int_update
-
int_get
-
int_add
-
enable_performance_trace
public static int enable_performance_trace(long handle) -
disable_performance_trace
public static int disable_performance_trace(long handle) -
get_performance_traces
-
clear_performance_traces
public static int clear_performance_traces(long handle) -
attach_tag
-
has_tag
-
detach_tag
-
get_tags
-
tag_iterator_begin
-
tag_iterator_next
public static int tag_iterator_next(long iterator) -
tag_iterator_close
public static int tag_iterator_close(long iterator) -
tag_iterator_alias
-
tag_iterator_type
public static int tag_iterator_type(long iterator) -
ts_create
-
ts_remove
-
ts_shard_size
-
ts_insert_columns
-
ts_list_columns
-
ts_local_table_init
-
ts_batch_table_release
public static void ts_batch_table_release(long handle, long batchTable) -
ts_batch_push
public static int ts_batch_push(long handle, long batchTable) -
ts_batch_push_async
public static int ts_batch_push_async(long handle, long batchTable) -
ts_batch_push_fast
public static int ts_batch_push_fast(long handle, long batchTable) -
ts_batch_release_columns_memory
public static int ts_batch_release_columns_memory(long handle, long batchTable) -
ts_batch_push_truncate
-
ts_batch_start_row
public static int ts_batch_start_row(long timestamp, long sec, long nsec) -
ts_batch_row_set_double
public static int ts_batch_row_set_double(long batchTable, long index, double value) -
ts_batch_row_set_int64
public static int ts_batch_row_set_int64(long batchTable, long index, long value) -
ts_batch_row_set_timestamp
public static int ts_batch_row_set_timestamp(long batchTable, long index, long sec, long nsec) -
ts_batch_row_set_blob
-
ts_batch_row_set_string
public static int ts_batch_row_set_string(long batchTable, long index, byte[] value) -
ts_exp_batch_prepare
public static long ts_exp_batch_prepare(long handle, long[] rowCount, long[] columnCount) Allocates all data structures in one big allocation. For each table, a rowCount and a columnCount is expected. rowCount.length == columnCount.length, and pretty much defines the number of tables. -
ts_exp_batch_set_column_from_double
public static void ts_exp_batch_set_column_from_double(long handle, long batchTables, long tableNum, long columnNum, String name, double[] values) -
ts_exp_batch_set_column_from_int64
public static void ts_exp_batch_set_column_from_int64(long handle, long batchTables, long tableNum, long columnNum, String name, long[] values) -
ts_exp_batch_set_column_from_blob
public static void ts_exp_batch_set_column_from_blob(long handle, long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values) -
ts_exp_batch_set_column_from_string
public static void ts_exp_batch_set_column_from_string(long handle, long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values) -
ts_exp_batch_set_column_from_timestamp
-
ts_exp_batch_set_table_data
-
ts_exp_batch_table_set_drop_duplicates
public static void ts_exp_batch_table_set_drop_duplicates(long batchTables, long tableNum) -
ts_exp_batch_table_set_drop_duplicate_columns
public static void ts_exp_batch_table_set_drop_duplicate_columns(long handle, long batchTables, long tableNum, String[] columns) -
ts_exp_batch_table_set_truncate_ranges
public static void ts_exp_batch_table_set_truncate_ranges(long handle, long batchTables, long tableNum, TimeRange[] ranges) -
ts_exp_batch_push
public static long ts_exp_batch_push(long handle, int pushMode, long batchTables, long tableCount) -
ts_exp_batch_release
public static void ts_exp_batch_release(long handle, long batchTables, long tableCount) -
ts_exp_batch_timestamps_release
public static void ts_exp_batch_timestamps_release(long xs) -
ts_local_table_release
public static void ts_local_table_release(long handle, long localTable) -
ts_table_get_ranges
-
ts_table_next_row
-
ts_point_get_ranges
public static Points.Data ts_point_get_ranges(long handle, String tableName, String columnName, int valueType, TimeRange[] ranges) -
ts_point_insert
-
query_execute
-
node_status
-
node_config
-
node_topology
-
node_stop
-
get_location
-
init_batch
public static long init_batch(long handle, int count) -
release_batch
public static void release_batch(long handle, long batch, int count) -
init_operations
-
delete_batch
public static int delete_batch(long handle, long batch) -
run_batch
public static int run_batch(long handle, long batch, int count) -
commit_batch_fast
public static int commit_batch_fast(long handle, long batch, int count) -
commit_batch_transactional
public static int commit_batch_transactional(long handle, long batch, int count) -
batch_write_blob_compare_and_swap
public static void batch_write_blob_compare_and_swap(long batch, int index, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry) -
batch_write_blob_get
-
batch_write_blob_get_and_update
public static void batch_write_blob_get_and_update(long batch, int index, String alias, ByteBuffer content, long expiry) -
batch_write_blob_put
public static void batch_write_blob_put(long handle, long batch, int index, String alias, ByteBuffer content, long expiry) -
batch_write_blob_update
public static void batch_write_blob_update(long handle, long batch, int index, String alias, ByteBuffer content, long expiry) -
batch_read_blob_compare_and_swap
public static int batch_read_blob_compare_and_swap(long handle, long batch, int index, String alias, Reference<ByteBuffer> originalContent) -
batch_read_blob_get
public static int batch_read_blob_get(long handle, long batch, int index, String alias, Reference<ByteBuffer> content) -
batch_read_blob_get_and_update
public static int batch_read_blob_get_and_update(long handle, long batch, int index, String alias, Reference<ByteBuffer> content) -
batch_read_blob_put
-
batch_read_blob_update
-
batch_write_string_put
-
batch_write_string_update
-
batch_write_timestamp_put
-
batch_write_timestamp_update
-
batch_write_int_put
public static void batch_write_int_put(long handle, long batch, int index, String alias, long content, long expiry) -
batch_write_int_update
public static void batch_write_int_update(long handle, long batch, int index, String alias, long content, long expiry) -
batch_write_double_put
public static void batch_write_double_put(long handle, long batch, int index, String alias, double content, long expiry) -
batch_write_double_update
public static void batch_write_double_update(long handle, long batch, int index, String alias, double content, long expiry)
-