Package | Description |
---|---|
org.apache.cassandra.hadoop.pig | |
org.apache.cassandra.thrift |
Modifier and Type | Method and Description |
---|---|
protected AbstractCassandraStorage.CfInfo |
AbstractCassandraStorage.getCfInfo(Cassandra.Client client)
return the CfInf for the column family
|
protected java.util.List<ColumnDef> |
AbstractCassandraStorage.getColumnMeta(Cassandra.Client client,
boolean cassandraStorage,
boolean includeCompactValueColumn)
get column meta data
|
protected abstract java.util.List<ColumnDef> |
AbstractCassandraStorage.getColumnMetadata(Cassandra.Client client)
get a list of columns
|
protected java.util.List<ColumnDef> |
CassandraStorage.getColumnMetadata(Cassandra.Client client)
get a list of column for the column family
|
protected java.util.List<ColumnDef> |
CqlStorage.getColumnMetadata(Cassandra.Client client)
include key columns
|
Modifier and Type | Field and Description |
---|---|
SchemaDisagreementException |
Cassandra.system_add_column_family_result.sde |
SchemaDisagreementException |
Cassandra.system_drop_column_family_result.sde |
SchemaDisagreementException |
Cassandra.system_add_keyspace_result.sde |
SchemaDisagreementException |
Cassandra.system_drop_keyspace_result.sde |
SchemaDisagreementException |
Cassandra.system_update_keyspace_result.sde |
SchemaDisagreementException |
Cassandra.system_update_column_family_result.sde |
SchemaDisagreementException |
Cassandra.execute_cql_query_result.sde |
SchemaDisagreementException |
Cassandra.execute_cql3_query_result.sde |
SchemaDisagreementException |
Cassandra.execute_prepared_cql_query_result.sde |
SchemaDisagreementException |
Cassandra.execute_prepared_cql3_query_result.sde |
Modifier and Type | Method and Description |
---|---|
SchemaDisagreementException |
SchemaDisagreementException.deepCopy() |
SchemaDisagreementException |
Cassandra.system_add_column_family_result.getSde() |
SchemaDisagreementException |
Cassandra.system_drop_column_family_result.getSde() |
SchemaDisagreementException |
Cassandra.system_add_keyspace_result.getSde() |
SchemaDisagreementException |
Cassandra.system_drop_keyspace_result.getSde() |
SchemaDisagreementException |
Cassandra.system_update_keyspace_result.getSde() |
SchemaDisagreementException |
Cassandra.system_update_column_family_result.getSde() |
SchemaDisagreementException |
Cassandra.execute_cql_query_result.getSde() |
SchemaDisagreementException |
Cassandra.execute_cql3_query_result.getSde() |
SchemaDisagreementException |
Cassandra.execute_prepared_cql_query_result.getSde() |
SchemaDisagreementException |
Cassandra.execute_prepared_cql3_query_result.getSde() |
Modifier and Type | Method and Description |
---|---|
CqlResult |
CassandraServer.execute_cql_query(java.nio.ByteBuffer query,
Compression compression) |
CqlResult |
Cassandra.Iface.execute_cql_query(java.nio.ByteBuffer query,
Compression compression)
Executes a CQL (Cassandra Query Language) statement and returns a
CqlResult containing the results.
|
CqlResult |
Cassandra.Client.execute_cql_query(java.nio.ByteBuffer query,
Compression compression) |
CqlResult |
CassandraServer.execute_cql3_query(java.nio.ByteBuffer query,
Compression compression,
ConsistencyLevel cLevel) |
CqlResult |
Cassandra.Iface.execute_cql3_query(java.nio.ByteBuffer query,
Compression compression,
ConsistencyLevel consistency) |
CqlResult |
Cassandra.Client.execute_cql3_query(java.nio.ByteBuffer query,
Compression compression,
ConsistencyLevel consistency) |
CqlResult |
CassandraServer.execute_prepared_cql_query(int itemId,
java.util.List<java.nio.ByteBuffer> bindVariables) |
CqlResult |
Cassandra.Iface.execute_prepared_cql_query(int itemId,
java.util.List<java.nio.ByteBuffer> values)
Executes a prepared CQL (Cassandra Query Language) statement by passing an id token and a list of variables
to bind and returns a CqlResult containing the results.
|
CqlResult |
Cassandra.Client.execute_prepared_cql_query(int itemId,
java.util.List<java.nio.ByteBuffer> values) |
CqlResult |
CassandraServer.execute_prepared_cql3_query(int itemId,
java.util.List<java.nio.ByteBuffer> bindVariables,
ConsistencyLevel cLevel) |
CqlResult |
Cassandra.Iface.execute_prepared_cql3_query(int itemId,
java.util.List<java.nio.ByteBuffer> values,
ConsistencyLevel consistency) |
CqlResult |
Cassandra.Client.execute_prepared_cql3_query(int itemId,
java.util.List<java.nio.ByteBuffer> values,
ConsistencyLevel consistency) |
java.lang.String |
Cassandra.AsyncClient.system_add_column_family_call.getResult() |
java.lang.String |
Cassandra.AsyncClient.system_drop_column_family_call.getResult() |
java.lang.String |
Cassandra.AsyncClient.system_add_keyspace_call.getResult() |
java.lang.String |
Cassandra.AsyncClient.system_drop_keyspace_call.getResult() |
java.lang.String |
Cassandra.AsyncClient.system_update_keyspace_call.getResult() |
java.lang.String |
Cassandra.AsyncClient.system_update_column_family_call.getResult() |
CqlResult |
Cassandra.AsyncClient.execute_cql_query_call.getResult() |
CqlResult |
Cassandra.AsyncClient.execute_cql3_query_call.getResult() |
CqlResult |
Cassandra.AsyncClient.execute_prepared_cql_query_call.getResult() |
CqlResult |
Cassandra.AsyncClient.execute_prepared_cql3_query_call.getResult() |
CqlResult |
Cassandra.Client.recv_execute_cql_query() |
CqlResult |
Cassandra.Client.recv_execute_cql3_query() |
CqlResult |
Cassandra.Client.recv_execute_prepared_cql_query() |
CqlResult |
Cassandra.Client.recv_execute_prepared_cql3_query() |
java.lang.String |
Cassandra.Client.recv_system_add_column_family() |
java.lang.String |
Cassandra.Client.recv_system_add_keyspace() |
java.lang.String |
Cassandra.Client.recv_system_drop_column_family() |
java.lang.String |
Cassandra.Client.recv_system_drop_keyspace() |
java.lang.String |
Cassandra.Client.recv_system_update_column_family() |
java.lang.String |
Cassandra.Client.recv_system_update_keyspace() |
java.lang.String |
CassandraServer.system_add_column_family(CfDef cf_def) |
java.lang.String |
Cassandra.Iface.system_add_column_family(CfDef cf_def)
adds a column family.
|
java.lang.String |
Cassandra.Client.system_add_column_family(CfDef cf_def) |
java.lang.String |
CassandraServer.system_add_keyspace(KsDef ks_def) |
java.lang.String |
Cassandra.Iface.system_add_keyspace(KsDef ks_def)
adds a keyspace and any column families that are part of it.
|
java.lang.String |
Cassandra.Client.system_add_keyspace(KsDef ks_def) |
java.lang.String |
CassandraServer.system_drop_column_family(java.lang.String column_family) |
java.lang.String |
Cassandra.Iface.system_drop_column_family(java.lang.String column_family)
drops a column family.
|
java.lang.String |
Cassandra.Client.system_drop_column_family(java.lang.String column_family) |
java.lang.String |
CassandraServer.system_drop_keyspace(java.lang.String keyspace) |
java.lang.String |
Cassandra.Iface.system_drop_keyspace(java.lang.String keyspace)
drops a keyspace and any column families that are part of it.
|
java.lang.String |
Cassandra.Client.system_drop_keyspace(java.lang.String keyspace) |
java.lang.String |
CassandraServer.system_update_column_family(CfDef cf_def) |
java.lang.String |
Cassandra.Iface.system_update_column_family(CfDef cf_def)
updates properties of a column family.
|
java.lang.String |
Cassandra.Client.system_update_column_family(CfDef cf_def) |
java.lang.String |
CassandraServer.system_update_keyspace(KsDef ks_def)
update an existing keyspace, but do not allow column family modifications.
|
java.lang.String |
Cassandra.Iface.system_update_keyspace(KsDef ks_def)
updates properties of a keyspace.
|
java.lang.String |
Cassandra.Client.system_update_keyspace(KsDef ks_def) |
Copyright © 2014 The Apache Software Foundation