Uses of Class
com.netflix.astyanax.connectionpool.exceptions.ConnectionException

Packages that use ConnectionException
com.netflix.astyanax   
com.netflix.astyanax.connectionpool   
com.netflix.astyanax.connectionpool.exceptions   
com.netflix.astyanax.connectionpool.impl   
com.netflix.astyanax.query   
com.netflix.astyanax.recipes   
com.netflix.astyanax.shallows   
com.netflix.astyanax.thrift   
com.netflix.astyanax.util   
 

Uses of ConnectionException in com.netflix.astyanax
 

Methods in com.netflix.astyanax with parameters of type ConnectionException
 boolean RowCallback.failure(ConnectionException e)
          Notification of an error calling cassandra.
 void CassandraOperationTracer.failure(ConnectionException e)
           
 boolean ExceptionCallback.onException(ConnectionException e)
           
 

Methods in com.netflix.astyanax that throw ConnectionException
 String Cluster.addColumnFamily(ColumnFamilyDefinition def)
          Add a column family to an existing keyspace
 String Cluster.addKeyspace(KeyspaceDefinition def)
          Add a new keyspace to the cluster.
 String Cluster.describeClusterName()
          The cluster name is completely arbitrary
 KeyspaceDefinition Keyspace.describeKeyspace()
          Return a complete description of the keyspace and its column families
 KeyspaceDefinition Cluster.describeKeyspace(String ksName)
          Describe a single keyspace
 List<KeyspaceDefinition> Cluster.describeKeyspaces()
          Return details about all keyspaces in the cluster
 String Cluster.describePartitioner()
          Describe the partitioner used by the cluster
 List<TokenRange> Keyspace.describeRing()
          Get a list of all tokens and their endpoints
 Map<String,List<String>> Cluster.describeSchemaVersions()
           
 String Cluster.describeSnitch()
          Describe the snitch name used on the cluster
 String Cluster.dropColumnFamily(String keyspaceName, String columnFamilyName)
          Delete the column family from the keyspace
 String Cluster.dropKeyspace(String keyspaceName)
          Delete a keyspace from the cluster
 OperationResult<R> Execution.execute()
          Block while executing the operations
 Future<OperationResult<R>> Execution.executeAsync()
          Return a future to the operation.
 SerializerPackage Keyspace.getSerializerPackage(String cfName, boolean ignoreErrors)
          Return the serializer package for a specific column family.
 String Cluster.getVersion()
          Return version of cassandra running on the cluster
 OperationResult<Void> Keyspace.testOperation(Operation<?,?> operation)
          This method is used for testing purposes only.
 OperationResult<Void> Keyspace.testOperation(Operation<?,?> operation, RetryPolicy retry)
          This method is used for testing purposes only.
<K,C> OperationResult<Void>
Keyspace.truncateColumnFamily(ColumnFamily<K,C> columnFamily)
          Delete all rows in a column family
 String Cluster.updateColumnFamily(ColumnFamilyDefinition def)
          Update an existing column family
 String Cluster.updateKeyspace(KeyspaceDefinition def)
          Update a new keyspace in the cluster.
 

Uses of ConnectionException in com.netflix.astyanax.connectionpool
 

Methods in com.netflix.astyanax.connectionpool that return ConnectionException
 ConnectionException Connection.getLastException()
          Get the last exception that caused the connection to be closed
 

Methods in com.netflix.astyanax.connectionpool with parameters of type ConnectionException
 void Connection.AsyncOpenCallback.failure(Connection<CL> conn, ConnectionException e)
           
 void HostConnectionPool.markAsDown(ConnectionException reason)
          Shut down the host so no more connections may be created when borrowConnections is called and connections will be terminated when returnConnection is called.
 

Methods in com.netflix.astyanax.connectionpool that throw ConnectionException
 Connection<CL> HostConnectionPool.borrowConnection(int timeout)
          Borrow a connection from the host.
 R Operation.execute(CL client)
          Execute the operation on the client object and return the results
<R> OperationResult<R>
Connection.execute(Operation<CL,R> op)
          Execute an operation on the connection and return a result
<R> OperationResult<R>
ConnectionPool.executeWithFailover(Operation<CL,R> op, RetryPolicy retry)
          Execute an operation with failover within the context of the connection pool.
 int HostConnectionPool.growConnections(int numConnections)
          Create numConnections new connections and add them to the
 void Connection.open()
          Open a new connection
 Connection<CL> HostConnectionPool.openConnection()
          This open is different from borrowConnection in that it actually creates a new connection without waiting for one that may be idle.
 OperationResult<R> ExecuteWithFailover.tryOperation(Operation<CL,R> operation)
           
 

Uses of ConnectionException in com.netflix.astyanax.connectionpool.exceptions
 

Subclasses of ConnectionException in com.netflix.astyanax.connectionpool.exceptions
 class AuthenticationException
           
 class BadConfigurationException
           
 class BadRequestException
           
 class ConnectionAbortedException
           
 class HostDownException
          No more connections may be opened on a host and no timeout was specified.
 class MaxConnsPerHostReachedException
          No more connections may be opened on a host and no timeout was specified.
 class NoAvailableHostsException
           
 class NotFoundException
           
 class OperationException
          Application exception for an operation executed within the context of the connection pool.
 class OperationTimeoutException
           
 class PoolTimeoutException
           
 class SchemaDisagreementException
           
 class ThriftStateException
           
 class ThrottledException
           
 class TimeoutException
           
 class TokenRangeOfflineException
           
 class TransportException
           
 class UnknownException
           
 class WalException
           
 

Methods in com.netflix.astyanax.connectionpool.exceptions that return ConnectionException
 ConnectionException ConnectionException.setAttempt(int attemptCount)
           
 ConnectionException ConnectionException.setHost(Host host)
           
 ConnectionException ConnectionException.setLatency(long latency)
           
 ConnectionException ConnectionException.setLatencyWithPool(long latency)
           
 

Uses of ConnectionException in com.netflix.astyanax.connectionpool.impl
 

Methods in com.netflix.astyanax.connectionpool.impl with parameters of type ConnectionException
 void AbstractExecuteWithFailoverImpl.informException(ConnectionException connectionException)
           
 void SimpleHostConnectionPool.markAsDown(ConnectionException reason)
          Mark the host as down.
 

Methods in com.netflix.astyanax.connectionpool.impl that throw ConnectionException
 Connection<CL> SimpleHostConnectionPool.borrowConnection(int timeout)
          Create a connection as long the max hasn't been reached
 Connection<CL> RoundRobinExecuteWithFailover.borrowConnection(Operation<CL,R> operation)
           
abstract  Connection<CL> AbstractExecuteWithFailoverImpl.borrowConnection(Operation<CL,R> operation)
           
<R> OperationResult<R>
AbstractHostPartitionConnectionPool.executeWithFailover(Operation<CL,R> op, RetryPolicy retry)
           
 OperationResult<R> AbstractExecutionImpl.executeWithRetry(RetryPolicy retry)
           
 int SimpleHostConnectionPool.growConnections(int numConnections)
           
 void AbstractExecuteWithFailoverImpl.informException(ConnectionException connectionException)
           
<R> ExecuteWithFailover<CL,R>
TokenAwareConnectionPoolImpl.newExecuteWithFailover(Operation<CL,R> op)
           
<R> ExecuteWithFailover<CL,R>
RoundRobinConnectionPoolImpl.newExecuteWithFailover(Operation<CL,R> operation)
           
<R> ExecuteWithFailover<CL,R>
BagOfConnectionsConnectionPoolImpl.newExecuteWithFailover(Operation<CL,R> op)
           
protected abstract
<R> ExecuteWithFailover<CL,R>
AbstractHostPartitionConnectionPool.newExecuteWithFailover(Operation<CL,R> op)
          Return a new failover context.
 Connection<CL> SimpleHostConnectionPool.openConnection()
          Open a new connection synchronously
 OperationResult<R> AbstractExecuteWithFailoverImpl.tryOperation(Operation<CL,R> operation)
           
 

Constructors in com.netflix.astyanax.connectionpool.impl that throw ConnectionException
AbstractExecuteWithFailoverImpl(ConnectionPoolConfiguration config, ConnectionPoolMonitor monitor)
           
RoundRobinExecuteWithFailover(ConnectionPoolConfiguration config, ConnectionPoolMonitor monitor, List<HostConnectionPool<CL>> pools, int index)
           
 

Uses of ConnectionException in com.netflix.astyanax.query
 

Methods in com.netflix.astyanax.query that throw ConnectionException
 void AllRowsQuery.executeWithCallback(RowCallback<K,C> callback)
          Execute the operation in a separate thread for each token range and provide the results in a callback.
 

Uses of ConnectionException in com.netflix.astyanax.recipes
 

Methods in com.netflix.astyanax.recipes that throw ConnectionException
 String UniquenessConstraintWithPrefix.isUnique(K key)
          Deprecated.  
 C UniquenessConstraint.isUnique(K key)
          Deprecated.  
 

Uses of ConnectionException in com.netflix.astyanax.shallows
 

Methods in com.netflix.astyanax.shallows with parameters of type ConnectionException
 void EmptyKeyspaceTracer.failure(ConnectionException e)
           
 

Uses of ConnectionException in com.netflix.astyanax.thrift
 

Methods in com.netflix.astyanax.thrift that return ConnectionException
static ConnectionException ThriftConverter.ToConnectionPoolException(Exception e)
          Convert from Thrift exceptions to an internal ConnectionPoolException
 

Methods in com.netflix.astyanax.thrift that throw ConnectionException
 String ThriftClusterImpl.addColumnFamily(ColumnFamilyDefinition def)
           
 String ThriftClusterImpl.addKeyspace(KeyspaceDefinition def)
           
 String ThriftClusterImpl.describeClusterName()
           
 KeyspaceDefinition ThriftKeyspaceImpl.describeKeyspace()
           
 KeyspaceDefinition ThriftClusterImpl.describeKeyspace(String ksName)
           
 List<KeyspaceDefinition> ThriftClusterImpl.describeKeyspaces()
           
 String ThriftClusterImpl.describePartitioner()
           
 List<TokenRange> ThriftKeyspaceImpl.describeRing()
           
 Map<String,List<String>> ThriftClusterImpl.describeSchemaVersions()
           
 String ThriftClusterImpl.describeSnitch()
           
 String ThriftClusterImpl.dropColumnFamily(String keyspaceName, String columnFamilyName)
           
 String ThriftClusterImpl.dropKeyspace(String keyspaceName)
           
 R AbstractOperationImpl.execute(org.apache.cassandra.thrift.Cassandra.Client client)
           
 SerializerPackage ThriftKeyspaceImpl.getSerializerPackage(String cfName, boolean ignoreErrors)
           
 String ThriftClusterImpl.getVersion()
          Get the version from the cluster
 OperationResult<Void> ThriftKeyspaceImpl.testOperation(Operation<?,?> operation)
           
 OperationResult<Void> ThriftKeyspaceImpl.testOperation(Operation<?,?> operation, RetryPolicy retry)
           
<K,C> OperationResult<Void>
ThriftKeyspaceImpl.truncateColumnFamily(ColumnFamily<K,C> columnFamily)
           
 String ThriftClusterImpl.updateColumnFamily(ColumnFamilyDefinition def)
           
 String ThriftClusterImpl.updateKeyspace(KeyspaceDefinition def)
           
 

Uses of ConnectionException in com.netflix.astyanax.util
 

Methods in com.netflix.astyanax.util that throw ConnectionException
 void RecordWriter.start()
           
 void ColumnarRecordWriter.start()
           
 

Constructors in com.netflix.astyanax.util that throw ConnectionException
JsonRowsWriter(PrintWriter out, SerializerPackage serializers)
           
 



Copyright © 2012. All Rights Reserved.