|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object me.prettyprint.cassandra.service.AbstractCluster me.prettyprint.cassandra.service.ThriftCluster
public class ThriftCluster
Field Summary |
---|
Fields inherited from class me.prettyprint.cassandra.service.AbstractCluster |
---|
connectionManager, xtrans |
Constructor Summary | |
---|---|
ThriftCluster(String clusterName,
CassandraHostConfigurator cassandraHostConfigurator)
|
|
ThriftCluster(String clusterName,
CassandraHostConfigurator cassandraHostConfigurator,
Map<String,String> credentials)
|
Method Summary | |
---|---|
String |
addColumnFamily(ColumnFamilyDefinition cfdef)
Add a column family and returns without waiting for schema cluster agreement. |
String |
addColumnFamily(ColumnFamilyDefinition cfdef,
boolean blockUntilComplete)
Add a column family and wait for schema cluster agreement if blockUntilComplete
is set to true. |
String |
addKeyspace(KeyspaceDefinition ksdef)
Add a keyspace and does not wait for schema agreement. |
String |
addKeyspace(KeyspaceDefinition ksdef,
boolean blockUntilComplete)
Add a keyspace and wait for schema cluster agreement if blockUntilComplete
is set to true. |
List<org.apache.cassandra.thrift.TokenRange> |
describeRing(String keyspace)
|
Map<String,List<String>> |
describeSchemaVersions()
|
String |
updateColumnFamily(ColumnFamilyDefinition cfdef)
Updates a column family and does not wait for schema agreement. |
String |
updateColumnFamily(ColumnFamilyDefinition cfdef,
boolean blockUntilComplete)
Update a column family and wait for schema cluster agreement if blockUntilComplete
is set to true. |
String |
updateKeyspace(KeyspaceDefinition ksdef)
Updates the Keyspace from the cluster without waiting for schema agreement. |
String |
updateKeyspace(KeyspaceDefinition ksdef,
boolean blockUntilComplete)
Updates the Keyspace and wait for schema cluster agreement if blockUntilComplete
is set to true. |
Methods inherited from class me.prettyprint.cassandra.service.AbstractCluster |
---|
addHost, describeClusterName, describeKeyspace, describeKeyspaces, describePartitioner, describeThriftVersion, dropColumnFamily, dropColumnFamily, dropKeyspace, dropKeyspace, getClusterName, getConnectionManager, getCredentials, getKnownPoolHosts, getName, truncate, waitForSchemaAgreement |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface me.prettyprint.hector.api.Cluster |
---|
addHost, describeClusterName, describeKeyspace, describeKeyspaces, describePartitioner, describeThriftVersion, dropColumnFamily, dropColumnFamily, dropKeyspace, dropKeyspace, getClusterName, getConnectionManager, getCredentials, getKnownPoolHosts, getName, truncate |
Constructor Detail |
---|
public ThriftCluster(String clusterName, CassandraHostConfigurator cassandraHostConfigurator)
public ThriftCluster(String clusterName, CassandraHostConfigurator cassandraHostConfigurator, Map<String,String> credentials)
Method Detail |
---|
public List<org.apache.cassandra.thrift.TokenRange> describeRing(String keyspace) throws HectorException
describeRing
in interface Cluster
HectorException
public Map<String,List<String>> describeSchemaVersions() throws HectorException
describeSchemaVersions
in interface Cluster
HectorException
public String updateKeyspace(KeyspaceDefinition ksdef) throws HectorException
Cluster
updateKeyspace
in interface Cluster
HectorException
public String updateKeyspace(KeyspaceDefinition ksdef, boolean blockUntilComplete) throws HectorException
Cluster
blockUntilComplete
is set to true. Otherwise it behaves exactly like: Cluster.updateKeyspace(KeyspaceDefinition)
updateKeyspace
in interface Cluster
HectorException
public String addColumnFamily(ColumnFamilyDefinition cfdef) throws HectorException
Cluster
addColumnFamily
in interface Cluster
HectorException
public String addColumnFamily(ColumnFamilyDefinition cfdef, boolean blockUntilComplete) throws HectorException
Cluster
blockUntilComplete
is set to true. Otherwise it behaves exactly like: Cluster.addColumnFamily(ColumnFamilyDefinition)
addColumnFamily
in interface Cluster
HectorException
public String updateColumnFamily(ColumnFamilyDefinition cfdef) throws HectorException
Cluster
updateColumnFamily
in interface Cluster
HectorException
public String updateColumnFamily(ColumnFamilyDefinition cfdef, boolean blockUntilComplete) throws HectorException
Cluster
blockUntilComplete
is set to true. Otherwise it behaves exactly like: #updateColumnFamily(String)
updateColumnFamily
in interface Cluster
HectorException
public String addKeyspace(KeyspaceDefinition ksdef) throws HectorException
Cluster
addKeyspace
in interface Cluster
HectorException
public String addKeyspace(KeyspaceDefinition ksdef, boolean blockUntilComplete) throws HectorException
Cluster
blockUntilComplete
is set to true. Otherwise it behaves exactly like: #addKeyspace(String)
addKeyspace
in interface Cluster
HectorException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |