Package net.quasardb.qdb.jni
Class qdb
java.lang.Object
net.quasardb.qdb.jni.qdb
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic intattach_tag(long handle, String alias, String tag) static intbatch_read_blob_compare_and_swap(long handle, long batch, int index, String alias, Reference<ByteBuffer> originalContent) static intbatch_read_blob_get(long handle, long batch, int index, String alias, Reference<ByteBuffer> content) static intbatch_read_blob_get_and_update(long handle, long batch, int index, String alias, Reference<ByteBuffer> content) static intbatch_read_blob_put(long handle, long batch, int index, String alias) static intbatch_read_blob_update(long handle, long batch, int index, String alias) static voidbatch_write_blob_compare_and_swap(long batch, int index, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry) static voidbatch_write_blob_get(long batch, int index, String alias) static voidbatch_write_blob_get_and_update(long batch, int index, String alias, ByteBuffer content, long expiry) static voidbatch_write_blob_put(long handle, long batch, int index, String alias, ByteBuffer content, long expiry) static voidbatch_write_blob_update(long handle, long batch, int index, String alias, ByteBuffer content, long expiry) static voidbatch_write_double_put(long handle, long batch, int index, String alias, double content, long expiry) static voidbatch_write_double_update(long handle, long batch, int index, String alias, double content, long expiry) static voidbatch_write_int_put(long handle, long batch, int index, String alias, long content, long expiry) static voidbatch_write_int_update(long handle, long batch, int index, String alias, long content, long expiry) static voidbatch_write_string_put(long handle, long batch, int index, String alias, String content, long expiry) static voidbatch_write_string_update(long handle, long batch, int index, String alias, String content, long expiry) static voidbatch_write_timestamp_put(long handle, long batch, int index, String alias, Timespec content, long expiry) static voidbatch_write_timestamp_update(long handle, long batch, int index, String alias, Timespec content, long expiry) static intblob_compare_and_swap(long handle, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry, Reference<ByteBuffer> originalContent) static intblob_get(long handle, String alias, Reference<ByteBuffer> content) static intblob_get_and_remove(long handle, String alias, Reference<ByteBuffer> content) static intblob_get_and_update(long handle, String alias, ByteBuffer newContent, long expiry, Reference<ByteBuffer> originalContent) static intblob_put(long handle, String alias, ByteBuffer content, long expiry) static intblob_remove_if(long handle, String alias, ByteBuffer comparand) static intblob_update(long handle, String alias, ByteBuffer content, long expiry) static Stringbuild()static intclear_performance_traces(long handle) static intclose(long handle) static intcommit_batch_fast(long handle, long batch, int count) static intcommit_batch_transactional(long handle, long batch, int count) static intstatic intdelete_batch(long handle, long batch) static intdetach_tag(long handle, String alias, String tag) static intdisable_performance_trace(long handle) static doubledouble_get(long handle, String alias) static voiddouble_put(long handle, String alias, double content) static booleandouble_update(long handle, String alias, double content) static intenable_performance_trace(long handle) static booleanentry_exists(long handle, String alias) static Stringerror_message(int code) static intexpires_at(long handle, String alias, long expiry_time) static intget_expiry_time(long handle, String alias, Reference<Long> expiry) static intstatic intget_metadata(long handle, String alias, ByteBuffer metadata) static intget_performance_traces(long handle, Reference<PerformanceTrace.Trace[]> traces) static intstatic intstatic intstatic longinit_batch(long handle, int count) static intinit_operations(long handle, int count, Reference<Long> batch) static intstatic intstatic intstatic intint_update(long handle, String alias, long value, long expiry) static intnode_config(long handle, String uri, Reference<String> content) static intnode_status(long handle, String uri, Reference<String> content) static intstatic intnode_topology(long handle, String uri, Reference<String> content) static longopen_tcp()static intoption_client_tidy_memory(long handle) static longoption_get_client_max_batch_load(long handle) static longoption_get_client_max_in_buf_size(long handle) static longoption_get_client_max_parallelism(long handle) static Stringoption_get_client_memory_info(long handle) static longoption_get_connection_per_address_soft_limit(long handle) static intoption_set_client_max_batch_load(long handle, long batchLoad) static intoption_set_client_max_in_buf_size(long handle, long size) static intoption_set_client_max_parallelism(long handle, long threadCount) static intoption_set_client_soft_memory_limit(long handle, long threadCount) static intoption_set_compression(long handle, int compressionMode) static intoption_set_connection_per_address_soft_limit(long handle, long limit) static intoption_set_timeout(long handle, int millis) static intpurge_all(long handle, int timeout) static longqdb_string_from_bytes(byte[] xs) Converts a java byte[] and returns an off-heap qdb_string_t *static intquery_execute(long handle, String query, Reference<Result> result) static voidrelease(long handle, ByteBuffer buffer) static voidrelease_batch(long handle, long batch, int count) static voidrelease_qdb_string(long ptr) static intstatic intrun_batch(long handle, long batch, int count) static intsecure_connect(long handle, String uri, qdb_cluster_security_options securityOptions) static Stringstring_get(long handle, String alias) static voidstring_put(long handle, String alias, String content) static booleanstring_update(long handle, String alias, String content) static Stringtag_iterator_alias(long iterator) static inttag_iterator_begin(long handle, String tag, Reference<Long> iterator) static inttag_iterator_close(long iterator) static inttag_iterator_next(long iterator) static inttag_iterator_type(long iterator) static Timespectimestamp_get(long handle, String alias) static voidtimestamp_put(long handle, String alias, Timespec value) static booleantimestamp_update(long handle, String alias, Timespec value) static inttrim_all(long handle, int pause, int timeout) static intts_batch_push(long handle, long batchTable) static intts_batch_push_async(long handle, long batchTable) static intts_batch_push_fast(long handle, long batchTable) static intts_batch_push_truncate(long handle, long batchTable, TimeRange[] ranges) static intts_batch_release_columns_memory(long handle, long batchTable) static intts_batch_row_set_blob(long batchTable, long index, ByteBuffer value) static intts_batch_row_set_double(long batchTable, long index, double value) static intts_batch_row_set_int64(long batchTable, long index, long value) static intts_batch_row_set_string(long batchTable, long index, byte[] value) static intts_batch_row_set_timestamp(long batchTable, long index, long sec, long nsec) static intts_batch_start_row(long timestamp, long sec, long nsec) static voidts_batch_table_release(long handle, long batchTable) static intstatic longts_exp_batch_prepare(long handle, long[] rowCount, long[] columnCount) Allocates all data structures in one big allocation.static longts_exp_batch_push(long handle, int pushMode, long batchTables, long tableCount) static voidts_exp_batch_release(long handle, long batchTables, long tableCount) static voidts_exp_batch_set_column_from_blob(long handle, long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values) static voidts_exp_batch_set_column_from_double(long handle, long batchTables, long tableNum, long columnNum, String name, double[] values) static voidts_exp_batch_set_column_from_int64(long handle, long batchTables, long tableNum, long columnNum, String name, long[] values) static voidts_exp_batch_set_column_from_string(long handle, long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values) static voidts_exp_batch_set_column_from_timestamp(long handle, long batchTables, long tableNum, long columnNum, String name, Timespecs values) static voidts_exp_batch_set_table_data(long handle, long batchTables, long tableNum, String tableName, Timespecs timespecs) static voidts_exp_batch_table_set_drop_duplicate_columns(long handle, long batchTables, long tableNum, String[] columns) static voidts_exp_batch_table_set_drop_duplicates(long batchTables, long tableNum) static voidts_exp_batch_table_set_truncate_ranges(long handle, long batchTables, long tableNum, TimeRange[] ranges) static voidts_exp_batch_timestamps_release(long xs) static intts_insert_columns(long handle, String alias, Column[] columns) static Column[]ts_list_columns(long handle, String alias) static longts_local_table_init(long handle, String alias, Column[] columns) static voidts_local_table_release(long handle, long localTable) static Points.Datats_point_get_ranges(long handle, String tableName, String columnName, int valueType, TimeRange[] ranges) static intts_point_insert(long handle, String tableName, String columnName, Timespecs timespecs, int valueType, Object values) static intstatic longts_shard_size(long handle, String alias) static intts_table_get_ranges(long handle, long localTable, TimeRange[] ranges) static WritableRowts_table_next_row(long handle, long localTable, Column[] columns) static Stringversion()static intwait_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)
-