Package | Description |
---|---|
org.apache.cassandra.cli | |
org.apache.cassandra.hadoop | |
org.apache.cassandra.hadoop.pig | |
org.apache.cassandra.thrift |
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.String,CfDef> |
CliClient.loadCql3Defs(Cassandra.Client thriftClient,
KsDef thriftKs) |
static java.util.Map<java.lang.String,CfDef> |
CliClient.loadCql3DefsUnchecked(Cassandra.Client thriftClient,
KsDef thriftKs) |
Constructor and Description |
---|
CliClient(CliSessionState cliSessionState,
Cassandra.Client thriftClient) |
Modifier and Type | Field and Description |
---|---|
protected Cassandra.Client |
AbstractColumnFamilyRecordWriter.AbstractRangeClient.client |
Modifier and Type | Method and Description |
---|---|
static Cassandra.Client |
AbstractColumnFamilyInputFormat.createAuthenticatedClient(java.lang.String location,
int port,
org.apache.hadoop.conf.Configuration conf) |
static Cassandra.Client |
AbstractColumnFamilyOutputFormat.createAuthenticatedClient(java.lang.String host,
int port,
org.apache.hadoop.conf.Configuration conf)
Connects to the given server:port and returns a client based on the given socket that points to the configured
keyspace, and is logged in with the configured credentials.
|
static Cassandra.Client |
ConfigHelper.createConnection(org.apache.hadoop.conf.Configuration conf,
java.lang.String host,
java.lang.Integer port) |
static Cassandra.Client |
ConfigHelper.getClientFromInputAddressList(org.apache.hadoop.conf.Configuration conf) |
static Cassandra.Client |
ConfigHelper.getClientFromOutputAddressList(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected CFDefinition |
AbstractCassandraStorage.getCfDefinition(java.lang.String ks,
java.lang.String cf,
Cassandra.Client client)
get CFDefinition of a column family
|
protected AbstractCassandraStorage.CfInfo |
AbstractCassandraStorage.getCfInfo(Cassandra.Client client)
return the CfInfo 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
|
protected java.util.List<ColumnDef> |
CqlStorage.getKeysMeta(Cassandra.Client client)
get keys meta data
|
Modifier and Type | Method and Description |
---|---|
Cassandra.Client |
Cassandra.Client.Factory.getClient(org.apache.thrift.protocol.TProtocol prot) |
Cassandra.Client |
Cassandra.Client.Factory.getClient(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot) |
Copyright © 2014 The Apache Software Foundation