Skip to content

M
MariaDB
Commit 791dc19f authored by unknown's avatar unknown
Browse files
Options

Ending spaces removed.

parent 4bcad090
Hide whitespace changes
Inline Side-by-side
Showing with 100 additions and 100 deletions
storage/cassandra/cassandra_se.cc
View file @ 791dc19f
......@@ -51,11 +51,11 @@ class Cassandra_se_impl: public Cassandra_se_interface
ConsistencyLevel::type write_consistency;
ConsistencyLevel::type read_consistency;
/* How many times to retry an operation before giving up */
int thrift_call_retries_to_do;
/* DDL data */
KsDef ks_def; /* KeySpace we're using (TODO: put this in table->share) */
CfDef cf_def; /* Column family we're using (TODO: put in table->share)*/
......@@ -68,15 +68,15 @@ class Cassandra_se_impl: public Cassandra_se_interface
/* Insert preparation */
typedef std::map<std::string, std::vector<Mutation> > ColumnFamilyToMutation;
typedef std::map<std::string, ColumnFamilyToMutation> KeyToCfMutationMap;
KeyToCfMutationMap batch_mutation; /* Prepare operation here */
int64_t insert_timestamp;
std::vector<Mutation>* insert_list;
/* Resultset we're reading */
std::vector<KeySlice> key_slice_vec;
std::vector<KeySlice>::iterator key_slice_it;
std::string rowkey; /* key of the record we're returning now */
SlicePredicate slice_pred;
......@@ -84,12 +84,12 @@ class Cassandra_se_impl: public Cassandra_se_interface
bool get_slices_returned_less;
bool get_slice_found_rows;
public:
Cassandra_se_impl() : cass(NULL),
Cassandra_se_impl() : cass(NULL),
write_consistency(ConsistencyLevel::ONE),
read_consistency(ConsistencyLevel::ONE),
thrift_call_retries_to_do(0) {}
virtual ~Cassandra_se_impl(){ delete cass; }
/* Connection and DDL checks */
bool connect(const char *host, int port, const char *keyspace);
void set_column_family(const char *cfname) { column_family.assign(cfname); }
......@@ -137,7 +137,7 @@ class Cassandra_se_impl: public Cassandra_se_interface
void clear_read_columns();
void clear_read_all_columns();
void add_read_column(const char *name);
/* Reads, MRR scans */
void new_lookup_keys();
int add_lookup_key(const char *key, size_t key_len);
......@@ -164,7 +164,7 @@ class Cassandra_se_impl: public Cassandra_se_interface
/* Non-inherited utility functions: */
int64_t get_i64_timestamp();
typedef bool (Cassandra_se_impl::*retryable_func_t)();
bool try_operation(retryable_func_t func);
};
......@@ -182,17 +182,17 @@ Cassandra_se_interface *create_cassandra_se()
bool Cassandra_se_impl::connect(const char *host, int port, const char *keyspace_arg)
{
bool res= true;
keyspace.assign(keyspace_arg);
try {
boost::shared_ptr<TTransport> socket =
boost::shared_ptr<TTransport> socket =
boost::shared_ptr<TSocket>(new TSocket(host, port));
boost::shared_ptr<TTransport> tr =
boost::shared_ptr<TTransport> tr =
boost::shared_ptr<TFramedTransport>(new TFramedTransport (socket));
boost::shared_ptr<TProtocol> p =
boost::shared_ptr<TProtocol> p =
boost::shared_ptr<TBinaryProtocol>(new TBinaryProtocol(tr));
cass= new CassandraClient(p);
tr->open();
cass->set_keyspace(keyspace_arg);
......@@ -216,7 +216,7 @@ bool Cassandra_se_impl::connect(const char *host, int port, const char *keyspace
}
void Cassandra_se_impl::set_consistency_levels(ulong read_cons_level,
void Cassandra_se_impl::set_consistency_levels(ulong read_cons_level,
ulong write_cons_level)
{
write_cons_level= (ConsistencyLevel::type)(write_cons_level + 1);
......@@ -229,7 +229,7 @@ bool Cassandra_se_impl::retryable_setup_ddl_checks()
try {
cass->describe_keyspace(ks_def, keyspace);
} catch (NotFoundException nfe) {
print_error("keyspace `%s` not found: %s", keyspace.c_str(), nfe.what());
return true;
......@@ -261,7 +261,7 @@ void Cassandra_se_impl::first_ddl_column()
}
bool Cassandra_se_impl::next_ddl_column(char **name, int *name_len,
bool Cassandra_se_impl::next_ddl_column(char **name, int *name_len,
char **type, int *type_len)
{
if (column_ddl_it == cf_def.column_metadata.end())
......@@ -314,7 +314,7 @@ int64_t Cassandra_se_impl::get_i64_timestamp()
int64_t usec = td.tv_usec;
usec = usec / 1000;
ms += usec;
return ms;
}
......@@ -345,7 +345,7 @@ void Cassandra_se_impl::add_row_deletion(const char *key, int key_len,
{
std::string key_to_delete;
key_to_delete.assign(key, key_len);
batch_mutation[key_to_delete]= ColumnFamilyToMutation();
ColumnFamilyToMutation& cf_mut= batch_mutation[key_to_delete];
......@@ -357,7 +357,7 @@ void Cassandra_se_impl::add_row_deletion(const char *key, int key_len,
mut.deletion.__isset.timestamp= true;
mut.deletion.timestamp= get_i64_timestamp();
mut.deletion.__isset.predicate= true;
/*
Attempting to delete columns with SliceRange causes exception with message
"Deletion does not yet support SliceRange predicates".
......@@ -439,7 +439,7 @@ bool Cassandra_se_impl::do_insert()
*/
if (batch_mutation.empty())
return false;
return try_operation(&Cassandra_se_impl::retryable_do_insert);
}
......@@ -449,7 +449,7 @@ bool Cassandra_se_impl::do_insert()
/////////////////////////////////////////////////////////////////////////////
/*
Make one key lookup. If the record is found, the result is stored locally and
Make one key lookup. If the record is found, the result is stored locally and
the caller should iterate over it.
*/
......@@ -475,7 +475,7 @@ bool Cassandra_se_impl::retryable_get_slice()
sr.finish = "";
slice_pred.__set_slice_range(sr);
cass->get_slice(column_data_vec, rowkey, cparent, slice_pred,
cass->get_slice(column_data_vec, rowkey, cparent, slice_pred,
read_consistency);
if (column_data_vec.size() == 0)
......@@ -548,7 +548,7 @@ void Cassandra_se_impl::get_read_rowkey(char **value, int *value_len)
bool Cassandra_se_impl::get_range_slices(bool last_key_as_start_key)
{
get_range_slices_param_last_key_as_start_key= last_key_as_start_key;
return try_operation(&Cassandra_se_impl::retryable_get_range_slices);
}
......@@ -556,10 +556,10 @@ bool Cassandra_se_impl::get_range_slices(bool last_key_as_start_key)
bool Cassandra_se_impl::retryable_get_range_slices()
{
bool last_key_as_start_key= get_range_slices_param_last_key_as_start_key;
ColumnParent cparent;
cparent.column_family= column_family;
/* SlicePredicate can be used to limit columns we will retrieve */
KeyRange key_range;
......@@ -620,7 +620,7 @@ bool Cassandra_se_impl::get_next_range_slice_row(bool *eof)
return false;
}
}
/*
(1) - skip the last row that we have read in the previous batch.
(2) - Rows that were deleted show up as rows without any columns. Skip
......@@ -710,16 +710,16 @@ bool Cassandra_se_impl::try_operation(retryable_func_t func_to_call)
res= true;
try {
if ((res= (this->*func_to_call)()))
{
/*
The function call was made successfully (without timeouts, etc),
but something inside it returned 'true'.
but something inside it returned 'true'.
This is supposedly a failure (or "not found" or other negative
result). We need to return this to the caller.
*/
n_retries= 0;
n_retries= 0;
}
} catch (InvalidRequestException ire) {
......@@ -735,7 +735,7 @@ bool Cassandra_se_impl::try_operation(retryable_func_t func_to_call)
print_error("TimedOutException: %s", te.what());
}catch(TException e){
/* todo: we may use retry for certain kinds of Thrift errors */
n_retries= 0;
n_retries= 0;
print_error("Thrift exception: %s", e.what());
} catch (...) {
n_retries= 0; /* Don't retry */
......
storage/cassandra/cassandra_se.h
View file @ 791dc19f
......@@ -37,7 +37,7 @@ class Cassandra_se_interface
{
public:
Cassandra_se_interface() { err_buffer[0]=0; }
virtual ~Cassandra_se_interface(){};
/* Init */
virtual bool connect(const char *host, int port, const char *keyspace)=0;
......@@ -45,11 +45,11 @@ class Cassandra_se_interface
/* Settings */
virtual void set_consistency_levels(ulong read_cons_level, ulong write_cons_level)=0;
/* Check underlying DDL */
virtual bool setup_ddl_checks()=0;
virtual void first_ddl_column()=0;
virtual bool next_ddl_column(char **name, int *name_len, char **value,
virtual bool next_ddl_column(char **name, int *name_len, char **value,
int *value_len)=0;
virtual void get_rowkey_type(char **name, char **type)=0;
virtual size_t get_ddl_size()=0;
......@@ -106,7 +106,7 @@ class Cassandra_status_vars
public:
ulong row_inserts;
ulong row_insert_batches;
ulong multiget_reads;
ulong multiget_keys_scanned;
ulong multiget_rows_read;
......
storage/cassandra/ha_cassandra.cc
View file @ 791dc19f
......@@ -113,7 +113,7 @@ static MYSQL_THDVAR_ULONG(failure_retries, PLUGIN_VAR_RQCMDARG,
NULL, NULL, /*default*/ 0, /*min*/ 0, /*max*/ 1024*1024*1024, 0);
/* These match values in enum_cassandra_consistency_level */
const char *cassandra_consistency_level[] =
const char *cassandra_consistency_level[] =
{
"ONE",
"QUORUM",
......@@ -145,19 +145,19 @@ mysql_mutex_t cassandra_default_host_lock;
static char* cassandra_default_thrift_host = NULL;
static char cassandra_default_host_buf[256]="";
static void
cassandra_default_thrift_host_update(THD *thd,
static void
cassandra_default_thrift_host_update(THD *thd,
struct st_mysql_sys_var* var,
void* var_ptr, /*!< out: where the
formal string goes */
const void* save) /*!< in: immediate result
const void* save) /*!< in: immediate result
from check function */
{
const char *new_host= *((char**)save);
const size_t max_len= sizeof(cassandra_default_host_buf);
mysql_mutex_lock(&cassandra_default_host_lock);
if (new_host)
{
strncpy(cassandra_default_host_buf, new_host, max_len);
......@@ -169,7 +169,7 @@ cassandra_default_thrift_host_update(THD *thd,
cassandra_default_host_buf[0]= 0;
cassandra_default_thrift_host= NULL;
}
*((const char**)var_ptr)= cassandra_default_thrift_host;
mysql_mutex_unlock(&cassandra_default_host_lock);
......@@ -177,10 +177,10 @@ cassandra_default_thrift_host_update(THD *thd,
static MYSQL_SYSVAR_STR(default_thrift_host, cassandra_default_thrift_host,
PLUGIN_VAR_RQCMDARG,
"Default host for Cassandra thrift connections",
PLUGIN_VAR_RQCMDARG,
"Default host for Cassandra thrift connections",
/*check*/NULL,
cassandra_default_thrift_host_update,
cassandra_default_thrift_host_update,
/*default*/NULL);
static struct st_mysql_sys_var* cassandra_system_variables[]= {
......@@ -465,7 +465,7 @@ int ha_cassandra::open(const char *name, int mode, uint test_if_locked)
if (!(share = get_share(name, table)))
DBUG_RETURN(1);
thr_lock_data_init(&share->lock,&lock,NULL);
DBUG_ASSERT(!se);
/*
Don't do the following on open: it prevents SHOW CREATE TABLE when the server
......@@ -501,7 +501,7 @@ int ha_cassandra::check_table_options(ha_table_option_struct *options)
if (!options->thrift_host && (!cassandra_default_thrift_host ||
!cassandra_default_thrift_host[0]))
{
my_error(ER_CONNECT_TO_FOREIGN_DATA_SOURCE, MYF(0),
my_error(ER_CONNECT_TO_FOREIGN_DATA_SOURCE, MYF(0),
"thrift_host table option must be specified, or "
"@@cassandra_default_thrift_host must be set");
return HA_WRONG_CREATE_OPTION;
......@@ -509,7 +509,7 @@ int ha_cassandra::check_table_options(ha_table_option_struct *options)
if (!options->keyspace || !options->column_family)
{
my_error(ER_CONNECT_TO_FOREIGN_DATA_SOURCE, MYF(0),
my_error(ER_CONNECT_TO_FOREIGN_DATA_SOURCE, MYF(0),
"keyspace and column_family table options must be specified");
return HA_WRONG_CREATE_OPTION;
}
......@@ -543,7 +543,7 @@ int ha_cassandra::create(const char *name, TABLE *table_arg,
int res;
DBUG_ENTER("ha_cassandra::create");
DBUG_ASSERT(options);
Field **pfield= table_arg->s->field;
if (!((*pfield)->flags & NOT_NULL_FLAG))
{
......@@ -555,7 +555,7 @@ int ha_cassandra::create(const char *name, TABLE *table_arg,
table_arg->key_info[0].key_parts != 1 ||
table_arg->key_info[0].key_part[0].fieldnr != 1)
{
my_error(ER_WRONG_COLUMN_NAME, MYF(0),
my_error(ER_WRONG_COLUMN_NAME, MYF(0),
"Table must have PRIMARY KEY defined over the first column");
DBUG_RETURN(HA_WRONG_CREATE_OPTION);
}
......@@ -582,7 +582,7 @@ class ColumnDataConverter
Field *field;
/* This will save Cassandra's data in the Field */
virtual int cassandra_to_mariadb(const char *cass_data,
virtual int cassandra_to_mariadb(const char *cass_data,
int cass_data_len)=0;
/*
......@@ -610,7 +610,7 @@ class DoubleDataConverter : public ColumnDataConverter
field->store(*pdata);
return 0;
}
bool mariadb_to_cassandra(char **cass_data, int *cass_data_len)
{
buf= field->val_real();
......@@ -672,7 +672,7 @@ class BigintDataConverter : public ColumnDataConverter
field->store(tmp);
return 0;
}
bool mariadb_to_cassandra(char **cass_data, int *cass_data_len)
{
longlong tmp= field->val_int();
......@@ -731,7 +731,7 @@ class Int32DataConverter : public ColumnDataConverter
field->store(tmp);
return 0;
}
bool mariadb_to_cassandra(char **cass_data, int *cass_data_len)
{
int32_t tmp= field->val_int();
......@@ -756,7 +756,7 @@ class StringCopyConverter : public ColumnDataConverter
field->store(cass_data, cass_data_len,field->charset());
return 0;
}
bool mariadb_to_cassandra(char **cass_data, int *cass_data_len)
{
String *pstr= field->val_str(&buf);
......@@ -780,7 +780,7 @@ class TimestampDataConverter : public ColumnDataConverter
DBUG_ASSERT(cass_data_len==8);
flip64(cass_data, (char*)&tmp);
/*
store_TIME's arguments:
store_TIME's arguments:
- seconds since epoch
- microsecond fraction of a second.
*/
......@@ -794,7 +794,7 @@ class TimestampDataConverter : public ColumnDataConverter
ulong ts_microsec;
int64_t tmp;
ts_time= ((Field_timestamp*)field)->get_timestamp(&ts_microsec);
/* Cassandra needs milliseconds-since-epoch */
tmp= ((int64_t)ts_time) * 1000 + ts_microsec/1000;
flip64((const char*)&tmp, (char*)&buf);
......@@ -1383,7 +1383,7 @@ ColumnDataConverter *map_field_to_validator(Field *field, const char *validator_
{
/*
Cassandra's "varint" type is a binary-encoded arbitary-length
big-endian number.
big-endian number.
- It can be mapped to VARBINARY(N), with sufficiently big N.
- If the value does not fit into N bytes, it is an error. We should not
truncate it, because that is just as good as returning garbage.
......@@ -1391,7 +1391,7 @@ ColumnDataConverter *map_field_to_validator(Field *field, const char *validator_
are zero-padded, which will work as multiplying the value by
2^k for some value of k.
*/
if (field->type() == MYSQL_TYPE_VARCHAR &&
if (field->type() == MYSQL_TYPE_VARCHAR &&
field->binary() &&
(!strcmp(validator_name, validator_varint) ||
!strcmp(validator_name, validator_decimal)))
......@@ -1675,7 +1675,7 @@ int ha_cassandra::index_read_map(uchar *buf, const uchar *key,
}
void ha_cassandra::print_conversion_error(const char *field_name,
void ha_cassandra::print_conversion_error(const char *field_name,
char *cass_value,
int cass_value_len)
{
......@@ -1691,7 +1691,7 @@ void ha_cassandra::print_conversion_error(const char *field_name,
se->print_error("Unable to convert value for field `%s` from Cassandra's data"
" format. Source data is %d bytes, 0x%s%s",
field_name, cass_value_len, buf,
field_name, cass_value_len, buf,
(i == sizeof(buf) - 1)? "..." : "");
my_error(ER_INTERNAL_ERROR, MYF(0), se->error_str());
}
......@@ -1759,7 +1759,7 @@ int ha_cassandra::read_cassandra_columns(bool unpack_pk)
if (field_converters[fieldnr]->cassandra_to_mariadb(cass_value,
cass_value_len))
{
print_conversion_error((*field)->field_name, cass_value,
print_conversion_error((*field)->field_name, cass_value,
cass_value_len);
res=1;
goto err;
......@@ -1948,7 +1948,7 @@ int ha_cassandra::write_row(uchar *buf)
my_bitmap_map *old_map;
int ires;
DBUG_ENTER("ha_cassandra::write_row");
if (!se && (ires= connect_and_check_options(table)))
DBUG_RETURN(ires);
......@@ -1956,7 +1956,7 @@ int ha_cassandra::write_row(uchar *buf)
se->clear_insert_buffer();
old_map= dbug_tmp_use_all_columns(table, table->read_set);
insert_lineno++;
/* Convert the key */
......@@ -2008,9 +2008,9 @@ int ha_cassandra::write_row(uchar *buf)
}
dbug_tmp_restore_column_map(table->read_set, old_map);
bool res;
if (doing_insert_batch)
{
res= 0;
......@@ -2025,7 +2025,7 @@ int ha_cassandra::write_row(uchar *buf)
if (res)
my_error(ER_INTERNAL_ERROR, MYF(0), se->error_str());
DBUG_RETURN(res? HA_ERR_INTERNAL_ERROR: 0);
}
......@@ -2046,7 +2046,7 @@ void ha_cassandra::start_bulk_insert(ha_rows rows)
int ha_cassandra::end_bulk_insert()
{
DBUG_ENTER("ha_cassandra::end_bulk_insert");
/* Flush out the insert buffer */
doing_insert_batch= false;
bool bres= se->do_insert();
......@@ -2133,7 +2133,7 @@ int ha_cassandra::delete_all_rows()
DBUG_RETURN(ires);
bres= se->truncate();
if (bres)
my_error(ER_INTERNAL_ERROR, MYF(0), se->error_str());
......@@ -2145,12 +2145,12 @@ int ha_cassandra::delete_row(const uchar *buf)
{
bool bres;
DBUG_ENTER("ha_cassandra::delete_row");
bres= se->remove_row();
if (bres)
my_error(ER_INTERNAL_ERROR, MYF(0), se->error_str());
DBUG_RETURN(bres? HA_ERR_INTERNAL_ERROR: 0);
}
......@@ -2158,7 +2158,7 @@ int ha_cassandra::delete_row(const uchar *buf)
int ha_cassandra::info(uint flag)
{
DBUG_ENTER("ha_cassandra::info");
if (!table)
return 1;
......@@ -2183,7 +2183,7 @@ void key_copy(uchar *to_key, uchar *from_record, KEY *key_info,
void ha_cassandra::position(const uchar *record)
{
DBUG_ENTER("ha_cassandra::position");
/* Copy the primary key to rowid */
key_copy(ref, (uchar*)record, &table->key_info[0],
table->field[0]->key_length(), true);
......@@ -2196,7 +2196,7 @@ int ha_cassandra::rnd_pos(uchar *buf, uchar *pos)
{
int rc;
DBUG_ENTER("ha_cassandra::rnd_pos");
int save_active_index= active_index;
active_index= 0; /* The primary key */
rc= index_read_map(buf, pos, key_part_map(1), HA_READ_KEY_EXACT);
......@@ -2230,7 +2230,7 @@ int ha_cassandra::reset()
- anything else?
*/
ha_rows ha_cassandra::multi_range_read_info_const(uint keyno, RANGE_SEQ_IF *seq,
void *seq_init_param,
void *seq_init_param,
uint n_ranges, uint *bufsz,
uint *flags, COST_VECT *cost)
{
......@@ -2240,7 +2240,7 @@ ha_rows ha_cassandra::multi_range_read_info_const(uint keyno, RANGE_SEQ_IF *seq,
ha_rows ha_cassandra::multi_range_read_info(uint keyno, uint n_ranges, uint keys,
uint key_parts, uint *bufsz,
uint key_parts, uint *bufsz,
uint *flags, COST_VECT *cost)
{
/* Can only be equality lookups on the primary key... */
......@@ -2269,14 +2269,14 @@ bool ha_cassandra::mrr_start_read()
my_bitmap_map *old_map;
old_map= dbug_tmp_use_all_columns(table, table->read_set);
se->new_lookup_keys();
while (!(source_exhausted= mrr_funcs.next(mrr_iter, &mrr_cur_range)))
{
char *cass_key;
int cass_key_len;
DBUG_ASSERT(mrr_cur_range.range_flag & EQ_RANGE);
uchar *key= (uchar*)mrr_cur_range.start_key.key;
......@@ -2285,9 +2285,9 @@ bool ha_cassandra::mrr_start_read()
store_key_image_to_rec(table->field[0], (uchar*)key, key_len);
rowkey_converter->mariadb_to_cassandra(&cass_key, &cass_key_len);
// Primitive buffer control
if (se->add_lookup_key(cass_key, cass_key_len) >
if (se->add_lookup_key(cass_key, cass_key_len) >
THDVAR(table->in_use, multiget_batch_size))
break;
}
......@@ -2308,7 +2308,7 @@ int ha_cassandra::multi_range_read_next(range_id_t *range_info)
res= read_cassandra_columns(true);
break;
}
else
else
{
if (source_exhausted)
{
......@@ -2324,7 +2324,7 @@ int ha_cassandra::multi_range_read_next(range_id_t *range_info)
}
}
}
/*
/*
We get here if we've refilled the buffer and done another read. Try
reading from results again
*/
......@@ -2444,7 +2444,7 @@ int ha_cassandra::update_row(const uchar *old_data, uchar *new_data)
}
/*
Compare it to the key we've read. For all types that Cassandra supports,
Compare it to the key we've read. For all types that Cassandra supports,
binary byte-wise comparison can be used
*/
bool new_primary_key;
......@@ -2472,8 +2472,8 @@ int ha_cassandra::update_row(const uchar *old_data, uchar *new_data)
if (new_primary_key)
{
/*
Primary key value changed. This is essentially a DELETE + INSERT.
/*
Primary key value changed. This is essentially a DELETE + INSERT.
Add a DELETE operation into the batch
*/
Column_name_enumerator_impl name_enumerator(this);
......@@ -2606,7 +2606,7 @@ int ha_cassandra::external_lock(THD *thd, int lock_type)
int ha_cassandra::delete_table(const char *name)
{
DBUG_ENTER("ha_cassandra::delete_table");
/*
/*
Cassandra table is just a view. Dropping it doesn't affect the underlying
column family.
*/
......@@ -2640,7 +2640,7 @@ bool ha_cassandra::check_if_incompatible_data(HA_CREATE_INFO *info,
static int show_cassandra_vars(THD *thd, SHOW_VAR *var, char *buff)
{
cassandra_counters_copy= cassandra_counters;
cassandra_counters_copy= cassandra_counters;
var->type= SHOW_ARRAY;
var->value= (char *) &cassandra_status_variables;
......
storage/cassandra/ha_cassandra.h
View file @ 791dc19f
/*
/*
Copyright (c) 2012, Monty Program Ab
This program is free software; you can redistribute it and/or modify
......@@ -106,7 +106,7 @@ class ha_cassandra: public handler
/* Used to produce 'wrong column %s at row %lu' warnings */
ha_rows insert_lineno;
void print_conversion_error(const char *field_name,
void print_conversion_error(const char *field_name,
char *cass_value, int cass_value_len);
int connect_and_check_options(TABLE *table_arg);
public:
......@@ -144,12 +144,12 @@ class ha_cassandra: public handler
We are saying that this engine is just statement capable to have
an engine that can only handle statement-based logging. This is
used in testing.
HA_REC_NOT_IN_SEQ
If we don't set it, filesort crashes, because it assumes rowids are
1..8 byte numbers
HA_REC_NOT_IN_SEQ
If we don't set it, filesort crashes, because it assumes rowids are
1..8 byte numbers
*/
return HA_BINLOG_STMT_CAPABLE |
HA_REC_NOT_IN_SEQ;
return HA_BINLOG_STMT_CAPABLE |
HA_REC_NOT_IN_SEQ;
}
......@@ -191,7 +191,7 @@ class ha_cassandra: public handler
support indexes.
*/
uint max_supported_key_length() const { return 16*1024; /* just to return something*/ }
int index_init(uint idx, bool sorted);
int index_read_map(uchar * buf, const uchar * key,
......@@ -211,19 +211,19 @@ class ha_cassandra: public handler
virtual void start_bulk_insert(ha_rows rows);
virtual int end_bulk_insert();
virtual int reset();
int multi_range_read_init(RANGE_SEQ_IF *seq, void *seq_init_param,
uint n_ranges, uint mode, HANDLER_BUFFER *buf);
int multi_range_read_next(range_id_t *range_info);
ha_rows multi_range_read_info_const(uint keyno, RANGE_SEQ_IF *seq,
void *seq_init_param,
void *seq_init_param,
uint n_ranges, uint *bufsz,
uint *flags, COST_VECT *cost);
ha_rows multi_range_read_info(uint keyno, uint n_ranges, uint keys,
uint key_parts, uint *bufsz,
uint key_parts, uint *bufsz,
uint *flags, COST_VECT *cost);
int multi_range_read_explain_info(uint mrr_mode, char *str, size_t size);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7