Class qdb

java.lang.Object
net.quasardb.qdb.jni.qdb

public final class qdb extends Object
  • Constructor Details

    • qdb

      public qdb()
  • Method Details

    • build

      public static String build()
    • version

      public static String version()
    • error_message

      public static String error_message(int code)
    • open_tcp

      public static long open_tcp()
    • connect

      public static int connect(long handle, String uri)
    • secure_connect

      public static int secure_connect(long handle, String uri, qdb_cluster_security_options securityOptions)
    • close

      public static int close(long handle)
    • release

      public static void release(long handle, ByteBuffer buffer)
    • 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

      public static String option_get_client_memory_info(long handle)
    • 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

      public static int remove(long handle, String alias)
    • expires_at

      public static int expires_at(long handle, String alias, long expiry_time)
    • get_expiry_time

      public static int get_expiry_time(long handle, String alias, Reference<Long> expiry)
    • get_type

      public static int get_type(long handle, String alias, Reference<Integer> type)
    • get_metadata

      public static int get_metadata(long handle, String alias, ByteBuffer metadata)
    • entry_exists

      public static boolean entry_exists(long handle, String alias)
    • 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

      public static int blob_put(long handle, String alias, ByteBuffer content, long expiry)
    • blob_get

      public static int blob_get(long handle, String alias, Reference<ByteBuffer> content)
    • blob_get_and_remove

      public static int blob_get_and_remove(long handle, String alias, Reference<ByteBuffer> content)
    • 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

      public static int blob_remove_if(long handle, String alias, ByteBuffer comparand)
    • blob_update

      public static int blob_update(long handle, String alias, ByteBuffer content, long expiry)
    • timestamp_put

      public static void timestamp_put(long handle, String alias, Timespec value)
    • timestamp_get

      public static Timespec timestamp_get(long handle, String alias)
    • timestamp_update

      public static boolean timestamp_update(long handle, String alias, Timespec value)
    • string_put

      public static void string_put(long handle, String alias, String content)
    • string_get

      public static String string_get(long handle, String alias)
    • string_update

      public static boolean string_update(long handle, String alias, String content)
    • double_put

      public static void double_put(long handle, String alias, double content)
    • double_get

      public static double double_get(long handle, String alias)
    • double_update

      public static boolean double_update(long handle, String alias, double content)
    • int_put

      public static int int_put(long handle, String alias, long value, long expiry)
    • int_update

      public static int int_update(long handle, String alias, long value, long expiry)
    • int_get

      public static int int_get(long handle, String alias, Reference<Long> value)
    • int_add

      public static int int_add(long handle, String alias, long addend, Reference<Long> result)
    • 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

      public static int get_performance_traces(long handle, Reference<PerformanceTrace.Trace[]> traces)
    • clear_performance_traces

      public static int clear_performance_traces(long handle)
    • attach_tag

      public static int attach_tag(long handle, String alias, String tag)
    • has_tag

      public static int has_tag(long handle, String alias, String tag)
    • detach_tag

      public static int detach_tag(long handle, String alias, String tag)
    • get_tags

      public static int get_tags(long handle, String alias, Reference<String[]> tags)
    • tag_iterator_begin

      public static int tag_iterator_begin(long handle, String tag, Reference<Long> iterator)
    • 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

      public static String tag_iterator_alias(long iterator)
    • tag_iterator_type

      public static int tag_iterator_type(long iterator)
    • ts_create

      public static int ts_create(long handle, String alias, long shard_size, Column[] columns)
    • ts_remove

      public static int ts_remove(long handle, String alias)
    • ts_shard_size

      public static long ts_shard_size(long handle, String alias)
    • ts_insert_columns

      public static int ts_insert_columns(long handle, String alias, Column[] columns)
    • ts_list_columns

      public static Column[] ts_list_columns(long handle, String alias)
    • ts_local_table_init

      public static long ts_local_table_init(long handle, String alias, Column[] columns)
    • 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

      public static int ts_batch_push_truncate(long handle, long batchTable, TimeRange[] ranges)
    • 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

      public static int ts_batch_row_set_blob(long batchTable, long index, ByteBuffer value)
    • 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

      public static void ts_exp_batch_set_column_from_timestamp(long handle, long batchTables, long tableNum, long columnNum, String name, Timespecs values)
    • ts_exp_batch_set_table_data

      public static void ts_exp_batch_set_table_data(long handle, long batchTables, long tableNum, String tableName, Timespecs timespecs)
    • 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

      public static int ts_table_get_ranges(long handle, long localTable, TimeRange[] ranges)
    • ts_table_next_row

      public static WritableRow ts_table_next_row(long handle, long localTable, Column[] columns)
    • 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

      public static int ts_point_insert(long handle, String tableName, String columnName, Timespecs timespecs, int valueType, Object values)
    • query_execute

      public static int query_execute(long handle, String query, Reference<Result> result)
    • node_status

      public static int node_status(long handle, String uri, Reference<String> content)
    • node_config

      public static int node_config(long handle, String uri, Reference<String> content)
    • node_topology

      public static int node_topology(long handle, String uri, Reference<String> content)
    • node_stop

      public static int node_stop(long handle, String uri, String reason)
    • get_location

      public static int get_location(long handle, String alias, Reference<String> address, Reference<Integer> port)
    • 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

      public static int init_operations(long handle, int count, Reference<Long> batch)
    • 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

      public static void batch_write_blob_get(long batch, int index, String alias)
    • 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

      public static int batch_read_blob_put(long handle, long batch, int index, String alias)
    • batch_read_blob_update

      public static int batch_read_blob_update(long handle, long batch, int index, String alias)
    • batch_write_string_put

      public static void batch_write_string_put(long handle, long batch, int index, String alias, String content, long expiry)
    • batch_write_string_update

      public static void batch_write_string_update(long handle, long batch, int index, String alias, String content, long expiry)
    • batch_write_timestamp_put

      public static void batch_write_timestamp_put(long handle, long batch, int index, String alias, Timespec content, long expiry)
    • batch_write_timestamp_update

      public static void batch_write_timestamp_update(long handle, long batch, int index, String alias, Timespec content, long expiry)
    • 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)