CassandraServer (apache-cassandra API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.cassandra.thrift
Class CassandraServer

java.lang.Object
  org.apache.cassandra.thrift.CassandraServer

All Implemented Interfaces:: org.apache.cassandra.thrift.Cassandra.Iface

public class CassandraServer
extends java.lang.Object
implements org.apache.cassandra.thrift.Cassandra.Iface
extends java.lang.Object
implements org.apache.cassandra.thrift.Cassandra.Iface

Field Summary
`static java.lang.String`	`TOKEN_MAP`

Constructor Summary
`CassandraServer()`

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.thrift.ColumnOrSuperColumn>> cfmap, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`void`	`batch_mutate(java.lang.String keyspace, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.thrift.Mutation>>> mutation_map, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`protected void`	`checkLoginDone()`
`java.lang.String`	`describe_cluster_name()`
`java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>`	`describe_keyspace(java.lang.String table)`
`java.util.Set<java.lang.String>`	`describe_keyspaces()`
`java.util.List<org.apache.cassandra.thrift.TokenRange>`	`describe_ring(java.lang.String keyspace)`
`java.util.List<java.lang.String>`	`describe_splits(java.lang.String start_token, java.lang.String end_token, int keys_per_split)`
`java.lang.String`	`describe_version()`
`int`	`get_count(java.lang.String table, java.lang.String key, org.apache.cassandra.thrift.ColumnParent column_parent, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`java.util.List<org.apache.cassandra.thrift.KeySlice>`	`get_range_slice(java.lang.String keyspace, org.apache.cassandra.thrift.ColumnParent column_parent, org.apache.cassandra.thrift.SlicePredicate predicate, java.lang.String start_key, java.lang.String finish_key, int maxRows, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`java.util.List<org.apache.cassandra.thrift.KeySlice>`	`get_range_slices(java.lang.String keyspace, org.apache.cassandra.thrift.ColumnParent column_parent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.KeyRange range, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>`	`get_slice(java.lang.String keyspace, java.lang.String key, org.apache.cassandra.thrift.ColumnParent column_parent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel 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.thrift.ColumnOrSuperColumn`	`get(java.lang.String table, java.lang.String key, org.apache.cassandra.thrift.ColumnPath column_path, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`void`	`insert(java.lang.String table, java.lang.String key, org.apache.cassandra.thrift.ColumnPath column_path, byte[] value, long timestamp, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`void`	`login(java.lang.String keyspace, org.apache.cassandra.thrift.AuthenticationRequest auth_request)`
`java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>>`	`multiget_slice(java.lang.String keyspace, java.util.List<java.lang.String> keys, org.apache.cassandra.thrift.ColumnParent column_parent, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`java.util.Map<java.lang.String,org.apache.cassandra.thrift.ColumnOrSuperColumn>`	`multiget(java.lang.String table, java.util.List<java.lang.String> keys, org.apache.cassandra.thrift.ColumnPath column_path, org.apache.cassandra.thrift.ConsistencyLevel 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, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`void`	`remove(java.lang.String table, java.lang.String key, org.apache.cassandra.thrift.ColumnPath column_path, long timestamp, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)`
`java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>`	`thriftifyColumns(java.util.Collection<IColumn> columns, boolean reverseOrder)`
`java.util.List<org.apache.cassandra.thrift.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`

Field Detail

TOKEN_MAP

public static java.lang.String TOKEN_MAP

Constructor Detail

CassandraServer

public CassandraServer()

Method Detail

readColumnFamily

protected java.util.Map<java.lang.String,ColumnFamily> readColumnFamily(java.util.List<ReadCommand> commands,
                                                                        org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                                                 throws org.apache.cassandra.thrift.InvalidRequestException,
                                                                        org.apache.cassandra.thrift.UnavailableException,
                                                                        org.apache.cassandra.thrift.TimedOutException

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

thriftifySubColumns

public java.util.List<org.apache.cassandra.thrift.Column> thriftifySubColumns(java.util.Collection<IColumn> columns)

thriftifyColumns

public java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn> thriftifyColumns(java.util.Collection<IColumn> columns,
                                                                                        boolean reverseOrder)

get_slice

public java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn> get_slice(java.lang.String keyspace,
                                                                                 java.lang.String key,
                                                                                 org.apache.cassandra.thrift.ColumnParent column_parent,
                                                                                 org.apache.cassandra.thrift.SlicePredicate predicate,
                                                                                 org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                                                          throws org.apache.cassandra.thrift.InvalidRequestException,
                                                                                 org.apache.cassandra.thrift.UnavailableException,
                                                                                 org.apache.cassandra.thrift.TimedOutException

Specified by:: get_slice in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

multiget_slice

public java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.thrift.ColumnOrSuperColumn>> multiget_slice(java.lang.String keyspace,
                                                                                                                      java.util.List<java.lang.String> keys,
                                                                                                                      org.apache.cassandra.thrift.ColumnParent column_parent,
                                                                                                                      org.apache.cassandra.thrift.SlicePredicate predicate,
                                                                                                                      org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                                                                                               throws org.apache.cassandra.thrift.InvalidRequestException,
                                                                                                                      org.apache.cassandra.thrift.UnavailableException,
                                                                                                                      org.apache.cassandra.thrift.TimedOutException

Specified by:: multiget_slice in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

get

public org.apache.cassandra.thrift.ColumnOrSuperColumn get(java.lang.String table,
                                                           java.lang.String key,
                                                           org.apache.cassandra.thrift.ColumnPath column_path,
                                                           org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                                    throws org.apache.cassandra.thrift.InvalidRequestException,
                                                           org.apache.cassandra.thrift.NotFoundException,
                                                           org.apache.cassandra.thrift.UnavailableException,
                                                           org.apache.cassandra.thrift.TimedOutException

Specified by:: get in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.NotFoundException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

multiget

public java.util.Map<java.lang.String,org.apache.cassandra.thrift.ColumnOrSuperColumn> multiget(java.lang.String table,
                                                                                                java.util.List<java.lang.String> keys,
                                                                                                org.apache.cassandra.thrift.ColumnPath column_path,
                                                                                                org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                                                                         throws org.apache.cassandra.thrift.InvalidRequestException,
                                                                                                org.apache.cassandra.thrift.UnavailableException,
                                                                                                org.apache.cassandra.thrift.TimedOutException

always returns a ColumnOrSuperColumn for each key, even if there is no data for it

Specified by:: multiget in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

get_count

public int get_count(java.lang.String table,
                     java.lang.String key,
                     org.apache.cassandra.thrift.ColumnParent column_parent,
                     org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
              throws org.apache.cassandra.thrift.InvalidRequestException,
                     org.apache.cassandra.thrift.UnavailableException,
                     org.apache.cassandra.thrift.TimedOutException

Specified by:: get_count in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

insert

public void insert(java.lang.String table,
                   java.lang.String key,
                   org.apache.cassandra.thrift.ColumnPath column_path,
                   byte[] value,
                   long timestamp,
                   org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
            throws org.apache.cassandra.thrift.InvalidRequestException,
                   org.apache.cassandra.thrift.UnavailableException,
                   org.apache.cassandra.thrift.TimedOutException

Specified by:: insert in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

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.thrift.ColumnOrSuperColumn>> cfmap,
                         org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                  throws org.apache.cassandra.thrift.InvalidRequestException,
                         org.apache.cassandra.thrift.UnavailableException,
                         org.apache.cassandra.thrift.TimedOutException

Specified by:: batch_insert in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

batch_mutate

public void batch_mutate(java.lang.String keyspace,
                         java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<org.apache.cassandra.thrift.Mutation>>> mutation_map,
                         org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                  throws org.apache.cassandra.thrift.InvalidRequestException,
                         org.apache.cassandra.thrift.UnavailableException,
                         org.apache.cassandra.thrift.TimedOutException

Specified by:: batch_mutate in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

remove

public void remove(java.lang.String table,
                   java.lang.String key,
                   org.apache.cassandra.thrift.ColumnPath column_path,
                   long timestamp,
                   org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
            throws org.apache.cassandra.thrift.InvalidRequestException,
                   org.apache.cassandra.thrift.UnavailableException,
                   org.apache.cassandra.thrift.TimedOutException

Specified by:: remove in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.cassandra.thrift.TimedOutException

get_string_property

public java.lang.String get_string_property(java.lang.String propertyName)

Specified by:: get_string_property in interface org.apache.cassandra.thrift.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.thrift.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.thrift.NotFoundException

Specified by:: describe_keyspace in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.NotFoundException

get_range_slice

public java.util.List<org.apache.cassandra.thrift.KeySlice> get_range_slice(java.lang.String keyspace,
                                                                            org.apache.cassandra.thrift.ColumnParent column_parent,
                                                                            org.apache.cassandra.thrift.SlicePredicate predicate,
                                                                            java.lang.String start_key,
                                                                            java.lang.String finish_key,
                                                                            int maxRows,
                                                                            org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                                                     throws org.apache.cassandra.thrift.InvalidRequestException,
                                                                            org.apache.cassandra.thrift.UnavailableException,
                                                                            org.apache.thrift.TException,
                                                                            org.apache.cassandra.thrift.TimedOutException

Specified by:: get_range_slice in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.thrift.TException; org.apache.cassandra.thrift.TimedOutException

get_range_slices

public java.util.List<org.apache.cassandra.thrift.KeySlice> get_range_slices(java.lang.String keyspace,
                                                                             org.apache.cassandra.thrift.ColumnParent column_parent,
                                                                             org.apache.cassandra.thrift.SlicePredicate predicate,
                                                                             org.apache.cassandra.thrift.KeyRange range,
                                                                             org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                                                      throws org.apache.cassandra.thrift.InvalidRequestException,
                                                                             org.apache.cassandra.thrift.UnavailableException,
                                                                             org.apache.thrift.TException,
                                                                             org.apache.cassandra.thrift.TimedOutException

Specified by:: get_range_slices in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.InvalidRequestException; org.apache.cassandra.thrift.UnavailableException; org.apache.thrift.TException; org.apache.cassandra.thrift.TimedOutException

describe_keyspaces

public java.util.Set<java.lang.String> describe_keyspaces()
                                                   throws org.apache.thrift.TException

Specified by:: describe_keyspaces in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.thrift.TException

describe_cluster_name

public java.lang.String describe_cluster_name()
                                       throws org.apache.thrift.TException

Specified by:: describe_cluster_name in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.thrift.TException

describe_version

public java.lang.String describe_version()
                                  throws org.apache.thrift.TException

Specified by:: describe_version in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.thrift.TException

describe_ring

public java.util.List<org.apache.cassandra.thrift.TokenRange> describe_ring(java.lang.String keyspace)

Specified by:: describe_ring in interface org.apache.cassandra.thrift.Cassandra.Iface

describe_splits

public java.util.List<java.lang.String> describe_splits(java.lang.String start_token,
                                                        java.lang.String end_token,
                                                        int keys_per_split)
                                                 throws org.apache.thrift.TException

Specified by:: describe_splits in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.thrift.TException

login

public void login(java.lang.String keyspace,
                  org.apache.cassandra.thrift.AuthenticationRequest auth_request)
           throws org.apache.cassandra.thrift.AuthenticationException,
                  org.apache.cassandra.thrift.AuthorizationException,
                  org.apache.thrift.TException

Specified by:: login in interface org.apache.cassandra.thrift.Cassandra.Iface

Throws:: org.apache.cassandra.thrift.AuthenticationException; org.apache.cassandra.thrift.AuthorizationException; org.apache.thrift.TException

checkLoginDone

protected void checkLoginDone()
                       throws org.apache.cassandra.thrift.InvalidRequestException

Throws:: org.apache.cassandra.thrift.InvalidRequestException