org.apache.cassandra.service
Class CassandraServer
java.lang.Object
org.apache.cassandra.service.CassandraServer
- All Implemented Interfaces:
- org.apache.cassandra.service.Cassandra.Iface
public class CassandraServer
- extends java.lang.Object
- implements org.apache.cassandra.service.Cassandra.Iface
Method Summary |
void |
batch_insert(java.lang.String keyspace,
java.lang.String key,
java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn>> cfmap,
int consistency_level)
|
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> |
describe_keyspace(java.lang.String table)
|
int |
get_count(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnParent column_parent,
int consistency_level)
|
java.util.List<java.lang.String> |
get_key_range(java.lang.String tablename,
java.lang.String columnFamily,
java.lang.String startWith,
java.lang.String stopAt,
int maxResults,
int consistency_level)
|
java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn> |
get_slice(java.lang.String keyspace,
java.lang.String key,
org.apache.cassandra.service.ColumnParent column_parent,
org.apache.cassandra.service.SlicePredicate predicate,
int consistency_level)
|
java.util.List<java.lang.String> |
get_string_list_property(java.lang.String propertyName)
|
java.lang.String |
get_string_property(java.lang.String propertyName)
|
org.apache.cassandra.service.ColumnOrSuperColumn |
get(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnPath column_path,
int consistency_level)
|
void |
insert(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnPath column_path,
byte[] value,
long timestamp,
int consistency_level)
|
java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn>> |
multiget_slice(java.lang.String keyspace,
java.util.List<java.lang.String> keys,
org.apache.cassandra.service.ColumnParent column_parent,
org.apache.cassandra.service.SlicePredicate predicate,
int consistency_level)
|
java.util.Map<java.lang.String,org.apache.cassandra.service.ColumnOrSuperColumn> |
multiget(java.lang.String table,
java.util.List<java.lang.String> keys,
org.apache.cassandra.service.ColumnPath column_path,
int consistency_level)
always returns a ColumnOrSuperColumn for each key, even if there is no data for it |
protected java.util.Map<java.lang.String,ColumnFamily> |
readColumnFamily(java.util.List<ReadCommand> commands,
int consistency_level)
|
void |
remove(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnPath column_path,
long timestamp,
int consistency_level)
|
void |
start()
|
java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn> |
thriftifyColumns(java.util.Collection<IColumn> columns,
boolean reverseOrder)
|
java.util.List<org.apache.cassandra.service.Column> |
thriftifySubColumns(java.util.Collection<IColumn> columns)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TOKEN_MAP
public static java.lang.String TOKEN_MAP
storageService
protected StorageService storageService
CassandraServer
public CassandraServer()
start
public void start()
throws java.io.IOException
- Throws:
java.io.IOException
readColumnFamily
protected java.util.Map<java.lang.String,ColumnFamily> readColumnFamily(java.util.List<ReadCommand> commands,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
thriftifySubColumns
public java.util.List<org.apache.cassandra.service.Column> thriftifySubColumns(java.util.Collection<IColumn> columns)
thriftifyColumns
public java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn> thriftifyColumns(java.util.Collection<IColumn> columns,
boolean reverseOrder)
get_slice
public java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn> get_slice(java.lang.String keyspace,
java.lang.String key,
org.apache.cassandra.service.ColumnParent column_parent,
org.apache.cassandra.service.SlicePredicate predicate,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- Specified by:
get_slice
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
multiget_slice
public java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn>> multiget_slice(java.lang.String keyspace,
java.util.List<java.lang.String> keys,
org.apache.cassandra.service.ColumnParent column_parent,
org.apache.cassandra.service.SlicePredicate predicate,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- Specified by:
multiget_slice
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
get
public org.apache.cassandra.service.ColumnOrSuperColumn get(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnPath column_path,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.NotFoundException,
org.apache.cassandra.service.UnavailableException
- Specified by:
get
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.NotFoundException
org.apache.cassandra.service.UnavailableException
multiget
public java.util.Map<java.lang.String,org.apache.cassandra.service.ColumnOrSuperColumn> multiget(java.lang.String table,
java.util.List<java.lang.String> keys,
org.apache.cassandra.service.ColumnPath column_path,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- always returns a ColumnOrSuperColumn for each key, even if there is no data for it
- Specified by:
multiget
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
get_count
public int get_count(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnParent column_parent,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- Specified by:
get_count
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
insert
public void insert(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnPath column_path,
byte[] value,
long timestamp,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- Specified by:
insert
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
batch_insert
public void batch_insert(java.lang.String keyspace,
java.lang.String key,
java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.service.ColumnOrSuperColumn>> cfmap,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- Specified by:
batch_insert
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
remove
public void remove(java.lang.String table,
java.lang.String key,
org.apache.cassandra.service.ColumnPath column_path,
long timestamp,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.cassandra.service.UnavailableException
- Specified by:
remove
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException
get_string_property
public java.lang.String get_string_property(java.lang.String propertyName)
- Specified by:
get_string_property
in interface org.apache.cassandra.service.Cassandra.Iface
get_string_list_property
public java.util.List<java.lang.String> get_string_list_property(java.lang.String propertyName)
- Specified by:
get_string_list_property
in interface org.apache.cassandra.service.Cassandra.Iface
describe_keyspace
public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> describe_keyspace(java.lang.String table)
throws org.apache.cassandra.service.NotFoundException
- Specified by:
describe_keyspace
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.NotFoundException
get_key_range
public java.util.List<java.lang.String> get_key_range(java.lang.String tablename,
java.lang.String columnFamily,
java.lang.String startWith,
java.lang.String stopAt,
int maxResults,
int consistency_level)
throws org.apache.cassandra.service.InvalidRequestException,
org.apache.thrift.TException,
org.apache.cassandra.service.UnavailableException
- Specified by:
get_key_range
in interface org.apache.cassandra.service.Cassandra.Iface
- Throws:
org.apache.cassandra.service.InvalidRequestException
org.apache.thrift.TException
org.apache.cassandra.service.UnavailableException
Copyright © 2009 The Apache Software Foundation