|
void
|
add(String rowKey, String columnParent, String counterName, int counterValue)
Increments a CounterColumn consisting of (name, value) at the given
ColumnParent.
|
|
void
|
batchMutable(Map content)
Executes the specified mutations on the keyspace.
|
|
void
|
connect(String username, String password)
Method invoked when a connection is required
|
|
String
|
connectionId()
Connection Identifier
|
|
String
|
describeClusterName()
Gets the name of the cluster.
|
|
Object
|
describeKeyspace(String keyspace)
Gets information about the specified keyspace.
|
|
List
|
describeKeyspaces()
Gets a list of all the keyspaces configured for the cluster.
|
|
String
|
describePartitioner()
Gets the name of the partitioner for the cluster.
|
|
List
|
describeRing(String keyspace)
Gets the token ring; a map of ranges to host addresses.
|
|
Map
|
describeSchemaVersions()
For each schema version present in the cluster, returns a list of nodes
at that version.
|
|
String
|
describeSnitch()
Gets the name of the snitch used for the cluster.
|
|
String
|
describeVersion()
Gets the Thrift API version.
|
|
void
|
disconnect()
Disconnect
|
|
Object
|
executeCqlQuery(String query, Compression compression)
Executes a CQL (Cassandra Query Language) statement and returns a
CqlResult containing the results.
|
|
Object
|
get(String rowKey, String columnPath, List<ColumnSerializer> columnSerializers)
Get Column or SuperColumn by the path
|
|
ConsistencyLevel
|
getConsistencyLevel()
|
|
int
|
getCount(String rowKey, String columnParent, String start, String finish, boolean reversed, int count)
Counts the columns present in column_parent within the predicate.
|
|
String
|
getHost()
|
|
Object
|
getIndexedSlices(String columnParent, String start, String finish, boolean reversed, int count, int clauseCount, String clauseStartKey, List<IndexExpresion> expressionList)
Like get_range_slices, returns a list of slices, but uses IndexClause
instead of KeyRange.
|
|
String
|
getKeyspace()
|
|
int
|
getPort()
|
|
Object
|
getRangeSlices(String columnParent, String start, String finish, boolean reversed, int count, String startKey, String endKey, String startToken, String endToken, int keyRangeCount)
Replaces get_range_slice.
|
|
Object
|
getRow(String rowKey, ColumnPath columnPath, List<ColumnSerializer> columnSerializers)
Get Column or SuperColumn by the path
|
|
Object
|
getSlice(String rowKey, String columnParent, String start, String finish, boolean reversed, int count, List<ColumnSerializer> columnSerializers)
Get the group of columns contained by column_parent (either a
ColumnFamily name or a ColumnFamily/SuperColumn name pair) specified by
the given SlicePredicate (start, finish, reversed and count) parameters.
|
|
void
|
insert(String rowKey, String columnParent, String columnName, String columnValue, int ttl)
Insert a Column consisting of (name, value, timestamp, ttl) at the given
ColumnParent.
|
|
Map
|
insertFromMap(Map content)
Insert object into the database
|
|
boolean
|
isConnected()
Are we connected
|
|
Object
|
multiGetCount(List<String> rowKeys, String columnParent, String start, String finish, boolean reversed, int count)
A combination of multiget_slice and get_count.
|
|
Object
|
multiGetSlice(List<String> rowKeys, String columnParent, String start, String finish, boolean reversed, int count, List<ColumnSerializer> columnSerializers)
Retrieves slices for column_parent and predicate on each of the given
keys in parallel.
|
|
void
|
remove(String rowKey, String columnPath)
Remove data from the row specified by key at the granularity specified by
column_path, and the given timestamp.
|
|
void
|
removeCounter(String rowKey, String columnPath)
Remove a counter from the row specified by key at the granularity
specified by column_path.
|
|
void
|
setClient(Cassandra.Client client)
|
|
void
|
setConsistencyLevel(ConsistencyLevel consistencyLevel)
|
|
void
|
setHost(String host)
|
|
void
|
setKeyspace(String keyspace)
|
|
void
|
setPort(int port)
|
|
void
|
setQueryKeyspace(String value)
Set the keyspace to use for subsequent requests.
|
|
String
|
systemAddColumnFamilyFromObject(CfDef cfDefinition)
Adds a column family.
|
|
String
|
systemAddColumnFamilyFromObjectWithSimpleNames(CfDef cfDefinition, List<String> columnNames)
Adds a column family.
|
|
String
|
systemAddColumnFamilyWithParams(String columnFamilyName, String comparatorType, String keyValidationClass, String defaultValidationClass, List<ColumnDef> columnMetadata, String keyspace)
Adds a column family to the current keyspace.
|
|
String
|
systemAddKeyspaceFromObject(KsDef keyspaceDefinition)
Creates a new keyspace and any column families defined with it.
|
|
Object
|
systemAddKeyspaceWithParams(String keyspaceName, List<String> columnNames, ReplicationStrategy strategyClass, Map<String, String> strategyOptions)
Creates a new keyspace with the provided name with all the defaults values
|
|
String
|
systemDropColumnFamily(String columnFamily)
Drops a column family.
|
|
Object
|
systemDropKeyspace(String keyspace)
Drops a keyspace.
|
|
String
|
systemUpdateColumnFamily(CfDef columnFamily)
Updates properties of a ColumnFamily.
|
|
String
|
systemUpdateKeyspace(KsDef keyspaceDef)
Updates properties of a keyspace.
|
|
void
|
truncate(String columnFamily)
Removes all the rows from the given column family.
|
Known Direct Subclasses