public final class qdb extends Object
Constructor and Description |
---|
qdb() |
Modifier and Type | Method and Description |
---|---|
static 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_and_update(long handle,
long batch,
int index,
String alias,
Reference<ByteBuffer> content) |
static int |
batch_read_blob_get(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_and_update(long batch,
int index,
String alias,
ByteBuffer content,
long expiry) |
static void |
batch_write_blob_get(long batch,
int index,
String alias) |
static void |
batch_write_blob_put(long batch,
int index,
String alias,
ByteBuffer content,
long expiry) |
static void |
batch_write_blob_update(long batch,
int index,
String alias,
ByteBuffer 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_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_get(long handle,
String alias,
Reference<ByteBuffer> content) |
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 |
connect(long handle,
String uri) |
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 int |
enable_performance_trace(long handle) |
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 |
get_location(long handle,
String alias,
Reference<String> address,
Reference<Integer> port) |
static int |
get_metadata(long handle,
String alias,
ByteBuffer metadata) |
static int |
get_performance_traces(long handle,
Reference<PerformanceTrace.Trace[]> traces) |
static int |
get_tags(long handle,
String alias,
Reference<String[]> tags) |
static int |
get_type(long handle,
String alias,
Reference<Integer> type) |
static int |
has_tag(long handle,
String alias,
String tag) |
static int |
init_operations(long handle,
int count,
Reference<Long> batch) |
static int |
int_add(long handle,
String alias,
long addend,
Reference<Long> result) |
static int |
int_get(long handle,
String alias,
Reference<Long> value) |
static int |
int_put(long handle,
String alias,
long value,
long expiry) |
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 |
node_stop(long handle,
String uri,
String reason) |
static int |
node_topology(long handle,
String uri,
Reference<String> content) |
static long |
open_tcp() |
static long |
option_get_client_max_in_buf_size(long handle) |
static long |
option_get_client_max_parallelism(long handle) |
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_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_qdb_string(long ptr) |
static void |
release(long handle,
ByteBuffer buffer) |
static int |
remove(long handle,
String alias) |
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 |
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 int |
trim_all(long handle,
int timeout) |
static int |
ts_batch_pinned_push(long handle,
long batchTable,
int[] columnTypes,
Object[] rows) |
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_push(long handle,
long batchTable) |
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_pinned_blob(long columnIndex,
long rowIndex,
ByteBuffer value) |
static int |
ts_batch_row_set_pinned_double(long columnIndex,
long rowIndex,
double value) |
static int |
ts_batch_row_set_pinned_int64(long columnIndex,
long rowIndex,
long value) |
static int |
ts_batch_row_set_pinned_string(long columnIndex,
long rowIndex,
byte[] value) |
static int |
ts_batch_row_set_pinned_timestamp(long columnIndex,
long rowIndex,
long sec,
long nsec) |
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_set_pinned_blobs(long handle,
long batchTable,
long shard,
int columnIndex,
long[] timeoffsets,
ByteBuffer[] values) |
static int |
ts_batch_set_pinned_doubles(long handle,
long batchTable,
long shard,
int columnIndex,
long[] timeoffsets,
double[] values) |
static int |
ts_batch_set_pinned_int64s(long handle,
long batchTable,
long shard,
int columnIndex,
long[] timeoffsets,
long[] values) |
static int |
ts_batch_set_pinned_strings(long handle,
long batchTable,
long shard,
int columnIndex,
long[] timeoffsets,
ByteBuffer[] values) |
static int |
ts_batch_set_pinned_timestamps(long handle,
long batchTable,
long shard,
int columnIndex,
long[] timeoffsets,
Timespecs values) |
static int |
ts_batch_start_row(long timestamp,
long sec,
long nsec) |
static int |
ts_batch_table_extra_columns(long handle,
long batchTable,
Writer.TableColumn[] columns) |
static long |
ts_batch_table_init(long handle,
Writer.TableColumn[] columns) |
static void |
ts_batch_table_release(long handle,
long batchTable) |
static int |
ts_blob_aggregate(long handle,
String alias,
String column,
qdb_ts_blob_aggregation[] input,
Reference<qdb_ts_blob_aggregation[]> aggregations) |
static int |
ts_blob_get_ranges(long handle,
String alias,
String column,
TimeRange[] ranges,
Reference<qdb_ts_blob_point[]> points) |
static int |
ts_blob_insert(long handle,
String alias,
String column,
qdb_ts_blob_point[] points) |
static int |
ts_create(long handle,
String alias,
long shard_size,
Column[] columns) |
static int |
ts_double_aggregate(long handle,
String alias,
String column,
qdb_ts_double_aggregation[] input,
Reference<qdb_ts_double_aggregation[]> aggregations) |
static int |
ts_double_get_ranges(long handle,
String alias,
String column,
TimeRange[] ranges,
Reference<qdb_ts_double_point[]> points) |
static int |
ts_double_insert(long handle,
String alias,
String column,
qdb_ts_double_point[] points) |
static long |
ts_exp_batch_prepare(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 batchTables,
long tableCount) |
static void |
ts_exp_batch_set_column_from_blob(long batchTables,
long tableNum,
long columnNum,
String name,
ByteBuffer[] values) |
static void |
ts_exp_batch_set_column_from_double(long batchTables,
long tableNum,
long columnNum,
String name,
double[] values) |
static void |
ts_exp_batch_set_column_from_int64(long batchTables,
long tableNum,
long columnNum,
String name,
long[] values) |
static void |
ts_exp_batch_set_column_from_string(long batchTables,
long tableNum,
long columnNum,
String name,
ByteBuffer[] values) |
static void |
ts_exp_batch_set_column_from_timestamp(long batchTables,
long tableNum,
long columnNum,
String name,
Timespecs values) |
static void |
ts_exp_batch_set_table_data(long batchTables,
long tableNum,
String tableName,
Timespecs timespecs) |
static void |
ts_exp_batch_table_set_truncate_ranges(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 int |
ts_remove(long handle,
String alias) |
static long |
ts_shard_size(long handle,
String alias) |
static int |
ts_string_aggregate(long handle,
String alias,
String column,
qdb_ts_string_aggregation[] input,
Reference<qdb_ts_string_aggregation[]> aggregations) |
static int |
ts_string_get_ranges(long handle,
String alias,
String column,
TimeRange[] ranges,
Reference<qdb_ts_string_point[]> points) |
static int |
ts_string_insert(long handle,
String alias,
String column,
qdb_ts_string_point[] points) |
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) |
public static String build()
public static String version()
public static String error_message(int code)
public static long open_tcp()
public static int connect(long handle, String uri)
public static int secure_connect(long handle, String uri, qdb_cluster_security_options securityOptions)
public static int close(long handle)
public static void release(long handle, ByteBuffer buffer)
public static long qdb_string_from_bytes(byte[] xs)
public static void release_qdb_string(long ptr)
public static int option_set_timeout(long handle, int millis)
public static int option_set_client_max_in_buf_size(long handle, long size)
public static long option_get_client_max_in_buf_size(long handle)
public static int option_set_client_max_parallelism(long handle, long threadCount)
public static long option_get_client_max_parallelism(long handle)
public static int purge_all(long handle, int timeout)
public static int trim_all(long handle, int timeout)
public static int wait_for_stabilization(long handle, int timeout)
public static int remove(long handle, String alias)
public static int expires_at(long handle, String alias, long expiry_time)
public static int get_expiry_time(long handle, String alias, Reference<Long> expiry)
public static int get_metadata(long handle, String alias, ByteBuffer metadata)
public static int blob_compare_and_swap(long handle, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry, Reference<ByteBuffer> originalContent)
public static int blob_put(long handle, String alias, ByteBuffer content, long expiry)
public static int blob_get(long handle, String alias, Reference<ByteBuffer> content)
public static int blob_get_and_remove(long handle, String alias, Reference<ByteBuffer> content)
public static int blob_get_and_update(long handle, String alias, ByteBuffer newContent, long expiry, Reference<ByteBuffer> originalContent)
public static int blob_remove_if(long handle, String alias, ByteBuffer comparand)
public static int blob_update(long handle, String alias, ByteBuffer content, long expiry)
public static int int_put(long handle, String alias, long value, long expiry)
public static int int_update(long handle, String alias, long value, long expiry)
public static int enable_performance_trace(long handle)
public static int disable_performance_trace(long handle)
public static int get_performance_traces(long handle, Reference<PerformanceTrace.Trace[]> traces)
public static int clear_performance_traces(long handle)
public static int tag_iterator_begin(long handle, String tag, Reference<Long> iterator)
public static int tag_iterator_next(long iterator)
public static int tag_iterator_close(long iterator)
public static String tag_iterator_alias(long iterator)
public static int tag_iterator_type(long iterator)
public static int ts_remove(long handle, String alias)
public static long ts_shard_size(long handle, String alias)
public static long ts_local_table_init(long handle, String alias, Column[] columns)
public static long ts_batch_table_init(long handle, Writer.TableColumn[] columns)
public static int ts_batch_table_extra_columns(long handle, long batchTable, Writer.TableColumn[] columns)
public static void ts_batch_table_release(long handle, long batchTable)
public static int ts_batch_push(long handle, long batchTable)
public static int ts_batch_push_async(long handle, long batchTable)
public static int ts_batch_push_fast(long handle, long batchTable)
public static int ts_batch_release_columns_memory(long handle, long batchTable)
public static int ts_batch_push_truncate(long handle, long batchTable, TimeRange[] ranges)
public static int ts_batch_pinned_push(long handle, long batchTable, int[] columnTypes, Object[] rows)
public static int ts_batch_start_row(long timestamp, long sec, long nsec)
public static int ts_batch_row_set_double(long batchTable, long index, double value)
public static int ts_batch_row_set_int64(long batchTable, long index, long value)
public static int ts_batch_row_set_timestamp(long batchTable, long index, long sec, long nsec)
public static int ts_batch_row_set_blob(long batchTable, long index, ByteBuffer value)
public static int ts_batch_row_set_string(long batchTable, long index, byte[] value)
public static int ts_batch_set_pinned_doubles(long handle, long batchTable, long shard, int columnIndex, long[] timeoffsets, double[] values)
public static int ts_batch_set_pinned_int64s(long handle, long batchTable, long shard, int columnIndex, long[] timeoffsets, long[] values)
public static int ts_batch_set_pinned_timestamps(long handle, long batchTable, long shard, int columnIndex, long[] timeoffsets, Timespecs values)
public static int ts_batch_set_pinned_blobs(long handle, long batchTable, long shard, int columnIndex, long[] timeoffsets, ByteBuffer[] values)
public static int ts_batch_set_pinned_strings(long handle, long batchTable, long shard, int columnIndex, long[] timeoffsets, ByteBuffer[] values)
public static int ts_batch_row_set_pinned_double(long columnIndex, long rowIndex, double value)
public static int ts_batch_row_set_pinned_int64(long columnIndex, long rowIndex, long value)
public static int ts_batch_row_set_pinned_timestamp(long columnIndex, long rowIndex, long sec, long nsec)
public static int ts_batch_row_set_pinned_blob(long columnIndex, long rowIndex, ByteBuffer value)
public static int ts_batch_row_set_pinned_string(long columnIndex, long rowIndex, byte[] value)
public static long ts_exp_batch_prepare(long[] rowCount, long[] columnCount)
public static void ts_exp_batch_set_column_from_double(long batchTables, long tableNum, long columnNum, String name, double[] values)
public static void ts_exp_batch_set_column_from_int64(long batchTables, long tableNum, long columnNum, String name, long[] values)
public static void ts_exp_batch_set_column_from_blob(long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values)
public static void ts_exp_batch_set_column_from_string(long batchTables, long tableNum, long columnNum, String name, ByteBuffer[] values)
public static void ts_exp_batch_set_column_from_timestamp(long batchTables, long tableNum, long columnNum, String name, Timespecs values)
public static void ts_exp_batch_set_table_data(long batchTables, long tableNum, String tableName, Timespecs timespecs)
public static void ts_exp_batch_table_set_truncate_ranges(long batchTables, long tableNum, TimeRange[] ranges)
public static long ts_exp_batch_push(long handle, int pushMode, long batchTables, long tableCount)
public static void ts_exp_batch_release(long batchTables, long tableCount)
public static void ts_exp_batch_timestamps_release(long xs)
public static void ts_local_table_release(long handle, long localTable)
public static int ts_table_get_ranges(long handle, long localTable, TimeRange[] ranges)
public static WritableRow ts_table_next_row(long handle, long localTable, Column[] columns)
public static int ts_double_insert(long handle, String alias, String column, qdb_ts_double_point[] points)
public static int ts_double_get_ranges(long handle, String alias, String column, TimeRange[] ranges, Reference<qdb_ts_double_point[]> points)
public static int ts_double_aggregate(long handle, String alias, String column, qdb_ts_double_aggregation[] input, Reference<qdb_ts_double_aggregation[]> aggregations)
public static int ts_blob_insert(long handle, String alias, String column, qdb_ts_blob_point[] points)
public static int ts_blob_get_ranges(long handle, String alias, String column, TimeRange[] ranges, Reference<qdb_ts_blob_point[]> points)
public static int ts_blob_aggregate(long handle, String alias, String column, qdb_ts_blob_aggregation[] input, Reference<qdb_ts_blob_aggregation[]> aggregations)
public static int ts_string_insert(long handle, String alias, String column, qdb_ts_string_point[] points)
public static int ts_string_get_ranges(long handle, String alias, String column, TimeRange[] ranges, Reference<qdb_ts_string_point[]> points)
public static int ts_string_aggregate(long handle, String alias, String column, qdb_ts_string_aggregation[] input, Reference<qdb_ts_string_aggregation[]> aggregations)
public static int get_location(long handle, String alias, Reference<String> address, Reference<Integer> port)
public static int delete_batch(long handle, long batch)
public static int run_batch(long handle, long batch, int count)
public static void batch_write_blob_compare_and_swap(long batch, int index, String alias, ByteBuffer newContent, ByteBuffer comparand, long expiry)
public static void batch_write_blob_get(long batch, int index, String alias)
public static void batch_write_blob_get_and_update(long batch, int index, String alias, ByteBuffer content, long expiry)
public static void batch_write_blob_put(long batch, int index, String alias, ByteBuffer content, long expiry)
public static void batch_write_blob_update(long batch, int index, String alias, ByteBuffer content, long expiry)
public static int batch_read_blob_compare_and_swap(long handle, long batch, int index, String alias, Reference<ByteBuffer> originalContent)
public static int batch_read_blob_get(long handle, long batch, int index, String alias, Reference<ByteBuffer> content)
public static int batch_read_blob_get_and_update(long handle, long batch, int index, String alias, Reference<ByteBuffer> content)
public static int batch_read_blob_put(long handle, long batch, int index, String alias)
public static int batch_read_blob_update(long handle, long batch, int index, String alias)
Copyright © 2021. All rights reserved.