Overview  Package  Class  Use  Tree  Deprecated   Index  Help 
 PREV   NEXT FRAMES    NO FRAMES    
A B C D E F G H I J K L M N O P Q R S T U V W X

A

absoluteFromFraction(double, long) - Static method in class org.apache.cassandra.utils.FBUtilities
 
AbstractBounds - Class in org.apache.cassandra.dht
 
AbstractBounds(Token, Token, IPartitioner) - Constructor for class org.apache.cassandra.dht.AbstractBounds
 
AbstractCache - Class in org.apache.cassandra.cache
 
AbstractCache() - Constructor for class org.apache.cassandra.cache.AbstractCache
 
AbstractColumnIterator - Class in org.apache.cassandra.db.filter
 
AbstractColumnIterator() - Constructor for class org.apache.cassandra.db.filter.AbstractColumnIterator
 
AbstractCommitLogExecutorService - Class in org.apache.cassandra.db.commitlog
 
AbstractCommitLogExecutorService() - Constructor for class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
AbstractEndpointSnitch - Class in org.apache.cassandra.locator
An endpoint snitch tells Cassandra information about network topology that it can use to route requests more efficiently (with "sortByProximity").
AbstractEndpointSnitch() - Constructor for class org.apache.cassandra.locator.AbstractEndpointSnitch
 
AbstractReplicationStrategy - Class in org.apache.cassandra.locator
This class contains a helper method that will be used by all abstraction that implement the IReplicaPlacementStrategy interface.
AbstractStatsDeque - Class in org.apache.cassandra.utils
 
AbstractStatsDeque() - Constructor for class org.apache.cassandra.utils.AbstractStatsDeque
 
AbstractType - Class in org.apache.cassandra.db.marshal
Specifies a Comparator for a specific type of byte[].
AbstractType() - Constructor for class org.apache.cassandra.db.marshal.AbstractType
 
ACCESS_FILENAME_PROPERTY - Static variable in class org.apache.cassandra.auth.SimpleAuthenticator
 
add(RowMutation, Object) - Method in class org.apache.cassandra.db.commitlog.CommitLog
 
add(CommitLog.LogRecordAdder) - Method in interface org.apache.cassandra.db.commitlog.ICommitLogExecutorService
submits the adder for execution and blocks for it to be synced, if necessary
add(ColumnFamily) - Method in class org.apache.cassandra.db.RowMutation
 
add(QueryPath, byte[], long) - Method in class org.apache.cassandra.db.RowMutation
 
add(String, int) - Method in class org.apache.cassandra.db.Table.TableMetadata
 
add(String, int, String) - Method in class org.apache.cassandra.db.Table.TableMetadata
 
add(Iterable<SSTableReader>) - Method in class org.apache.cassandra.io.SSTableTracker
 
add(CompactionIterator.CompactedRow) - Method in interface org.apache.cassandra.service.AntiEntropyService.IValidator
 
add(CompactionIterator.CompactedRow) - Method in class org.apache.cassandra.service.AntiEntropyService.NoopValidator
Does nothing.
add(CompactionIterator.CompactedRow) - Method in class org.apache.cassandra.service.AntiEntropyService.Validator
Called (in order) for every row present in the CF.
add(double) - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
add(String) - Method in class org.apache.cassandra.utils.BloomFilter
 
add(byte[]) - Method in class org.apache.cassandra.utils.BloomFilter
 
add(double) - Method in class org.apache.cassandra.utils.BoundedStatsDeque
 
add(long) - Method in class org.apache.cassandra.utils.EstimatedHistogram
 
add(String) - Method in class org.apache.cassandra.utils.Filter
 
addAll(ColumnFamily) - Method in class org.apache.cassandra.db.ColumnFamily
 
addAll(Iterator<MerkleTree.RowHash>) - Method in class org.apache.cassandra.utils.MerkleTree.TreeRange
 
addBootstrapSource(InetAddress, String) - Method in class org.apache.cassandra.service.StorageService
 
addBootstrapToken(Token, InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
addCallback(IAsyncCallback, String) - Method in class org.apache.cassandra.net.MessagingService
 
addColumn(IColumn) - Method in class org.apache.cassandra.db.Column
 
addColumn(QueryPath, byte[], long) - Method in class org.apache.cassandra.db.ColumnFamily
 
addColumn(QueryPath, byte[], long, boolean) - Method in class org.apache.cassandra.db.ColumnFamily
In most places the CF must be part of a QueryPath but here it is ignored.
addColumn(IColumn) - Method in class org.apache.cassandra.db.ColumnFamily
 
addColumn(IColumn) - Method in interface org.apache.cassandra.db.IColumn
 
addColumn(IColumn) - Method in interface org.apache.cassandra.db.IColumnContainer
 
addColumn(IColumn) - Method in class org.apache.cassandra.db.SuperColumn
 
addFilesToStream(PendingFile[]) - Method in class org.apache.cassandra.streaming.StreamOutManager
 
addHash(MerkleTree.RowHash) - Method in class org.apache.cassandra.utils.MerkleTree.TreeRange
 
addLeavingEndPoint(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
addLocalApplicationState(String, ApplicationState) - Method in class org.apache.cassandra.gms.Gossiper
 
addMessageSink(IMessageSink) - Static method in class org.apache.cassandra.net.sink.SinkManager
 
addMicro(long) - Method in class org.apache.cassandra.utils.LatencyTracker
 
addNano(long) - Method in class org.apache.cassandra.utils.LatencyTracker
takes nanoseconds
address - Variable in class org.apache.cassandra.dht.BootStrapper
 
addSSTable(SSTableReader) - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
addToCompactedRowStats(Long) - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
AE_SERVICE_STAGE - Static variable in class org.apache.cassandra.concurrent.StageManager
 
afterExecute(Runnable, Throwable) - Method in class org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor
 
AIOExecutorService - Class in org.apache.cassandra.concurrent
 
AIOExecutorService(int, int, long, TimeUnit, BlockingQueue<Runnable>, ThreadFactory) - Constructor for class org.apache.cassandra.concurrent.AIOExecutorService
 
all() - Static method in class org.apache.cassandra.db.ColumnFamilyStore
 
all() - Static method in class org.apache.cassandra.db.Table
 
allIndexPositions() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
AllowAllAuthenticator - Class in org.apache.cassandra.auth
 
AllowAllAuthenticator() - Constructor for class org.apache.cassandra.auth.AllowAllAuthenticator
 
alwaysMatchingBloomFilter() - Static method in class org.apache.cassandra.utils.BloomFilter
 
AntiEntropyService - Class in org.apache.cassandra.service
AntiEntropyService encapsulates "validating" (hashing) individual column families, exchanging MerkleTrees with remote nodes via a TreeRequest/Response conversation, and then triggering repairs for disagreeing ranges.
AntiEntropyService() - Constructor for class org.apache.cassandra.service.AntiEntropyService
Protected constructor.
AntiEntropyService.Differencer - Class in org.apache.cassandra.service
Compares two trees, and launches repairs for disagreeing ranges.
AntiEntropyService.Differencer(AntiEntropyService.CFPair, InetAddress, InetAddress, MerkleTree, MerkleTree) - Constructor for class org.apache.cassandra.service.AntiEntropyService.Differencer
 
AntiEntropyService.IValidator - Interface in org.apache.cassandra.service
A Strategy to handle building and validating a merkle tree for a column family.
AntiEntropyService.NoopValidator - Class in org.apache.cassandra.service
The IValidator to be used before a cluster has stabilized, or when repairs are disabled.
AntiEntropyService.NoopValidator() - Constructor for class org.apache.cassandra.service.AntiEntropyService.NoopValidator
 
AntiEntropyService.TreeRequestVerbHandler - Class in org.apache.cassandra.service
Handler for requests from remote nodes to generate a valid tree.
AntiEntropyService.TreeRequestVerbHandler() - Constructor for class org.apache.cassandra.service.AntiEntropyService.TreeRequestVerbHandler
 
AntiEntropyService.TreeResponseVerbHandler - Class in org.apache.cassandra.service
Handler for responses from remote nodes which contain a valid tree.
AntiEntropyService.TreeResponseVerbHandler() - Constructor for class org.apache.cassandra.service.AntiEntropyService.TreeResponseVerbHandler
 
AntiEntropyService.Validator - Class in org.apache.cassandra.service
The IValidator to be used in normal operation.
append(DecoratedKey, DataOutputBuffer) - Method in class org.apache.cassandra.io.SSTableWriter
 
append(DecoratedKey, byte[]) - Method in class org.apache.cassandra.io.SSTableWriter
 
ApplicationState - Class in org.apache.cassandra.gms
This abstraction represents the state associated with a particular node which an application wants to make available to the rest of the nodes in the cluster.
ApplicationState(String) - Constructor for class org.apache.cassandra.gms.ApplicationState
Wraps the specified state into a ApplicationState instance.
apply() - Method in class org.apache.cassandra.db.RowMutation
 
apply(RowMutation, Object, boolean) - Method in class org.apache.cassandra.db.Table
This method adds the row to the Commit Log associated with this table.
AsciiType - Class in org.apache.cassandra.db.marshal
 
AsciiType() - Constructor for class org.apache.cassandra.db.marshal.AsciiType
 
atomicSetMax(AtomicInteger, int) - Static method in class org.apache.cassandra.utils.FBUtilities
 
atomicSetMax(AtomicLong, long) - Static method in class org.apache.cassandra.utils.FBUtilities
 
avronateSubColumns(Collection<IColumn>) - Method in class org.apache.cassandra.avro.CassandraServer
 
AvroValidation - Class in org.apache.cassandra.avro
The Avro analogue to org.apache.cassandra.service.ThriftValidation
AvroValidation() - Constructor for class org.apache.cassandra.avro.AvroValidation
 
await() - Method in class org.apache.cassandra.utils.SimpleCondition
 
await(long, TimeUnit) - Method in class org.apache.cassandra.utils.SimpleCondition
 
awaitNanos(long) - Method in class org.apache.cassandra.utils.SimpleCondition
 
awaitTermination(long, TimeUnit) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
awaitTermination(long, TimeUnit) - Method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
awaitUninterruptibly() - Method in class org.apache.cassandra.utils.SimpleCondition
 
awaitUntil(Date) - Method in class org.apache.cassandra.utils.SimpleCondition
 

B

batch_insert(Utf8, Utf8, Map<Utf8, GenericArray<ColumnOrSuperColumn>>, ConsistencyLevel) - Method in class org.apache.cassandra.avro.CassandraServer
 
batch_insert(String, String, Map<String, List<ColumnOrSuperColumn>>, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
batch_mutate(String, Map<String, Map<String, List<Mutation>>>, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
BatchCommitLogExecutorServiceMBean - Interface in org.apache.cassandra.db.commitlog
 
bf - Variable in class org.apache.cassandra.io.SSTable
 
BigIntegerToken - Class in org.apache.cassandra.dht
 
BigIntegerToken(BigInteger) - Constructor for class org.apache.cassandra.dht.BigIntegerToken
 
BigIntegerToken(String) - Constructor for class org.apache.cassandra.dht.BigIntegerToken
 
BinaryMemtable - Class in org.apache.cassandra.db
 
BinaryMemtable(ColumnFamilyStore) - Constructor for class org.apache.cassandra.db.BinaryMemtable
 
BinaryVerbHandler - Class in org.apache.cassandra.db
 
BinaryVerbHandler() - Constructor for class org.apache.cassandra.db.BinaryVerbHandler
 
BitSetSerializer - Class in org.apache.cassandra.utils
 
BitSetSerializer() - Constructor for class org.apache.cassandra.utils.BitSetSerializer
 
BloomFilter - Class in org.apache.cassandra.utils
 
BootStrapper - Class in org.apache.cassandra.dht
 
BootStrapper(InetAddress, Token, TokenMetadata) - Constructor for class org.apache.cassandra.dht.BootStrapper
 
BootStrapper.BootstrapTokenVerbHandler - Class in org.apache.cassandra.dht
 
BootStrapper.BootstrapTokenVerbHandler() - Constructor for class org.apache.cassandra.dht.BootStrapper.BootstrapTokenVerbHandler
 
BoundedStatsDeque - Class in org.apache.cassandra.utils
not threadsafe.
BoundedStatsDeque(int) - Constructor for class org.apache.cassandra.utils.BoundedStatsDeque
 
Bounds - Class in org.apache.cassandra.dht
 
Bounds(Token, Token) - Constructor for class org.apache.cassandra.dht.Bounds
 
buffer - Variable in class org.apache.cassandra.io.CompactionIterator.CompactedRow
 
BufferedRandomAccessFile - Class in org.apache.cassandra.io.util
A BufferedRandomAccessFile is like a RandomAccessFile, but it uses a private buffer so that most operations do not require a disk access.
BufferedRandomAccessFile(File, String) - Constructor for class org.apache.cassandra.io.util.BufferedRandomAccessFile
Open a new BufferedRandomAccessFile on file in mode mode, which should be "r" for reading only, or "rw" for reading and writing.
BufferedRandomAccessFile(File, String, int) - Constructor for class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
BufferedRandomAccessFile(String, String) - Constructor for class org.apache.cassandra.io.util.BufferedRandomAccessFile
Open a new BufferedRandomAccessFile on the file named name in mode mode, which should be "r" for reading only, or "rw" for reading and writing.
BufferedRandomAccessFile(String, String, int) - Constructor for class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
BuffSz_ - Static variable in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
bufIn_ - Variable in class org.apache.cassandra.db.ReadVerbHandler.ReadContext
 
bufOut_ - Variable in class org.apache.cassandra.db.ReadVerbHandler.ReadContext
 
BYTE_MASK - Static variable in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
byteArrayToInt(byte[]) - Static method in class org.apache.cassandra.utils.FBUtilities
 
byteArrayToInt(byte[], int) - Static method in class org.apache.cassandra.utils.FBUtilities
 
bytesOnDisk() - Method in class org.apache.cassandra.io.SSTable
 
bytesPastMark() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
bytesPastMark() - Method in interface org.apache.cassandra.io.util.FileDataInput
 
bytesPastMark() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
bytesToHex(byte...) - Static method in class org.apache.cassandra.utils.FBUtilities
 
BytesToken - Class in org.apache.cassandra.dht
 
BytesToken(byte...) - Constructor for class org.apache.cassandra.dht.BytesToken
 
BytesType - Class in org.apache.cassandra.db.marshal
 
BytesType() - Constructor for class org.apache.cassandra.db.marshal.BytesType
 

C

calculatePendingRanges(AbstractReplicationStrategy, String) - Static method in class org.apache.cassandra.service.StorageService
 
call() - Method in class org.apache.cassandra.service.AntiEntropyService.Validator
Called after the validation lifecycle to trigger additional action with the now valid tree.
callMe(K, V) - Method in interface org.apache.cassandra.cache.ICacheExpungeHook
 
CassandraDaemon - Class in org.apache.cassandra.avro
The Avro analogue to org.apache.cassandra.service.CassandraDaemon.
CassandraDaemon() - Constructor for class org.apache.cassandra.avro.CassandraDaemon
 
CassandraDaemon - Class in org.apache.cassandra.thrift
This class supports two methods for creating a Cassandra node daemon, invoking the class's main method, and using the jsvc wrapper from commons-daemon, (for more information on using this class with the jsvc wrapper, see the Commons Daemon documentation).
CassandraDaemon() - Constructor for class org.apache.cassandra.thrift.CassandraDaemon
 
CassandraServer - Class in org.apache.cassandra.avro
 
CassandraServer() - Constructor for class org.apache.cassandra.avro.CassandraServer
 
CassandraServer - Class in org.apache.cassandra.thrift
 
CassandraServer() - Constructor for class org.apache.cassandra.thrift.CassandraServer
 
cf - Variable in class org.apache.cassandra.db.Row
 
cf - Variable in class org.apache.cassandra.service.AntiEntropyService.Differencer
 
cf - Variable in class org.apache.cassandra.service.AntiEntropyService.Validator
 
CFMetaData - Class in org.apache.cassandra.config
 
cfMetaData - Variable in class org.apache.cassandra.config.KSMetaData
 
cfName - Variable in class org.apache.cassandra.config.CFMetaData
 
CHAR_MASK - Static variable in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
checkAllColumnFamilies() - Method in class org.apache.cassandra.db.CompactionManager
 
checkLoginDone() - Method in class org.apache.cassandra.thrift.CassandraServer
 
CHUNK_SIZE - Static variable in class org.apache.cassandra.net.FileStreamTask
 
cleanup() - Method in class org.apache.cassandra.io.SSTableDeletingReference
 
clear() - Method in class org.apache.cassandra.cache.InstrumentedCache
 
clear() - Method in class org.apache.cassandra.db.ColumnFamily
 
clear() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
clear() - Method in class org.apache.cassandra.utils.BloomFilter
 
clear() - Method in class org.apache.cassandra.utils.BoundedStatsDeque
 
clearGlobalSnapshot() - Method in class org.apache.cassandra.tools.ClusterCmd
Remove all the existing snapshots from all (live) nodes in the cluster
clearSinks() - Static method in class org.apache.cassandra.net.sink.SinkManager
 
clearSnapshot() - Method in class org.apache.cassandra.db.Table
Clear all the snapshots for a given table.
clearSnapshot() - Method in class org.apache.cassandra.service.StorageService
Remove all the existing snapshots.
clearSnapshot() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Remove all the existing snapshots.
clearSnapshot() - Method in class org.apache.cassandra.tools.NodeProbe
Remove all the existing snapshots.
clearUnsafe() - Method in class org.apache.cassandra.io.SSTableTracker
 
clearUnsafe() - Method in class org.apache.cassandra.locator.TokenMetadata
used by tests
CliClient - Class in org.apache.cassandra.cli
 
CliClient(CliSessionState, Cassandra.Client) - Constructor for class org.apache.cassandra.cli.CliClient
 
CliCompiler - Class in org.apache.cassandra.cli
 
CliCompiler() - Constructor for class org.apache.cassandra.cli.CliCompiler
 
CliCompiler.ANTLRNoCaseStringStream - Class in org.apache.cassandra.cli
 
CliCompiler.ANTLRNoCaseStringStream(String) - Constructor for class org.apache.cassandra.cli.CliCompiler.ANTLRNoCaseStringStream
 
CliCompleter - Class in org.apache.cassandra.cli
 
CliCompleter() - Constructor for class org.apache.cassandra.cli.CliCompleter
 
CliMain - Class in org.apache.cassandra.cli
Cassandra Command Line Interface (CLI) Main
CliMain() - Constructor for class org.apache.cassandra.cli.CliMain
 
CliOptions - Class in org.apache.cassandra.cli
Used to process, and act upon the arguments passed to the CLI.
CliOptions() - Constructor for class org.apache.cassandra.cli.CliOptions
 
CliSessionState - Class in org.apache.cassandra.cli
Used to hold the state for the CLI.
CliSessionState() - Constructor for class org.apache.cassandra.cli.CliSessionState
 
CliUtils - Class in org.apache.cassandra.cli
 
CliUtils() - Constructor for class org.apache.cassandra.cli.CliUtils
 
clone() - Method in class org.apache.cassandra.net.MessagingService
 
cloneAfterAllLeft() - Method in class org.apache.cassandra.locator.TokenMetadata
Create a copy of TokenMetadata with tokenToEndPointMap reflecting situation after all current leave operations have finished.
cloneMe() - Method in class org.apache.cassandra.db.ColumnFamily
 
cloneMe() - Method in class org.apache.cassandra.db.SuperColumn
 
cloneMeShallow() - Method in class org.apache.cassandra.db.ColumnFamily
 
cloneMeShallow() - Method in class org.apache.cassandra.db.SuperColumn
 
cloneOnlyTokenMap() - Method in class org.apache.cassandra.locator.TokenMetadata
Create a copy of TokenMetadata with only tokenToEndPointMap.
close() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
close() - Method in class org.apache.cassandra.db.filter.AbstractColumnIterator
 
close() - Method in interface org.apache.cassandra.db.filter.ColumnIterator
clean up any open resources
close() - Method in class org.apache.cassandra.db.filter.SimpleAbstractColumnIterator
 
close() - Method in class org.apache.cassandra.hadoop.ColumnFamilyRecordReader
 
close() - Method in class org.apache.cassandra.io.CompactionIterator
 
close() - Method in class org.apache.cassandra.io.SSTableScanner
 
close() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
CloseableIterator<T> - Interface in org.apache.cassandra.utils
 
closeAndOpenReader() - Method in class org.apache.cassandra.io.SSTableWriter
Renames temporary SSTable files to valid data, index, and bloom filter files
closeSocket() - Method in class org.apache.cassandra.net.OutboundTcpConnection
 
ClusterCmd - Class in org.apache.cassandra.tools
JMX cluster wide operations for Cassandra.
ClusterCmd(String, int) - Constructor for class org.apache.cassandra.tools.ClusterCmd
Creates a ClusterProbe using the specified JMX host and port.
ClusterCmd(String) - Constructor for class org.apache.cassandra.tools.ClusterCmd
Creates a ClusterProbe using the specified JMX host and default port.
CMD_TYPE_GET_SLICE - Static variable in class org.apache.cassandra.db.ReadCommand
 
CMD_TYPE_GET_SLICE_BY_NAMES - Static variable in class org.apache.cassandra.db.ReadCommand
 
CollatingOrderPreservingPartitioner - Class in org.apache.cassandra.dht
 
CollatingOrderPreservingPartitioner() - Constructor for class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
collectCollatedColumns(ColumnFamily, Iterator<IColumn>, int) - Method in class org.apache.cassandra.db.filter.QueryFilter
 
collectReducedColumns(IColumnContainer, Iterator<IColumn>, int) - Method in class org.apache.cassandra.db.filter.NamesQueryFilter
 
collectReducedColumns(IColumnContainer, Iterator<IColumn>, int) - Method in class org.apache.cassandra.db.filter.QueryFilter
collects columns from reducedColumns into returnCF.
collectReducedColumns(IColumnContainer, Iterator<IColumn>, int) - Method in class org.apache.cassandra.db.filter.SliceQueryFilter
 
Column - Class in org.apache.cassandra.db
Column is immutable, which prevents all kinds of confusion in a multithreaded environment.
Column(byte[], byte[], long) - Constructor for class org.apache.cassandra.db.Column
 
Column(byte[], byte[], long, boolean) - Constructor for class org.apache.cassandra.db.Column
 
column(byte[]) - Static method in class org.apache.cassandra.db.filter.QueryPath
 
column_family - Variable in class org.apache.cassandra.db.RangeSliceCommand
 
ColumnFamily - Class in org.apache.cassandra.db
 
ColumnFamily(String, String, AbstractType, AbstractType) - Constructor for class org.apache.cassandra.db.ColumnFamily
 
columnFamily_ - Variable in class org.apache.cassandra.db.ColumnFamilyStore
 
ColumnFamilyInputFormat - Class in org.apache.cassandra.hadoop
Hadoop InputFormat allowing map/reduce against Cassandra rows within one ColumnFamily.
ColumnFamilyInputFormat() - Constructor for class org.apache.cassandra.hadoop.ColumnFamilyInputFormat
 
columnFamilyName - Variable in class org.apache.cassandra.db.filter.QueryPath
 
columnFamilyName - Variable in class org.apache.cassandra.io.SSTable
 
columnFamilyNames() - Method in class org.apache.cassandra.db.RowMutation
 
ColumnFamilyNotDefinedException - Exception in org.apache.cassandra.db
 
ColumnFamilyNotDefinedException(String) - Constructor for exception org.apache.cassandra.db.ColumnFamilyNotDefinedException
 
ColumnFamilyRecordReader - Class in org.apache.cassandra.hadoop
 
ColumnFamilyRecordReader() - Constructor for class org.apache.cassandra.hadoop.ColumnFamilyRecordReader
 
ColumnFamilySerializer - Class in org.apache.cassandra.db
 
ColumnFamilySerializer() - Constructor for class org.apache.cassandra.db.ColumnFamilySerializer
 
ColumnFamilySplit - Class in org.apache.cassandra.hadoop
 
ColumnFamilySplit(String, String, String[]) - Constructor for class org.apache.cassandra.hadoop.ColumnFamilySplit
 
ColumnFamilySplit() - Constructor for class org.apache.cassandra.hadoop.ColumnFamilySplit
 
ColumnFamilyStore - Class in org.apache.cassandra.db
 
ColumnFamilyStoreMBean - Interface in org.apache.cassandra.db
The MBean interface for ColumnFamilyStore
ColumnIndexer - Class in org.apache.cassandra.db
Help to create an index for a column family based on size of columns
ColumnIndexer() - Constructor for class org.apache.cassandra.db.ColumnIndexer
 
ColumnIterator - Interface in org.apache.cassandra.db.filter
 
columnName - Variable in class org.apache.cassandra.db.filter.QueryPath
 
columnNames - Variable in class org.apache.cassandra.db.SliceByNamesReadCommand
 
columns - Variable in class org.apache.cassandra.db.filter.NamesQueryFilter
 
columns - Variable in class org.apache.cassandra.db.filter.SSTableNamesIterator
 
ColumnSerializer - Class in org.apache.cassandra.db
 
ColumnSerializer() - Constructor for class org.apache.cassandra.db.ColumnSerializer
 
columnType - Variable in class org.apache.cassandra.config.CFMetaData
 
commandType - Variable in class org.apache.cassandra.db.ReadCommand
 
comment - Variable in class org.apache.cassandra.config.CFMetaData
 
CommitLog - Class in org.apache.cassandra.db.commitlog
 
CommitLogSegment - Class in org.apache.cassandra.db.commitlog
 
CommitLogSegment(int) - Constructor for class org.apache.cassandra.db.commitlog.CommitLogSegment
 
CommitLogSegment.CommitLogContext - Class in org.apache.cassandra.db.commitlog
 
CommitLogSegment.CommitLogContext(long) - Constructor for class org.apache.cassandra.db.commitlog.CommitLogSegment.CommitLogContext
 
compact(Token) - Method in class org.apache.cassandra.utils.MerkleTree
Compacts the smallest subranges evenly split by the given token into a single range.
compactedFilename(String) - Static method in class org.apache.cassandra.io.SSTable
 
compactedFilename() - Method in class org.apache.cassandra.io.SSTable
 
CompactEndPointSerializationHelper - Class in org.apache.cassandra.net
 
CompactEndPointSerializationHelper() - Constructor for class org.apache.cassandra.net.CompactEndPointSerializationHelper
 
CompactionIterator - Class in org.apache.cassandra.io
 
CompactionIterator(Iterable<SSTableReader>, int, boolean) - Constructor for class org.apache.cassandra.io.CompactionIterator
 
CompactionIterator(Iterator, int, boolean) - Constructor for class org.apache.cassandra.io.CompactionIterator
 
CompactionIterator.CompactedRow - Class in org.apache.cassandra.io
 
CompactionIterator.CompactedRow(DecoratedKey, DataOutputBuffer) - Constructor for class org.apache.cassandra.io.CompactionIterator.CompactedRow
 
CompactionManager - Class in org.apache.cassandra.db
 
CompactionManager() - Constructor for class org.apache.cassandra.db.CompactionManager
 
CompactionManagerMBean - Interface in org.apache.cassandra.db
 
comparator - Variable in class org.apache.cassandra.config.CFMetaData
 
comparator - Static variable in class org.apache.cassandra.db.DecoratedKey
 
compare(byte[], byte[]) - Method in class org.apache.cassandra.db.marshal.BytesType
 
compare(byte[], byte[]) - Method in class org.apache.cassandra.db.marshal.LexicalUUIDType
 
compare(byte[], byte[]) - Method in class org.apache.cassandra.db.marshal.LongType
 
compare(byte[], byte[]) - Method in class org.apache.cassandra.db.marshal.TimeUUIDType
 
compare(byte[], byte[]) - Method in class org.apache.cassandra.db.marshal.UTF8Type
 
compare(File, File) - Method in class org.apache.cassandra.io.util.FileUtils.FileComparator
 
compareByteArrays(byte[], byte[]) - Static method in class org.apache.cassandra.utils.FBUtilities
 
comparePriority(Column) - Method in class org.apache.cassandra.db.Column
 
compareTo(DecoratedKey) - Method in class org.apache.cassandra.db.DecoratedKey
 
compareTo(Memtable) - Method in class org.apache.cassandra.db.Memtable
Compares two Memtable based on creation time.
compareTo(Token<BigInteger>) - Method in class org.apache.cassandra.dht.BigIntegerToken
 
compareTo(Token<byte[]>) - Method in class org.apache.cassandra.dht.BytesToken
 
compareTo(Range) - Method in class org.apache.cassandra.dht.Range
 
compareTo(Token<String>) - Method in class org.apache.cassandra.dht.StringToken
 
compareTo(Token<T>) - Method in class org.apache.cassandra.dht.Token
This determines the comparison for node destination purposes.
compareTo(ApplicationState) - Method in class org.apache.cassandra.gms.ApplicationState
 
compareTo(GossipDigest) - Method in class org.apache.cassandra.gms.GossipDigest
 
compareTo(IndexSummary.KeyPosition) - Method in class org.apache.cassandra.io.IndexSummary.KeyPosition
 
compareTo(IteratingRow) - Method in class org.apache.cassandra.io.IteratingRow
 
compareTo(SSTableReader) - Method in class org.apache.cassandra.io.SSTableReader
 
compileQuery(String) - Static method in class org.apache.cassandra.cli.CliCompiler
 
complete() - Method in class org.apache.cassandra.io.IndexSummary
 
complete() - Method in interface org.apache.cassandra.service.AntiEntropyService.IValidator
 
complete() - Method in class org.apache.cassandra.service.AntiEntropyService.NoopValidator
Does nothing.
complete() - Method in class org.apache.cassandra.service.AntiEntropyService.Validator
Registers the newly created tree for rendezvous in AE_SERVICE_STAGE.
completedTaskCount - Variable in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
COMPRESSION - Static variable in class org.apache.cassandra.net.ProtocolHeader
 
compressToStream(byte[], ByteArrayOutputStream) - Static method in class org.apache.cassandra.utils.FBUtilities
 
computeNext() - Method in class org.apache.cassandra.db.filter.SSTableNamesIterator
 
computeNext() - Method in class org.apache.cassandra.io.IteratingRow
 
computeNext() - Method in class org.apache.cassandra.utils.MerkleTree.TreeRangeIterator
Find the next TreeRange.
computeNext() - Method in class org.apache.cassandra.utils.ReducingIterator
 
condition - Variable in class org.apache.cassandra.service.QuorumResponseHandler
 
condition - Variable in class org.apache.cassandra.service.WriteResponseHandler
 
ConfigHelper - Class in org.apache.cassandra.hadoop
 
ConfigHelper() - Constructor for class org.apache.cassandra.hadoop.ConfigHelper
 
connect(String, int) - Static method in class org.apache.cassandra.cli.CliMain
Establish a thrift connection to cassandra instance
CONSISTENT - Static variable in class org.apache.cassandra.utils.MerkleTree
 
constructStreamHeader(boolean) - Static method in class org.apache.cassandra.net.MessagingService
 
contains(Token) - Method in class org.apache.cassandra.dht.AbstractBounds
 
contains(Token) - Method in class org.apache.cassandra.dht.Bounds
 
contains(Token, Token, Token) - Static method in class org.apache.cassandra.dht.Range
 
contains(Range) - Method in class org.apache.cassandra.dht.Range
 
contains(Token) - Method in class org.apache.cassandra.dht.Range
Helps determine if a given point on the DHT ring is contained in the range in question.
containsKey(K) - Method in class org.apache.cassandra.utils.ExpiringMap
 
containsValue(V) - Method in class org.apache.cassandra.utils.ExpiringMap
 
contents() - Method in class org.apache.cassandra.db.Memtable
 
Context - Class in org.apache.cassandra.concurrent
Context object adding a collection of key/value pairs into ThreadLocalContext.
Context() - Constructor for class org.apache.cassandra.concurrent.Context
 
convertFromDiskFormat(String) - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
convertFromDiskFormat(String) - Method in interface org.apache.cassandra.dht.IPartitioner
Convert the on disk representation to a DecoratedKey object
convertFromDiskFormat(String) - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
convertFromDiskFormat(String) - Method in class org.apache.cassandra.dht.RandomPartitioner
 
convertToDiskFormat(DecoratedKey<BytesToken>) - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
convertToDiskFormat(DecoratedKey<T>) - Method in interface org.apache.cassandra.dht.IPartitioner
Convert the DecoratedKey to the on disk format used for this partitioner.
convertToDiskFormat(DecoratedKey<StringToken>) - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
convertToDiskFormat(DecoratedKey<BigIntegerToken>) - Method in class org.apache.cassandra.dht.RandomPartitioner
 
convict(InetAddress) - Method in class org.apache.cassandra.gms.Gossiper
This method is part of IFailureDetectionEventListener interface.
convict(InetAddress) - Method in interface org.apache.cassandra.gms.IFailureDetectionEventListener
Convict the specified endpoint.
convict(InetAddress) - Method in interface org.apache.cassandra.gms.IFailureNotification
 
convict(InetAddress) - Method in class org.apache.cassandra.net.MessagingService
called by failure detection code to notify that housekeeping should be performed on downed sockets.
copy() - Method in class org.apache.cassandra.db.ReadCommand
 
copy() - Method in class org.apache.cassandra.db.SliceByNamesReadCommand
 
copy() - Method in class org.apache.cassandra.db.SliceFromReadCommand
 
count - Variable in class org.apache.cassandra.db.filter.SliceQueryFilter
 
count - Variable in class org.apache.cassandra.db.SliceFromReadCommand
 
create(String, String) - Static method in class org.apache.cassandra.db.ColumnFamily
 
create(X, Y) - Static method in class org.apache.cassandra.utils.Pair
 
createAllDirectories() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
Creates all storage-related directories.
createColumnFamilyStore(String, String) - Static method in class org.apache.cassandra.db.ColumnFamilyStore
 
createColumnOrSuperColumn_Column(Column) - Static method in class org.apache.cassandra.thrift.ThriftGlue
 
createColumnOrSuperColumn_SuperColumn(SuperColumn) - Static method in class org.apache.cassandra.thrift.ThriftGlue
 
createColumnParent(String, byte[]) - Static method in class org.apache.cassandra.thrift.ThriftGlue
 
createColumnPath(String, byte[], byte[]) - Static method in class org.apache.cassandra.thrift.ThriftGlue
 
createDirectory(String) - Static method in class org.apache.cassandra.io.util.FileUtils
 
createFile(String) - Static method in class org.apache.cassandra.io.util.FileUtils
 
createHardLink(File, File) - Static method in class org.apache.cassandra.io.util.FileUtils
Create a hard link for a given file.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.cassandra.hadoop.ColumnFamilyInputFormat
 
createSlicePredicate(List<byte[]>, SliceRange) - Static method in class org.apache.cassandra.thrift.ThriftGlue
 

D

DatabaseDescriptor - Class in org.apache.cassandra.config
 
DatabaseDescriptor() - Constructor for class org.apache.cassandra.config.DatabaseDescriptor
 
DatabaseDescriptor.CommitLogSync - Enum in org.apache.cassandra.config
 
DatabaseDescriptor.DiskAccessMode - Enum in org.apache.cassandra.config
 
DatacenterEndPointSnitch - Class in org.apache.cassandra.locator
DataCenterEndPointSnitch

This class basically reads the configuration and sets the IP Ranges to a hashMap which can be read later.

DatacenterEndPointSnitch() - Constructor for class org.apache.cassandra.locator.DatacenterEndPointSnitch
Constructor, intialize XML config and read the config in...
DatacenterShardStategy - Class in org.apache.cassandra.locator
This Stategy is little diffrent than the Rack aware Statergy.
DatacenterShardStategy(TokenMetadata, IEndPointSnitch) - Constructor for class org.apache.cassandra.locator.DatacenterShardStategy
 
DatacenterSyncWriteResponseHandler - Class in org.apache.cassandra.service
This class will block for the replication factor which is provided in the input map.
DatacenterSyncWriteResponseHandler(Map<String, Integer>, String) - Constructor for class org.apache.cassandra.service.DatacenterSyncWriteResponseHandler
 
DatacenterWriteResponseHandler - Class in org.apache.cassandra.service
This class will basically will block for the replication factor which is provided in the input map.
DatacenterWriteResponseHandler(int, String) - Constructor for class org.apache.cassandra.service.DatacenterWriteResponseHandler
 
DataOutputBuffer - Class in org.apache.cassandra.io.util
An implementation of the DataOutputStream interface.
DataOutputBuffer() - Constructor for class org.apache.cassandra.io.util.DataOutputBuffer
Constructs a new empty buffer.
debug - Variable in class org.apache.cassandra.cli.CliSessionState
 
DebuggableThreadPoolExecutor - Class in org.apache.cassandra.concurrent
 
DebuggableThreadPoolExecutor(String) - Constructor for class org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor
 
DebuggableThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, ThreadFactory) - Constructor for class org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor
 
decommission() - Method in class org.apache.cassandra.service.StorageService
 
decommission() - Method in interface org.apache.cassandra.service.StorageServiceMBean
transfer this node's data to other machines and remove it from service.
decommission() - Method in class org.apache.cassandra.tools.NodeProbe
 
decompress(byte[], int, int) - Static method in class org.apache.cassandra.utils.FBUtilities
 
DecoratedKey<T extends Token> - Class in org.apache.cassandra.db
Represents a decorated key, handy for certain operations where just working with strings gets slow.
DecoratedKey(T, String) - Constructor for class org.apache.cassandra.db.DecoratedKey
 
decorateKey(String) - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
decorateKey(String) - Method in interface org.apache.cassandra.dht.IPartitioner
Transform key to object representation of the on-disk format.
decorateKey(String) - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
decorateKey(String) - Method in class org.apache.cassandra.dht.RandomPartitioner
 
DEFAULT_KEY_CACHE_SIZE - Static variable in class org.apache.cassandra.config.CFMetaData
 
DEFAULT_ROW_CACHE_SIZE - Static variable in class org.apache.cassandra.config.CFMetaData
 
defreezeBloomFilter(FileDataInput) - Static method in class org.apache.cassandra.io.IndexHelper
Defreeze the bloom filter.
delete(int, long) - Method in class org.apache.cassandra.db.ColumnFamily
Deprecated. 
delete(ColumnFamily) - Method in class org.apache.cassandra.db.ColumnFamily
 
delete(QueryPath, long) - Method in class org.apache.cassandra.db.RowMutation
 
delete(String) - Static method in class org.apache.cassandra.io.util.FileUtils
 
delete(List<String>) - Static method in class org.apache.cassandra.io.util.FileUtils
 
delete(File[]) - Static method in class org.apache.cassandra.io.util.FileUtils
 
deleteDir(File) - Static method in class org.apache.cassandra.io.util.FileUtils
Deletes all files and subdirectories under "dir".
deleteIfCompacted(String) - Static method in class org.apache.cassandra.io.SSTable
We use a ReferenceQueue to manage deleting files that have been compacted and for which no more SSTable references exist.
deleteOnCleanup() - Method in class org.apache.cassandra.io.SSTableDeletingReference
 
deleteWithConfirm(File) - Static method in class org.apache.cassandra.io.util.FileUtils
 
DeletionService - Class in org.apache.cassandra.io
 
DeletionService() - Constructor for class org.apache.cassandra.io.DeletionService
 
Delimiter - Static variable in class org.apache.cassandra.service.StorageService
 
deliverHints(InetAddress) - Method in class org.apache.cassandra.db.HintedHandOffManager
 
deliverHints(InetAddress) - Method in class org.apache.cassandra.service.StorageService
Deliver hints to the specified node when it has crashed and come back up/ marked as alive after a network partition
depth - Variable in class org.apache.cassandra.utils.MerkleTree.TreeRange
 
deque - Variable in class org.apache.cassandra.utils.BoundedStatsDeque
 
describe_cluster_name() - Method in class org.apache.cassandra.thrift.CassandraServer
 
describe_keyspace(String) - Method in class org.apache.cassandra.thrift.CassandraServer
 
describe_keyspaces() - Method in class org.apache.cassandra.thrift.CassandraServer
 
describe_ring(String) - Method in class org.apache.cassandra.thrift.CassandraServer
 
describe_splits(String, String, int) - Method in class org.apache.cassandra.thrift.CassandraServer
 
describe_version() - Method in class org.apache.cassandra.thrift.CassandraServer
 
deserialize(InputStream) - Static method in class org.apache.cassandra.config.CFMetaData
 
deserialize(InputStream) - Static method in class org.apache.cassandra.config.KSMetaData
 
deserialize(DataInput) - Method in class org.apache.cassandra.db.ColumnFamilySerializer
 
deserialize(DataInput) - Method in class org.apache.cassandra.db.ColumnSerializer
 
deserialize(DataInputStream) - Static method in class org.apache.cassandra.db.filter.QueryPath
 
deserialize(DataInputStream) - Method in class org.apache.cassandra.db.WriteResponse.WriteResponseSerializer
 
deserialize(DataInput) - Method in class org.apache.cassandra.dht.Token.TokenSerializer
 
deserialize(DataInputStream) - Method in interface org.apache.cassandra.io.ICompactSerializer
Deserialize into the specified DataInputStream instance.
deserialize(DataInput) - Method in interface org.apache.cassandra.io.ICompactSerializer2
Deserialize from the specified DataInput instance.
deserialize(FileDataInput) - Static method in class org.apache.cassandra.io.IndexHelper.IndexInfo
 
deserialize(DataInputStream) - Static method in class org.apache.cassandra.net.CompactEndPointSerializationHelper
 
deserialize(DataInputStream) - Method in class org.apache.cassandra.service.AntiEntropyService.TreeRequestVerbHandler
 
deserialize(DataInputStream) - Method in class org.apache.cassandra.service.AntiEntropyService.TreeResponseVerbHandler
 
deserialize(DataInputStream) - Static method in class org.apache.cassandra.utils.BitSetSerializer
 
deserialize(TDeserializer, TBase, DataInput) - Static method in class org.apache.cassandra.utils.FBUtilities
 
deserializeFromSSTable(SSTableReader, DataInput) - Method in class org.apache.cassandra.db.ColumnFamilySerializer
 
deserializeFromSSTableNoColumns(String, String, AbstractType, AbstractType, DataInput) - Method in class org.apache.cassandra.db.ColumnFamilySerializer
 
deserializeFromSSTableNoColumns(ColumnFamily, DataInput) - Method in class org.apache.cassandra.db.ColumnFamilySerializer
 
deserializeIndex(FileDataInput) - Static method in class org.apache.cassandra.io.IndexHelper
Deserialize the index into a structure and return it
destroy() - Method in class org.apache.cassandra.avro.CassandraDaemon
hook for JSVC
destroy() - Method in class org.apache.cassandra.thrift.CassandraDaemon
hook for JSVC
DestructivePQIterator<T> - Class in org.apache.cassandra.utils
 
DestructivePQIterator(PriorityQueue<T>) - Constructor for class org.apache.cassandra.utils.DestructivePQIterator
 
details_ - Variable in class org.apache.cassandra.net.Header
 
diff(IColumn) - Method in class org.apache.cassandra.db.Column
 
diff(ColumnFamily) - Method in class org.apache.cassandra.db.ColumnFamily
 
diff(ColumnFamily, ColumnFamily) - Static method in class org.apache.cassandra.db.ColumnFamily
 
diff(IColumn) - Method in interface org.apache.cassandra.db.IColumn
 
diff(IColumn) - Method in class org.apache.cassandra.db.SuperColumn
 
difference(MerkleTree, MerkleTree) - Static method in class org.apache.cassandra.utils.MerkleTree
 
differences - Variable in class org.apache.cassandra.service.AntiEntropyService.Differencer
 
digest(ColumnFamily) - Static method in class org.apache.cassandra.db.ColumnFamily
 
digest() - Method in class org.apache.cassandra.db.ReadResponse
 
digest(byte[]) - Method in class org.apache.cassandra.utils.SafeMessageDigest
 
digest() - Method in class org.apache.cassandra.utils.SafeMessageDigest
 
digest_ - Static variable in class org.apache.cassandra.utils.SafeMessageDigest
 
DigestMismatchException - Exception in org.apache.cassandra.service
 
DigestMismatchException(String) - Constructor for exception org.apache.cassandra.service.DigestMismatchException
 
disableAutoCompaction() - Method in class org.apache.cassandra.db.CompactionManager
 
discardCompletedSegments(String, String, CommitLogSegment.CommitLogContext) - Method in class org.apache.cassandra.db.commitlog.CommitLog
 
disconnect() - Static method in class org.apache.cassandra.cli.CliMain
Disconnect thrift connection to cassandra instance
DO_REPAIR - Static variable in class org.apache.cassandra.db.ReadCommand
 
doConsistencyCheck(Row, List<InetAddress>, ReadCommand) - Method in class org.apache.cassandra.service.StorageService
This method performs the requisite operations to make sure that the N replicas are in sync.
doVerb(Message) - Method in class org.apache.cassandra.db.BinaryVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.db.ReadRepairVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.db.ReadVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.db.RowMutationVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.dht.BootStrapper.BootstrapTokenVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.gms.Gossiper.GossipDigestAck2VerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.gms.Gossiper.GossipDigestAckVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.gms.Gossiper.GossipDigestSynVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.gms.Gossiper.JoinVerbHandler
 
doVerb(Message) - Method in interface org.apache.cassandra.net.IVerbHandler
This method delivers a message to the implementing class (if the implementing class was registered by a call to MessagingService.registerVerbHandlers).
doVerb(Message) - Method in class org.apache.cassandra.net.ResponseVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.service.AntiEntropyService.TreeRequestVerbHandler
Trigger a readonly compaction which will broadcast the tree upon completion.
doVerb(Message) - Method in class org.apache.cassandra.service.AntiEntropyService.TreeResponseVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.service.RangeSliceVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.streaming.StreamFinishedVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.streaming.StreamInitiateDoneVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.streaming.StreamInitiateVerbHandler
 
doVerb(Message) - Method in class org.apache.cassandra.streaming.StreamRequestVerbHandler
 
drain() - Method in class org.apache.cassandra.service.StorageService
shuts node off to writes, empties memtables and the commit log.
drain() - Method in interface org.apache.cassandra.service.StorageServiceMBean
makes node unavailable for writes, flushes memtables and replays commitlog.
drain() - Method in class org.apache.cassandra.tools.NodeProbe
 
dumpInterArrivalTimes() - Method in class org.apache.cassandra.gms.FailureDetector
Dump the inter arrival times for examination if necessary.
dumpInterArrivalTimes() - Method in interface org.apache.cassandra.gms.FailureDetectorMBean
 

E

echoData(DataOutput) - Method in class org.apache.cassandra.io.IteratingRow
 
EmbeddedCassandraService - Class in org.apache.cassandra.service
An embedded, in-memory cassandra storage service that listens on the thrift interface as configured in storage-conf.xml This kind of service is useful when running unit tests of services using cassandra for example.
EmbeddedCassandraService() - Constructor for class org.apache.cassandra.service.EmbeddedCassandraService
 
EMPTY_CF - Static variable in class org.apache.cassandra.db.ReadCommand
 
EMPTY_ROW - Static variable in class org.apache.cassandra.service.AntiEntropyService.Validator
 
encodedUTF8Length(String) - Static method in class org.apache.cassandra.utils.FBUtilities
 
EndPointSnitch - Class in org.apache.cassandra.locator
A simple endpoint snitch implementation that assumes rack and dc information is encoded in the ip address.
EndPointSnitch() - Constructor for class org.apache.cassandra.locator.EndPointSnitch
 
EndPointState - Class in org.apache.cassandra.gms
This abstraction represents both the HeartBeatState and the ApplicationState in an EndPointState instance.
enumeratekeys(String, PrintStream) - Static method in class org.apache.cassandra.tools.SSTableExport
Enumerate row keys from an SSTableReader and write the result to a PrintStream.
enumeratekeys(String, String) - Static method in class org.apache.cassandra.tools.SSTableExport
Enumerate row keys from an SSTable and write the result to a file.
epSnitch - Variable in class org.apache.cassandra.config.KSMetaData
 
equals(Object) - Method in class org.apache.cassandra.config.CFMetaData
 
equals(Object) - Method in class org.apache.cassandra.config.KSMetaData
 
equals(Object) - Method in class org.apache.cassandra.db.ColumnFamily
 
equals(Object) - Method in class org.apache.cassandra.db.DecoratedKey
 
equals(Object) - Method in class org.apache.cassandra.db.marshal.AbstractType
 
equals(Object) - Method in class org.apache.cassandra.dht.AbstractBounds
 
equals(Object) - Method in class org.apache.cassandra.dht.Bounds
 
equals(Object) - Method in class org.apache.cassandra.dht.BytesToken
 
equals(Object) - Method in class org.apache.cassandra.dht.Range
 
equals(Object) - Method in class org.apache.cassandra.dht.Token
 
equals(Object, Object) - Static method in class org.apache.cassandra.utils.FBUtilities
 
equals(Object) - Method in class org.apache.cassandra.utils.Pair
 
err - Variable in class org.apache.cassandra.cli.CliSessionState
 
EstimatedHistogram - Class in org.apache.cassandra.utils
 
EstimatedHistogram() - Constructor for class org.apache.cassandra.utils.EstimatedHistogram
 
estimatedKeys() - Method in class org.apache.cassandra.io.SSTableReader
 
estimatedKeys() - Method in class org.apache.cassandra.io.SSTableTracker
 
execute(Runnable) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Executes the given command at some time in the future.
executeCLIStmt(String) - Method in class org.apache.cassandra.cli.CliClient
 
executor - Static variable in class org.apache.cassandra.io.DeletionService
 
ExpiringMap<K,V> - Class in org.apache.cassandra.utils
 
ExpiringMap(long) - Constructor for class org.apache.cassandra.utils.ExpiringMap
 
ExpiringMap(long, ICacheExpungeHook<K, V>) - Constructor for class org.apache.cassandra.utils.ExpiringMap
 
export(String, PrintStream, String[], String[]) - Static method in class org.apache.cassandra.tools.SSTableExport
Export specific rows from an SSTable and write the resulting JSON to a PrintStream.
export(String, String, String[], String[]) - Static method in class org.apache.cassandra.tools.SSTableExport
Export specific rows from an SSTable and write the resulting JSON to a file.
export(String, PrintStream, String[]) - Static method in class org.apache.cassandra.tools.SSTableExport
Export an SSTable and write the resulting JSON to a PrintStream.
export(String, String, String[]) - Static method in class org.apache.cassandra.tools.SSTableExport
Export an SSTable and write the resulting JSON to a file.
export(String, String[]) - Static method in class org.apache.cassandra.tools.SSTableExport
Export an SSTable and write the resulting JSON to standard out.

F

FailureDetector - Class in org.apache.cassandra.gms
This FailureDetector is an implementation of the paper titled "The Phi Accrual Failure Detector" by Hayashibara.
FailureDetector() - Constructor for class org.apache.cassandra.gms.FailureDetector
 
FailureDetectorMBean - Interface in org.apache.cassandra.gms
 
FBUtilities - Class in org.apache.cassandra.utils
 
FBUtilities() - Constructor for class org.apache.cassandra.utils.FBUtilities
 
FILE_BUFFER_SIZE - Static variable in class org.apache.cassandra.io.CompactionIterator
 
FileDataInput - Interface in org.apache.cassandra.io.util
 
FILES_ON_DISK - Static variable in class org.apache.cassandra.io.SSTable
 
FileStreamTask - Class in org.apache.cassandra.net
 
FileUtils - Class in org.apache.cassandra.io.util
 
FileUtils() - Constructor for class org.apache.cassandra.io.util.FileUtils
 
FileUtils.FileComparator - Class in org.apache.cassandra.io.util
 
FileUtils.FileComparator() - Constructor for class org.apache.cassandra.io.util.FileUtils.FileComparator
 
Filter - Class in org.apache.cassandra.utils
 
Filter() - Constructor for class org.apache.cassandra.utils.Filter
 
filterFilename(String) - Static method in class org.apache.cassandra.io.SSTable
 
filterFilename() - Method in class org.apache.cassandra.io.SSTable
 
filterSuperColumn(SuperColumn, int) - Method in class org.apache.cassandra.db.filter.IdentityQueryFilter
 
filterSuperColumn(SuperColumn, int) - Method in class org.apache.cassandra.db.filter.NamesQueryFilter
 
filterSuperColumn(SuperColumn, int) - Method in class org.apache.cassandra.db.filter.QueryFilter
subcolumns of a supercolumn are unindexed, so to pick out parts of those we operate in-memory.
filterSuperColumn(SuperColumn, int) - Method in class org.apache.cassandra.db.filter.SliceQueryFilter
 
findSuitableEndPoint(String, String) - Method in class org.apache.cassandra.service.StorageService
This function finds the closest live endpoint that contains a given key.
finish - Variable in class org.apache.cassandra.db.filter.SliceQueryFilter
 
finish - Variable in class org.apache.cassandra.db.SliceFromReadCommand
 
finishAndStartNext(String) - Method in class org.apache.cassandra.streaming.StreamOutManager
 
firstName - Variable in class org.apache.cassandra.io.IndexHelper.IndexInfo
 
flush() - Method in class org.apache.cassandra.db.Table
 
flushAndSignal(Condition, ExecutorService, ExecutorService) - Method in class org.apache.cassandra.db.BinaryMemtable
 
flushAndSignal(Condition, ExecutorService, ExecutorService) - Method in interface org.apache.cassandra.db.IFlushable
 
flushAndSignal(Condition, ExecutorService, ExecutorService) - Method in class org.apache.cassandra.db.Memtable
 
forceAntiCompaction(Collection<Range>, InetAddress) - Method in class org.apache.cassandra.db.Table
 
forceBlockingFlush() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
forceBloomFilterFailures() - Method in class org.apache.cassandra.io.SSTableReader
obviously only for testing
forceCleanup() - Method in class org.apache.cassandra.db.Table
Do a cleanup of keys that do not belong locally.
forceCompaction() - Method in class org.apache.cassandra.db.Table
 
forceFlush() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
forceFlush() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
Triggers an immediate memtable flush.
forceFlushBinary() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
forceFlushIfExpired() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
forceMajorCompaction() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
forceMajorCompaction() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
force a major compaction of this column family
forceNewSegment() - Method in class org.apache.cassandra.db.commitlog.CommitLog
 
forceTableCleanup() - Method in class org.apache.cassandra.service.StorageService
 
forceTableCleanup() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Trigger a cleanup of keys on all tables.
forceTableCleanup() - Method in class org.apache.cassandra.tools.NodeProbe
 
forceTableCompaction() - Method in class org.apache.cassandra.service.StorageService
 
forceTableCompaction() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Forces major compaction (all sstable files compacted)
forceTableCompaction() - Method in class org.apache.cassandra.tools.NodeProbe
 
forceTableFlush(String, String...) - Method in class org.apache.cassandra.service.StorageService
Flush all memtables for a table and column families.
forceTableFlush(String, String...) - Method in interface org.apache.cassandra.service.StorageServiceMBean
Flush all memtables for the given column families, or all columnfamilies for the given table if none are explicitly listed.
forceTableFlush(String, String...) - Method in class org.apache.cassandra.tools.NodeProbe
 
forceTableRepair(String, String...) - Method in class org.apache.cassandra.service.StorageService
Trigger proactive repair for a table and column families.
forceTableRepair(String, String...) - Method in interface org.apache.cassandra.service.StorageServiceMBean
Triggers proactive repair for given column families, or all columnfamilies for the given table if none are explicitly listed.
forceTableRepair(String, String...) - Method in class org.apache.cassandra.tools.NodeProbe
 
framed - Variable in class org.apache.cassandra.cli.CliSessionState
 
fromByteArray(byte[]) - Method in class org.apache.cassandra.dht.Token.TokenFactory
 
fromString(String) - Method in class org.apache.cassandra.dht.Token.TokenFactory
 
FULLY_INCONSISTENT - Static variable in class org.apache.cassandra.utils.MerkleTree
 

G

GCInspector - Class in org.apache.cassandra.service
 
GCInspector() - Constructor for class org.apache.cassandra.service.GCInspector
 
get(Utf8, Utf8, ColumnPath, ConsistencyLevel) - Method in class org.apache.cassandra.avro.CassandraServer
 
get(K) - Method in class org.apache.cassandra.cache.InstrumentedCache
 
get(Object) - Method in class org.apache.cassandra.concurrent.Context
 
get(String, String) - Method in class org.apache.cassandra.db.Table
Deprecated. 
get() - Method in interface org.apache.cassandra.net.IAsyncResult
Returns the result for the task that was submitted.
get(long, TimeUnit) - Method in interface org.apache.cassandra.net.IAsyncResult
Same operation as the above get() but allows the calling thread to specify a timeout.
get() - Method in class org.apache.cassandra.service.QuorumResponseHandler
 
get() - Method in class org.apache.cassandra.service.WriteResponseHandler
 
get(InetAddress) - Static method in class org.apache.cassandra.streaming.StreamOutManager
 
get(String, String, ColumnPath, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
get(Boolean) - Method in class org.apache.cassandra.utils.EstimatedHistogram
 
get(K) - Method in class org.apache.cassandra.utils.ExpiringMap
 
get_api_version() - Method in class org.apache.cassandra.avro.CassandraServer
 
get_count(String, String, ColumnParent, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
get_range_slice(String, ColumnParent, SlicePredicate, String, String, int, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
get_range_slices(String, ColumnParent, SlicePredicate, KeyRange, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
get_slice(String, String, ColumnParent, SlicePredicate, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
get_string_list_property(String) - Method in class org.apache.cassandra.thrift.CassandraServer
 
get_string_property(String) - Method in class org.apache.cassandra.thrift.CassandraServer
 
getAbsolutePosition() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
getAbsolutePosition() - Method in interface org.apache.cassandra.io.util.FileDataInput
 
getAbsolutePosition() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
getActiveCount() - Method in interface org.apache.cassandra.concurrent.IExecutorMBean
Get the current number of running tasks
getActiveCount() - Method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
Get the current number of running tasks
getAddressRanges(TokenMetadata, String) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
getAddressRanges(String) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
getAllDataFileLocations() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getAllDataFileLocationsForTable(String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
Get a list of data directories for a given table
getAllFilenames() - Method in class org.apache.cassandra.io.SSTable
 
getAllRanges(List<Token>) - Method in class org.apache.cassandra.service.StorageService
Get all ranges that span the ring given a set of tokens.
getApplicationState(String) - Method in class org.apache.cassandra.gms.EndPointState
 
getApplicationStateMap() - Method in class org.apache.cassandra.gms.EndPointState
 
getApproximateKeyCount(Iterable<SSTableReader>) - Static method in class org.apache.cassandra.io.SSTableReader
 
getAsyncResult(String) - Static method in class org.apache.cassandra.net.MessagingService
 
getAttributeValue(Node, String) - Static method in class org.apache.cassandra.utils.XMLUtils
 
getAuthenticator() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getBalancedToken(TokenMetadata, Map<InetAddress, Double>) - Static method in class org.apache.cassandra.dht.BootStrapper
 
getBits(int, int, int) - Static method in class org.apache.cassandra.net.MessagingService
 
getBMTThreshold() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getBootstrapToken(TokenMetadata, Map<InetAddress, Double>) - Static method in class org.apache.cassandra.dht.BootStrapper
if initialtoken was specified, use that.
getBootstrapToken() - Method in class org.apache.cassandra.service.StorageService
return a token to which if a node bootstraps it will get about 1/2 of this node's range
getBootstrapTokens() - Method in class org.apache.cassandra.locator.TokenMetadata
caller should not modify bootstrapTokens
getBytesCompacted() - Method in class org.apache.cassandra.db.CompactionManager
 
getBytesCompacted() - Method in interface org.apache.cassandra.db.CompactionManagerMBean
 
getBytesRead() - Method in class org.apache.cassandra.io.CompactionIterator
 
getBytesTotalInProgress() - Method in class org.apache.cassandra.db.CompactionManager
 
getBytesTotalInProgress() - Method in interface org.apache.cassandra.db.CompactionManagerMBean
 
getCache() - Method in interface org.apache.cassandra.cache.IAggregatableCacheProvider
 
getCapacity() - Method in class org.apache.cassandra.cache.InstrumentedCache
 
getCapacity() - Method in interface org.apache.cassandra.cache.JMXInstrumentedCacheMBean
 
getCFMetaData(String, String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getClusterName() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getClusterName() - Method in class org.apache.cassandra.db.SystemTable.StorageMetadata
 
getCollatingIterator(Iterable<SSTableReader>) - Static method in class org.apache.cassandra.io.CompactionIterator
 
getCollatingIterator() - Static method in class org.apache.cassandra.utils.FBUtilities
 
getColumn(CommonTree, int) - Static method in class org.apache.cassandra.cli.CliCompiler
 
getColumn(byte[]) - Method in class org.apache.cassandra.db.ColumnFamily
 
getColumnComparator(AbstractType) - Method in class org.apache.cassandra.db.filter.QueryFilter
 
getColumnComparator(AbstractType) - Method in class org.apache.cassandra.db.filter.SliceQueryFilter
 
getColumnComparator() - Method in class org.apache.cassandra.io.SSTableReader
 
getColumnFamilies() - Method in class org.apache.cassandra.db.RowMutation
 
getColumnFamilies() - Method in class org.apache.cassandra.db.Table
 
getColumnFamily(CommonTree) - Static method in class org.apache.cassandra.cli.CliCompiler
 
getColumnFamily(String, QueryPath, byte[], byte[], boolean, int) - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getColumnFamily(QueryFilter) - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getColumnFamily(QueryFilter, int) - Method in class org.apache.cassandra.db.ColumnFamilyStore
get a list of columns starting from a given column, in a specified order.
getColumnFamily() - Method in interface org.apache.cassandra.db.filter.ColumnIterator
returns the CF of the column being iterated.
getColumnFamily() - Method in class org.apache.cassandra.db.filter.SSTableNamesIterator
 
getColumnFamily(String) - Method in class org.apache.cassandra.db.Memtable
 
getColumnFamily(Configuration) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
 
getColumnFamily() - Method in class org.apache.cassandra.io.IteratingRow
 
getColumnFamilyCount() - Static method in class org.apache.cassandra.db.Table.TableMetadata
 
getColumnFamilyId(String) - Method in class org.apache.cassandra.db.Table
 
getColumnFamilyIDString() - Static method in class org.apache.cassandra.db.Table.TableMetadata
 
getColumnFamilyInProgress() - Method in class org.apache.cassandra.db.CompactionManager
 
getColumnFamilyInProgress() - Method in interface org.apache.cassandra.db.CompactionManagerMBean
 
getColumnFamilyName() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getColumnFamilyName() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getColumnFamilyName() - Method in class org.apache.cassandra.db.filter.QueryFilter
 
getColumnFamilyName() - Method in class org.apache.cassandra.db.ReadCommand
 
getColumnFamilyName(int) - Static method in class org.apache.cassandra.db.Table.TableMetadata
 
getColumnFamilyName() - Method in class org.apache.cassandra.io.SSTable
 
getColumnFamilyStore(String) - Method in class org.apache.cassandra.db.Table
 
getColumnFamilyStoreMBeanProxies() - Method in class org.apache.cassandra.tools.NodeProbe
 
getColumnFamilyStores() - Method in class org.apache.cassandra.db.Table
 
getColumnFamilyType(String, String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getColumnIndexSize() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getColumnNames() - Method in class org.apache.cassandra.db.ColumnFamily
 
getColumnSerializer() - Method in class org.apache.cassandra.db.ColumnFamily
 
getColumnSerializer() - Method in class org.apache.cassandra.io.SSTableReader
 
getColumnsMap() - Method in class org.apache.cassandra.db.ColumnFamily
 
getColumnsString(Collection<IColumn>) - Method in class org.apache.cassandra.db.marshal.AbstractType
convenience method
getColumnType(String, String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getColumnType(String) - Static method in class org.apache.cassandra.db.ColumnFamily
 
getCommitLogSync() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getCommitLogSyncBatchWindow() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getCommitLogSyncPeriod() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getCompactionThreshold(PrintStream) - Method in class org.apache.cassandra.tools.NodeProbe
Get the compaction threshold
getComparator(String, String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getComparator() - Method in class org.apache.cassandra.db.ColumnFamily
 
getComparator() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getComparator() - Method in interface org.apache.cassandra.db.IColumnContainer
 
getComparator() - Method in class org.apache.cassandra.db.ReadCommand
 
getComparator() - Method in class org.apache.cassandra.db.SuperColumn
 
getComparator(AbstractType) - Static method in class org.apache.cassandra.io.IndexHelper
 
getComparatorFor(String, String, byte[]) - Static method in class org.apache.cassandra.db.ColumnFamily
 
getCompletedTasks() - Method in interface org.apache.cassandra.concurrent.IExecutorMBean
Get the number of completed tasks
getCompletedTasks() - Method in class org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
Get the number of completed tasks
getCompletedTasks() - Method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
Get the number of completed tasks
getConcurrentReaders() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getConcurrentWriters() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getConfigFileName() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getConnection(InetAddress, Message) - Static method in class org.apache.cassandra.net.MessagingService
 
getConnectionPool(InetAddress) - Static method in class org.apache.cassandra.net.MessagingService
 
getConsistencyCheck() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getConsistencyThreads() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getContext() - Method in class org.apache.cassandra.db.commitlog.CommitLog
 
getContext() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
getCorePoolSize() - Method in interface org.apache.cassandra.concurrent.JMXConfigurableThreadPoolExecutorMBean
 
getCurrentGenerationNumber(InetAddress) - Method in class org.apache.cassandra.gms.Gossiper
 
getCurrentGenerationNumber() - Method in class org.apache.cassandra.service.StorageService
 
getCurrentGenerationNumber() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Return the generation value for this node.
getCurrentGenerationNumber() - Method in class org.apache.cassandra.tools.NodeProbe
 
getCurrentKey() - Method in class org.apache.cassandra.hadoop.ColumnFamilyRecordReader
 
getCurrentOperations() - Method in class org.apache.cassandra.db.Memtable
 
getCurrentThroughput() - Method in class org.apache.cassandra.db.Memtable
 
getCurrentValue() - Method in class org.apache.cassandra.hadoop.ColumnFamilyRecordReader
 
getData() - Method in class org.apache.cassandra.io.util.DataOutputBuffer
Returns the current contents of the buffer.
getDataFileLocation(long) - Method in class org.apache.cassandra.db.Table
 
getDataFileLocationForTable(String, long) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getDefaultGCBefore() - Static method in class org.apache.cassandra.db.CompactionManager
 
getDeserializationExecutor() - Static method in class org.apache.cassandra.net.MessagingService
 
getDestinations() - Static method in class org.apache.cassandra.streaming.StreamOutManager
 
getDigestLength() - Method in class org.apache.cassandra.utils.SafeMessageDigest
 
getDiskAccessMode() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getEndPoint(String, String) - Method in class org.apache.cassandra.client.RingCache
 
getEndPoint(Token) - Method in class org.apache.cassandra.locator.TokenMetadata
 
getEndPoints(String, String) - Method in class org.apache.cassandra.tools.NodeProbe
 
getEndPointSnitch(String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getEndPosition() - Method in class org.apache.cassandra.io.IteratingRow
 
getEndToken() - Method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
getFileDataInput(DecoratedKey, int) - Method in class org.apache.cassandra.io.SSTableReader
 
getFileLength() - Method in class org.apache.cassandra.io.SSTableScanner
 
getFilename() - Method in class org.apache.cassandra.io.SSTable
 
getFilePointer() - Method in class org.apache.cassandra.io.SSTableScanner
 
getFilePointer() - Method in class org.apache.cassandra.io.SSTableWriter
 
getFilePointer() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
getFilesDestinedFor(InetAddress) - Method in class org.apache.cassandra.tools.NodeProbe
 
getFilter(long, int) - Static method in class org.apache.cassandra.utils.BloomFilter
 
getFilter(long, double) - Static method in class org.apache.cassandra.utils.BloomFilter
 
getFirstEndpoint() - Method in class org.apache.cassandra.locator.TokenMetadata
 
getFlushDataBufferSizeInMB() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getFlushIndexBufferSizeInMB() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getFlushPath() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getFrom() - Method in class org.apache.cassandra.net.Message
 
getGcGraceInSeconds() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getGeneration() - Method in class org.apache.cassandra.db.SystemTable.StorageMetadata
 
getGenerationFromFileName(String) - Static method in class org.apache.cassandra.db.ColumnFamilyStore
 
getHashBuckets(String) - Method in class org.apache.cassandra.utils.Filter
 
getHashBuckets(byte[]) - Method in class org.apache.cassandra.utils.Filter
 
getHasToken() - Method in class org.apache.cassandra.gms.EndPointState
 
getHeader() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
getHeader(Object) - Method in class org.apache.cassandra.net.Message
 
getHeapMemoryUsage() - Method in class org.apache.cassandra.tools.NodeProbe
 
getHintedEndpoints(String, Collection<InetAddress>) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
returns multimap of {live destination: ultimate targets}, where if target is not the same as the destination, it is a "hinted" write, and will need to be sent to the ultimate target when it becomes alive again.
getHits() - Method in class org.apache.cassandra.cache.InstrumentedCache
 
getHits() - Method in interface org.apache.cassandra.cache.JMXInstrumentedCacheMBean
total cache hit count since cache creation
getIncomingFiles(String) - Method in class org.apache.cassandra.streaming.StreamingService
details about incoming streams.
getIncomingFiles(String) - Method in interface org.apache.cassandra.streaming.StreamingServiceMBean
details about incoming streams
getIncomingFiles(InetAddress) - Method in class org.apache.cassandra.tools.NodeProbe
 
getIndexAccessMode() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getIndexedReadBufferSizeInKB() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getIndexPositions() - Method in class org.apache.cassandra.io.IndexSummary
 
getIndexPositions() - Method in class org.apache.cassandra.io.SSTableReader
 
getInitialToken() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getInputSplitSize(Configuration) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
 
getInternal(K) - Method in class org.apache.cassandra.cache.InstrumentedCache
 
getJobJarLocation() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getJobTrackerAddress() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getKey(CommonTree) - Static method in class org.apache.cassandra.cli.CliCompiler
 
getKey() - Method in class org.apache.cassandra.io.IteratingRow
 
getKeyCache() - Method in class org.apache.cassandra.io.SSTableTracker
 
getKeyCacheMBean(String, String) - Method in class org.apache.cassandra.tools.NodeProbe
 
getKeyIterator(DecoratedKey) - Method in class org.apache.cassandra.db.Memtable
 
getKeysCachedFor(String, String, long) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getKeyspace(Configuration) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
 
getLastIndexPosition() - Method in class org.apache.cassandra.io.IndexSummary
 
getLeavingEndPoints() - Method in class org.apache.cassandra.locator.TokenMetadata
caller should not modify leavigEndPoints
getLength() - Method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
getLength() - Method in class org.apache.cassandra.io.util.DataOutputBuffer
Returns the length of the valid data currently in the buffer.
getLifetimeReadLatencyHistogramMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getLifetimeReadLatencyHistogramMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getLifetimeWriteLatencyHistogramMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getLifetimeWriteLatencyHistogramMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getListenAddress() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getLiveDiskSpaceUsed() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getLiveDiskSpaceUsed() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getLiveMembers() - Method in class org.apache.cassandra.gms.Gossiper
 
getLiveNaturalEndpoints(String, String) - Method in class org.apache.cassandra.service.StorageService
This method attempts to return N endpoints that are responsible for storing the specified key i.e for replication.
getLiveNaturalEndpoints(String, Token) - Method in class org.apache.cassandra.service.StorageService
 
getLiveNodes() - Method in class org.apache.cassandra.service.StorageService
 
getLiveNodes() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Retrieve the list of live nodes in the cluster, where "liveness" is determined by the failure detector of the node being queried.
getLiveNodes() - Method in class org.apache.cassandra.tools.NodeProbe
 
getLiveSize() - Method in class org.apache.cassandra.io.SSTableTracker
 
getLiveSSTableCount() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getLiveSSTableCount() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getLoad() - Method in class org.apache.cassandra.service.StorageService
raw load value
getLoad() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Numeric load value.
getLoadInfo() - Method in class org.apache.cassandra.service.StorageLoadBalancer
 
getLoadMap() - Method in class org.apache.cassandra.service.StorageService
 
getLoadMap() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Human-readable load value.
getLoadMap() - Method in class org.apache.cassandra.tools.NodeProbe
 
getLoadString() - Method in class org.apache.cassandra.service.StorageService
 
getLoadString() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Human-readable load value
getLoadString() - Method in class org.apache.cassandra.tools.NodeProbe
 
getLocalAddress() - Static method in class org.apache.cassandra.utils.FBUtilities
 
getLocalDeletionTime() - Method in class org.apache.cassandra.db.Column
 
getLocalDeletionTime() - Method in class org.apache.cassandra.db.ColumnFamily
 
getLocalDeletionTime() - Method in interface org.apache.cassandra.db.IColumn
 
getLocalDeletionTime() - Method in class org.apache.cassandra.db.SuperColumn
 
getLocalPrimaryRange() - Method in class org.apache.cassandra.service.StorageService
 
getLocalRanges(String) - Method in class org.apache.cassandra.service.StorageService
 
getLocalToken() - Method in class org.apache.cassandra.service.StorageService
 
getLocation(InetAddress) - Method in class org.apache.cassandra.locator.AbstractEndpointSnitch
Determines the name of the datacenter this endpoint lives in.
getLocation(InetAddress) - Method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
 
getLocation(InetAddress) - Method in class org.apache.cassandra.locator.EndPointSnitch
 
getLocations() - Method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
getLogFileLocation() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getMapQuorumFactor() - Method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
Returns a DC replication map, the key will be the dc name and the value will be the replication factor of that Datacenter.
getMapReplicationFactor() - Method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
Returns a DC replication map, the key will be the dc name and the value will be the replication factor of that Datacenter.
getMarkedForDeleteAt() - Method in class org.apache.cassandra.db.Column
 
getMarkedForDeleteAt() - Method in class org.apache.cassandra.db.ColumnFamily
 
getMarkedForDeleteAt() - Method in interface org.apache.cassandra.db.IColumn
 
getMarkedForDeleteAt() - Method in interface org.apache.cassandra.db.IColumnContainer
 
getMarkedForDeleteAt() - Method in class org.apache.cassandra.db.SuperColumn
 
getMaximumCompactionThreshold() - Method in class org.apache.cassandra.db.CompactionManager
Gets the maximum number of sstables in queue before compaction kicks off
getMaximumCompactionThreshold() - Method in interface org.apache.cassandra.db.CompactionManagerMBean
Gets the maximum number of sstables in queue before compaction kicks off
getMaxRowCompactedSize() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getMaxRowCompactedSize() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
return the size of the largest compacted row
getMeanRowCompactedSize() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getMeanRowCompactedSize() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
return the mean size of the rows compacted
getMemColumnIterator(Memtable, ColumnFamily, AbstractType) - Method in class org.apache.cassandra.db.filter.NamesQueryFilter
 
getMemColumnIterator(Memtable, ColumnFamily, AbstractType) - Method in class org.apache.cassandra.db.filter.QueryFilter
returns an iterator that returns columns from the given memtable matching the Filter criteria in sorted order.
getMemColumnIterator(Memtable, AbstractType) - Method in class org.apache.cassandra.db.filter.QueryFilter
 
getMemColumnIterator(Memtable, ColumnFamily, AbstractType) - Method in class org.apache.cassandra.db.filter.SliceQueryFilter
 
getMemtableColumnsCount() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getMemtableColumnsCount() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
Returns the total number of columns present in the memtable.
getMemtableDataSize() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getMemtableDataSize() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
Returns the total amount of data stored in the memtable, including column related overhead.
getMemtableLifetimeMS() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getMemtableOperations() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getMemtablesPendingFlush() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getMemtableSwitchCount() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getMemtableSwitchCount() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
Returns the number of times that a flush has resulted in the memtable being switched out.
getMemtableThroughput() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getMessage() - Method in class org.apache.cassandra.db.RangeSliceCommand
 
getMessageBody() - Method in class org.apache.cassandra.net.Message
 
getMessageId() - Method in class org.apache.cassandra.net.Message
 
getMessageType() - Method in class org.apache.cassandra.net.Message
 
getMinimumCompactionThreshold() - Method in class org.apache.cassandra.db.CompactionManager
Gets the minimum number of sstables in queue before compaction kicks off
getMinimumCompactionThreshold() - Method in interface org.apache.cassandra.db.CompactionManagerMBean
Gets the minimum number of sstables in queue before compaction kicks off
getMinimumToken() - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
getMinimumToken() - Method in interface org.apache.cassandra.dht.IPartitioner
 
getMinimumToken() - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
getMinimumToken() - Method in class org.apache.cassandra.dht.RandomPartitioner
 
getMinRowCompactedSize() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getMinRowCompactedSize() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
return the size of the smallest compacted row
getNamesIterator(ColumnFamily, NamesQueryFilter) - Method in class org.apache.cassandra.db.Memtable
 
getNaturalEndpoints(Token, TokenMetadata, String) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
get the endpoints that should store the given Token, for the given table.
getNaturalEndpoints(Token, String) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
getNaturalEndpoints(Token, TokenMetadata, String) - Method in class org.apache.cassandra.locator.DatacenterShardStategy
 
getNaturalEndpoints(Token, TokenMetadata, String) - Method in class org.apache.cassandra.locator.RackAwareStrategy
 
getNaturalEndpoints(Token, TokenMetadata, String) - Method in class org.apache.cassandra.locator.RackUnawareStrategy
 
getNaturalEndpoints(String, String) - Method in class org.apache.cassandra.service.StorageService
This method returns the N endpoints that are responsible for storing the specified key i.e for replication.
getNaturalEndpoints(String, Token) - Method in class org.apache.cassandra.service.StorageService
This method returns the N endpoints that are responsible for storing the specified key i.e for replication.
getNaturalEndpoints(String, String) - Method in interface org.apache.cassandra.service.StorageServiceMBean
This method returns the N endpoints that are responsible for storing the specified key i.e for replication.
getNearestPosition(DecoratedKey) - Method in class org.apache.cassandra.io.SSTableReader
like getPosition, but if key is not found will return the location of the first key _greater_ than the desired one, or -1 if no such key exists.
getNeighbors(String) - Static method in class org.apache.cassandra.service.AntiEntropyService
Return all of the neighbors with whom we share data.
getNewFileNameFromOldContextAndNames(Map<String, String>, Map<String, String>, PendingFile) - Method in class org.apache.cassandra.streaming.StreamInitiateVerbHandler
 
getNewNames(PendingFile[]) - Method in class org.apache.cassandra.streaming.StreamInitiateVerbHandler
 
getNextAvailableDataLocation() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getNextVersion() - Static method in class org.apache.cassandra.gms.VersionGenerator
 
getNodeValue(String) - Method in class org.apache.cassandra.utils.XMLUtils
 
getNodeValues(String) - Method in class org.apache.cassandra.utils.XMLUtils
 
getNonSystemTables() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getObjectCount() - Method in interface org.apache.cassandra.cache.IAggregatableCacheProvider
 
getObjectCount() - Method in class org.apache.cassandra.db.Column
 
getObjectCount() - Method in interface org.apache.cassandra.db.IColumn
 
getObjectCount() - Method in class org.apache.cassandra.db.SuperColumn
 
getOpCount() - Method in class org.apache.cassandra.utils.LatencyTracker
 
getOperationMode() - Method in class org.apache.cassandra.service.StorageService
 
getOperationMode() - Method in interface org.apache.cassandra.service.StorageServiceMBean
get the operational mode (leaving, joining, normal, decommissioned, client)
getOperationMode() - Method in class org.apache.cassandra.tools.NodeProbe
 
getOutgoingFiles(String) - Method in class org.apache.cassandra.streaming.StreamingService
outgoing streams
getOutgoingFiles(String) - Method in interface org.apache.cassandra.streaming.StreamingServiceMBean
outgoing streams
getPartitioner() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getPartitioner() - Method in class org.apache.cassandra.io.SSTableReader
 
getPartitioner() - Static method in class org.apache.cassandra.service.StorageService
 
getPath() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
getPath() - Method in class org.apache.cassandra.io.IteratingRow
 
getPath() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
getPath() - Method in interface org.apache.cassandra.io.util.FileDataInput
 
getPath() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
getPendingAddressRanges(TokenMetadata, Token, InetAddress, String) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
getPendingFiles(InetAddress) - Static method in class org.apache.cassandra.streaming.StreamOutManager
this method exists so that we don't have to call StreamOutManager.get() which has a nasty side-effect of indicating that we are streaming to a particular host.
getPendingRanges(String) - Method in class org.apache.cassandra.locator.TokenMetadata
a mutable map may be returned but caller should not modify it
getPendingRanges(String, InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
getPendingTasks() - Method in interface org.apache.cassandra.concurrent.IExecutorMBean
Get the number of tasks waiting to be executed
getPendingTasks() - Method in class org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
Get the number of tasks waiting to be executed
getPendingTasks() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getPendingTasks() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getPendingTasks() - Method in class org.apache.cassandra.db.CompactionManager
 
getPendingTasks() - Method in interface org.apache.cassandra.db.CompactionManagerMBean
 
getPhiConvictThreshold() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getPhiConvictThreshold() - Method in class org.apache.cassandra.gms.FailureDetector
 
getPhiConvictThreshold() - Method in interface org.apache.cassandra.gms.FailureDetectorMBean
 
getPosition(DecoratedKey) - Method in class org.apache.cassandra.io.SSTableReader
returns the position in the data file to find the given key, or -1 if the key is not present
getPredecessor(Token) - Method in class org.apache.cassandra.locator.TokenMetadata
 
getPrimaryRangeFor(Token) - Method in class org.apache.cassandra.locator.TokenMetadata
 
getPrimaryRangeForEndPoint(InetAddress) - Method in class org.apache.cassandra.service.StorageService
Get the primary range for the specified endpoint.
getProgress() - Method in class org.apache.cassandra.hadoop.ColumnFamilyRecordReader
 
getQuorum(String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getRackForEndPoint(InetAddress) - Method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
Return the rack for which an endpoint resides in
getRandomToken() - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
getRandomToken() - Method in interface org.apache.cassandra.dht.IPartitioner
 
getRandomToken() - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
getRandomToken() - Method in class org.apache.cassandra.dht.RandomPartitioner
 
getRangeAddresses(TokenMetadata, String) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
getRangeBatchSize(Configuration) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
The number of rows to request with each get range slices request.
getRangeOperations() - Method in class org.apache.cassandra.service.StorageProxy
 
getRangeOperations() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getRangeSlice(byte[], AbstractBounds, int, SliceRange, List<byte[]>) - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getRangeSlice(RangeSliceCommand, ConsistencyLevel) - Static method in class org.apache.cassandra.service.StorageProxy
 
getRangeToAddressMap(String) - Method in class org.apache.cassandra.service.StorageService
 
getRangeToEndPointMap(String) - Method in class org.apache.cassandra.service.StorageService
for a keyspace, return the ranges and corresponding hosts for a given keyspace.
getRangeToEndPointMap(String) - Method in interface org.apache.cassandra.service.StorageServiceMBean
Retrieve a map of range to end points that describe the ring topology of a Cassandra cluster.
getRangeToEndPointMap(String) - Method in class org.apache.cassandra.tools.NodeProbe
 
getRawCachedRow(String) - Method in class org.apache.cassandra.db.ColumnFamilyStore
raw cached row -- does not fetch the row if it is not present.
getReadCount() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getReadCount() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getReadOperations() - Method in class org.apache.cassandra.service.StorageProxy
 
getReadOperations() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getRecentHitRate() - Method in class org.apache.cassandra.cache.InstrumentedCache
 
getRecentHitRate() - Method in interface org.apache.cassandra.cache.JMXInstrumentedCacheMBean
hits / requests since the last time getHitRate was called.
getRecentLatencyHistogramMicros() - Method in class org.apache.cassandra.utils.LatencyTracker
 
getRecentLatencyMicros() - Method in class org.apache.cassandra.utils.LatencyTracker
returns microseconds
getRecentRangeLatencyMicros() - Method in class org.apache.cassandra.service.StorageProxy
 
getRecentRangeLatencyMicros() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getRecentReadLatencyHistogramMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getRecentReadLatencyHistogramMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getRecentReadLatencyMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getRecentReadLatencyMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getRecentReadLatencyMicros() - Method in class org.apache.cassandra.service.StorageProxy
 
getRecentReadLatencyMicros() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getRecentWriteLatencyHistogramMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getRecentWriteLatencyHistogramMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getRecentWriteLatencyMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getRecentWriteLatencyMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getRecentWriteLatencyMicros() - Method in class org.apache.cassandra.service.StorageProxy
 
getRecentWriteLatencyMicros() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getReduced() - Method in class org.apache.cassandra.io.CompactionIterator
 
getReduced() - Method in class org.apache.cassandra.utils.ReducingIterator
return the last object computed by reduce
getRegisteredCallback(String) - Static method in class org.apache.cassandra.net.MessagingService
 
getReplicaPlacementStrategyClass(String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getReplicationFactor(String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getReplicationStrategy(String) - Method in class org.apache.cassandra.service.StorageService
 
getReplicationStrategy(TokenMetadata, String) - Static method in class org.apache.cassandra.service.StorageService
 
getReply(Message) - Method in class org.apache.cassandra.db.RangeSliceReply
 
getReply(InetAddress, byte[]) - Method in class org.apache.cassandra.net.Message
 
getRequestedNodeList(String) - Method in class org.apache.cassandra.utils.XMLUtils
 
getRequests() - Method in class org.apache.cassandra.cache.InstrumentedCache
 
getRequests() - Method in interface org.apache.cassandra.cache.JMXInstrumentedCacheMBean
total request count since cache creation
getReverseComparator() - Method in class org.apache.cassandra.db.marshal.AbstractType
 
getRow(Table) - Method in class org.apache.cassandra.db.ReadCommand
 
getRow(Table) - Method in class org.apache.cassandra.db.SliceByNamesReadCommand
 
getRow(Table) - Method in class org.apache.cassandra.db.SliceFromReadCommand
 
getRow(QueryFilter) - Method in class org.apache.cassandra.db.Table
 
getRowCache() - Method in class org.apache.cassandra.io.SSTableTracker
 
getRowCacheMBean(String, String) - Method in class org.apache.cassandra.tools.NodeProbe
 
getRowMutation(String, String, Map<String, List<ColumnOrSuperColumn>>) - Static method in class org.apache.cassandra.db.RowMutation
 
getRowMutation() - Method in class org.apache.cassandra.db.RowMutationMessage
 
getRowMutationFromMutations(String, String, Map<String, List<Mutation>>) - Static method in class org.apache.cassandra.db.RowMutation
 
getRowsCachedFor(String, String, long) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getRowWarningThreshold() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getRpcTimeout() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getScanner(int) - Method in class org.apache.cassandra.io.SSTableReader
 
getScanners() - Method in class org.apache.cassandra.io.CompactionIterator
 
getSeeds() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getSegment() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment.CommitLogContext
 
getSegmentCount() - Method in class org.apache.cassandra.db.commitlog.CommitLog
 
getSerializedBuffer() - Method in class org.apache.cassandra.db.RowMutation
 
getSize() - Method in class org.apache.cassandra.cache.InstrumentedCache
 
getSize() - Method in interface org.apache.cassandra.cache.JMXInstrumentedCacheMBean
 
getSlicedReadBufferSizeInKB() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getSliceIterator(ColumnFamily, SliceQueryFilter, AbstractType) - Method in class org.apache.cassandra.db.Memtable
obtain an iterator of columns in this memtable in the specified order starting from a given column.
getSlicePredicate(Configuration) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
 
getSnapshotPath(String, String, String) - Static method in class org.apache.cassandra.db.Table
 
getSortedApplicationStates() - Method in class org.apache.cassandra.gms.EndPointState
 
getSortedColumns() - Method in class org.apache.cassandra.db.ColumnFamily
 
getSortedListByProximity(InetAddress, Collection<InetAddress>) - Method in class org.apache.cassandra.locator.AbstractEndpointSnitch
 
getSortedListByProximity(InetAddress, Collection<InetAddress>) - Method in interface org.apache.cassandra.locator.IEndPointSnitch
returns a new List sorted by proximity to the given endpoint
getSpannedDataPosition(IndexSummary.KeyPosition) - Method in class org.apache.cassandra.io.IndexSummary
 
getSpannedDataPosition(long) - Method in class org.apache.cassandra.io.IndexSummary
 
getSpannedIndexDataPositions() - Method in class org.apache.cassandra.io.IndexSummary
 
getSpannedIndexPosition(long) - Method in class org.apache.cassandra.io.IndexSummary
 
getSplits(JobContext) - Method in class org.apache.cassandra.hadoop.ColumnFamilyInputFormat
 
getSplits(Range, int) - Method in class org.apache.cassandra.service.StorageService
 
getSSTableColumnIterator(SSTableReader) - Method in class org.apache.cassandra.db.filter.NamesQueryFilter
 
getSSTableColumnIterator(SSTableReader) - Method in class org.apache.cassandra.db.filter.QueryFilter
returns an iterator that returns columns from the given SSTable matching the Filter criteria in sorted order.
getSSTableColumnIterator(SSTableReader) - Method in class org.apache.cassandra.db.filter.SliceQueryFilter
 
getSSTables() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getSSTables() - Method in class org.apache.cassandra.io.SSTableTracker
 
getStage(String) - Static method in class org.apache.cassandra.concurrent.StageManager
Retrieve a stage from the StageManager
getStageQueueSize() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getStartToken() - Method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
getStatus() - Method in class org.apache.cassandra.streaming.StreamingService
 
getStatus() - Method in interface org.apache.cassandra.streaming.StreamingServiceMBean
What's currently happening wrt streaming.
getStoragePort() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getStreamDestinations() - Method in class org.apache.cassandra.streaming.StreamingService
hosts receiving outgoing streams.
getStreamDestinations() - Method in interface org.apache.cassandra.streaming.StreamingServiceMBean
hosts recieving outgoing streams
getStreamDestinations() - Method in class org.apache.cassandra.tools.NodeProbe
 
getStreamSources() - Method in class org.apache.cassandra.streaming.StreamingService
hosts sending incoming streams
getStreamSources() - Method in interface org.apache.cassandra.streaming.StreamingServiceMBean
hosts sending incoming streams.
getStreamSources() - Method in class org.apache.cassandra.tools.NodeProbe
 
getString(AbstractType) - Method in class org.apache.cassandra.db.Column
 
getString(AbstractType) - Method in interface org.apache.cassandra.db.IColumn
 
getString(byte[]) - Method in class org.apache.cassandra.db.marshal.AbstractType
get a string representation of the bytes suitable for log messages
getString(Collection<byte[]>) - Method in class org.apache.cassandra.db.marshal.AbstractType
convenience method
getString(byte[]) - Method in class org.apache.cassandra.db.marshal.AsciiType
 
getString(byte[]) - Method in class org.apache.cassandra.db.marshal.BytesType
 
getString(byte[]) - Method in class org.apache.cassandra.db.marshal.LexicalUUIDType
 
getString(byte[]) - Method in class org.apache.cassandra.db.marshal.LongType
 
getString(byte[]) - Method in class org.apache.cassandra.db.marshal.TimeUUIDType
 
getString(byte[]) - Method in class org.apache.cassandra.db.marshal.UTF8Type
 
getString(AbstractType) - Method in class org.apache.cassandra.db.SuperColumn
 
getStringEndpointMap() - Method in class org.apache.cassandra.service.StorageService
 
getSubColumn(byte[]) - Method in class org.apache.cassandra.db.Column
 
getSubColumn(byte[]) - Method in interface org.apache.cassandra.db.IColumn
 
getSubColumn(byte[]) - Method in class org.apache.cassandra.db.SuperColumn
 
getSubColumns() - Method in class org.apache.cassandra.db.Column
 
getSubColumns() - Method in interface org.apache.cassandra.db.IColumn
 
getSubColumns() - Method in class org.apache.cassandra.db.SuperColumn
 
getSubComparator(String, String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getSuccessor(Token) - Method in class org.apache.cassandra.locator.TokenMetadata
 
getSuccessor(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
getSuccessor(InetAddress) - Method in class org.apache.cassandra.service.StorageService
 
getTable() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getTable() - Method in class org.apache.cassandra.db.RowMutation
 
getTableMetaData(String) - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getTableName(CommonTree) - Static method in class org.apache.cassandra.cli.CliCompiler
 
getTableName() - Method in class org.apache.cassandra.io.SSTable
 
getTables() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getTempSSTableFileName() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getThreadPoolMBeanProxies() - Method in class org.apache.cassandra.tools.NodeProbe
 
getThriftAddress() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getThriftPort() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
getToken() - Method in class org.apache.cassandra.db.SystemTable.StorageMetadata
 
getToken(String) - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
getToken(String) - Method in interface org.apache.cassandra.dht.IPartitioner
 
getToken(String) - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
getToken(String) - Method in class org.apache.cassandra.dht.RandomPartitioner
 
getToken(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
getToken() - Method in class org.apache.cassandra.service.StorageService
 
getToken() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Fetch a string representation of the token.
getToken() - Method in class org.apache.cassandra.tools.NodeProbe
 
getTokenFactory() - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
getTokenFactory() - Method in interface org.apache.cassandra.dht.IPartitioner
 
getTokenFactory() - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
getTokenFactory() - Method in class org.apache.cassandra.dht.RandomPartitioner
 
getTokenMetadata() - Method in class org.apache.cassandra.service.StorageService
 
getTotalBytes() - Method in class org.apache.cassandra.io.CompactionIterator
 
getTotalBytes(Iterable<SSTableReader>) - Static method in class org.apache.cassandra.io.SSTable
 
getTotalDiskSpaceUsed() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getTotalDiskSpaceUsed() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getTotalLatencyHistogramMicros() - Method in class org.apache.cassandra.utils.LatencyTracker
 
getTotalLatencyMicros() - Method in class org.apache.cassandra.utils.LatencyTracker
returns microseconds
getTotalRangeLatencyMicros() - Method in class org.apache.cassandra.service.StorageProxy
 
getTotalRangeLatencyMicros() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getTotalReadLatencyMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getTotalReadLatencyMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getTotalReadLatencyMicros() - Method in class org.apache.cassandra.service.StorageProxy
 
getTotalReadLatencyMicros() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getTotalSize() - Method in class org.apache.cassandra.io.SSTableTracker
 
getTotalWriteLatencyMicros() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getTotalWriteLatencyMicros() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getTotalWriteLatencyMicros() - Method in class org.apache.cassandra.service.StorageProxy
 
getTotalWriteLatencyMicros() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getUnreachableMembers() - Method in class org.apache.cassandra.gms.Gossiper
 
getUnreachableNodes() - Method in class org.apache.cassandra.service.StorageService
 
getUnreachableNodes() - Method in interface org.apache.cassandra.service.StorageServiceMBean
Retrieve the list of unreachable nodes in the cluster, as determined by this node's failure detector.
getUnreachableNodes() - Method in class org.apache.cassandra.tools.NodeProbe
 
getUptime() - Method in class org.apache.cassandra.tools.NodeProbe
 
getUsedDiskSpaceForPath(String) - Static method in class org.apache.cassandra.io.util.FileUtils
calculate the total space used by a file or directory
getValidator(String, String, InetAddress, boolean) - Method in class org.apache.cassandra.service.AntiEntropyService
Return a Validator object which can be used to collect hashes for a column family.
getValidColumnFamilies(String, String...) - Method in class org.apache.cassandra.service.StorageService
 
getValue() - Method in class org.apache.cassandra.gms.ApplicationState
 
getVerb() - Method in class org.apache.cassandra.net.Message
 
getVerbHandler(StorageService.Verb) - Method in class org.apache.cassandra.net.MessagingService
This method returns the verb handler associated with the registered verb.
getWriteCount() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
getWriteCount() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
 
getWriteEndpoints(Token, String, Collection<InetAddress>) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
write endpoints may be different from read endpoints, because read endpoints only need care about the "natural" nodes for a token, but write endpoints also need to account for nodes that are bootstrapping into the ring, and write data there too so that they stay up to date during the bootstrap process.
getWriteOperations() - Method in class org.apache.cassandra.service.StorageProxy
 
getWriteOperations() - Method in interface org.apache.cassandra.service.StorageProxyMBean
 
getWriteResponseHandler(int, ConsistencyLevel, String) - Method in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
getWriteResponseHandler(int, ConsistencyLevel, String) - Method in class org.apache.cassandra.locator.DatacenterShardStategy
This method will generate the QRH object and returns.
getWriteResponseHandler(int, ConsistencyLevel, String) - Method in class org.apache.cassandra.service.StorageService
 
GOSSIP_STAGE - Static variable in class org.apache.cassandra.concurrent.StageManager
 
GossipDigest - Class in org.apache.cassandra.gms
Contains information about a specified list of EndPoints and the largest version of the state they have generated as known by the local endpoint.
Gossiper - Class in org.apache.cassandra.gms
This module is responsible for Gossiping information for the local endpoint.
Gossiper.GossipDigestAck2VerbHandler - Class in org.apache.cassandra.gms
 
Gossiper.GossipDigestAck2VerbHandler() - Constructor for class org.apache.cassandra.gms.Gossiper.GossipDigestAck2VerbHandler
 
Gossiper.GossipDigestAckVerbHandler - Class in org.apache.cassandra.gms
 
Gossiper.GossipDigestAckVerbHandler() - Constructor for class org.apache.cassandra.gms.Gossiper.GossipDigestAckVerbHandler
 
Gossiper.GossipDigestSynVerbHandler - Class in org.apache.cassandra.gms
 
Gossiper.GossipDigestSynVerbHandler() - Constructor for class org.apache.cassandra.gms.Gossiper.GossipDigestSynVerbHandler
 
Gossiper.JoinVerbHandler - Class in org.apache.cassandra.gms
 
Gossiper.JoinVerbHandler() - Constructor for class org.apache.cassandra.gms.Gossiper.JoinVerbHandler
 
guid() - Static method in class org.apache.cassandra.utils.GuidGenerator
 
guidAsBytes() - Static method in class org.apache.cassandra.utils.GuidGenerator
 
GuidGenerator - Class in org.apache.cassandra.utils
 
GuidGenerator() - Constructor for class org.apache.cassandra.utils.GuidGenerator
 
guidToString(byte[]) - Static method in class org.apache.cassandra.utils.GuidGenerator
 

H

handleMessage(Message) - Method in interface org.apache.cassandra.net.sink.IMessageSink
 
hash(String, byte[]) - Method in class org.apache.cassandra.net.MessagingService
 
hash(String) - Static method in class org.apache.cassandra.utils.FBUtilities
 
hash(String, byte[]...) - Static method in class org.apache.cassandra.utils.FBUtilities
 
hash(Range) - Method in class org.apache.cassandra.utils.MerkleTree
Hash the given range in the tree.
hash - Variable in class org.apache.cassandra.utils.MerkleTree.RowHash
 
hash(byte[]) - Method in class org.apache.cassandra.utils.MerkleTree.TreeRange
 
hash() - Method in class org.apache.cassandra.utils.MerkleTree.TreeRange
 
hash(byte[], int, int) - Method in class org.apache.cassandra.utils.MurmurHash
 
hashCode() - Method in class org.apache.cassandra.db.ColumnFamily
 
hashCode() - Method in class org.apache.cassandra.db.DecoratedKey
 
hashCode() - Method in class org.apache.cassandra.dht.AbstractBounds
 
hashCode() - Method in class org.apache.cassandra.dht.BytesToken
 
hashCode() - Method in class org.apache.cassandra.dht.Token
 
hashCode() - Method in class org.apache.cassandra.utils.Pair
 
hashdepth - Variable in class org.apache.cassandra.utils.MerkleTree
 
hasNext() - Method in class org.apache.cassandra.io.SSTableScanner
 
hasNext() - Method in class org.apache.cassandra.utils.DestructivePQIterator
 
hasUnreclaimedSpace() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
Header - Class in org.apache.cassandra.net
 
HeaderTypes - Class in org.apache.cassandra.net
 
HeaderTypes() - Constructor for class org.apache.cassandra.net.HeaderTypes
 
hexToBytes(String) - Static method in class org.apache.cassandra.utils.FBUtilities
 
HINT - Static variable in class org.apache.cassandra.db.RowMutation
 
hint_ - Static variable in class org.apache.cassandra.db.RowMutationMessage
 
hintedHandoffEnabled() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
HintedHandOffManager - Class in org.apache.cassandra.db
For each table (keyspace), there is a row in the system hints CF.
HintedHandOffManager() - Constructor for class org.apache.cassandra.db.HintedHandOffManager
 
HINTS_CF - Static variable in class org.apache.cassandra.db.HintedHandOffManager
 
HISTORYFILE - Static variable in class org.apache.cassandra.cli.CliMain
 
hostName - Variable in class org.apache.cassandra.cli.CliSessionState
 

I

IAggregatableCacheProvider<K,V> - Interface in org.apache.cassandra.cache
 
IAsyncCallback - Interface in org.apache.cassandra.net
implementors of IAsyncCallback need to make sure that any public methods are threadsafe with respect to response() being called from the message service.
IAsyncResult - Interface in org.apache.cassandra.net
 
IAuthenticator - Interface in org.apache.cassandra.auth
 
ICacheExpungeHook<K,V> - Interface in org.apache.cassandra.cache
 
IColumn - Interface in org.apache.cassandra.db
 
IColumnContainer - Interface in org.apache.cassandra.db
 
ICommitLogExecutorService - Interface in org.apache.cassandra.db.commitlog
Like ExecutorService, but customized for batch and periodic commitlog execution.
ICompactSerializer<T> - Interface in org.apache.cassandra.io
Allows for the controlled serialization/deserialization of a given type.
ICompactSerializer2<T> - Interface in org.apache.cassandra.io
 
id - Variable in class org.apache.cassandra.concurrent.NamedThreadFactory
 
IdentityQueryFilter - Class in org.apache.cassandra.db.filter
 
IdentityQueryFilter(String, QueryPath) - Constructor for class org.apache.cassandra.db.filter.IdentityQueryFilter
Only for use in testing; will read entire CF into memory.
IEndPointSnitch - Interface in org.apache.cassandra.locator
This interface helps determine location of node in the data center relative to another node.
IEndPointStateChangePublisher - Interface in org.apache.cassandra.gms
This is implemented by the Gossiper module to publish change events to interested parties.
IEndPointStateChangeSubscriber - Interface in org.apache.cassandra.gms
This is called by an instance of the IEndPointStateChangePublisher to notify interested parties about changes in the the state associated with any endpoint.
IExecutorMBean - Interface in org.apache.cassandra.concurrent
 
IFailureDetectionEventListener - Interface in org.apache.cassandra.gms
Implemented by the Gossiper to convict an endpoint based on the PHI calculated by the Failure Detector on the inter-arrival times of the heart beats.
IFailureDetector - Interface in org.apache.cassandra.gms
An interface that provides an application with the ability to query liveness information of a node in the cluster.
IFailureNotification - Interface in org.apache.cassandra.gms
 
IFlushable - Interface in org.apache.cassandra.db
 
IMessageSink - Interface in org.apache.cassandra.net.sink
 
importJson(String, String, String, String) - Static method in class org.apache.cassandra.tools.SSTableImport
Convert a JSON formatted file to an SSTable.
in - Variable in class org.apache.cassandra.cli.CliSessionState
 
IncomingStreamReader - Class in org.apache.cassandra.streaming
 
IncomingStreamReader(SocketChannel) - Constructor for class org.apache.cassandra.streaming.IncomingStreamReader
 
IncomingTcpConnection - Class in org.apache.cassandra.net
 
IncomingTcpConnection(Socket) - Constructor for class org.apache.cassandra.net.IncomingTcpConnection
 
INDEX_INTERVAL - Static variable in class org.apache.cassandra.io.IndexSummary
Every 128th index entry is loaded into memory so we know where to start looking for the actual key w/o seeking
indexFilename(String) - Static method in class org.apache.cassandra.io.SSTable
 
indexFilename() - Method in class org.apache.cassandra.io.SSTable
 
indexFor(byte[], List<IndexHelper.IndexInfo>, AbstractType, boolean) - Static method in class org.apache.cassandra.io.IndexHelper
the index of the IndexInfo in which @name will be found.
IndexHelper - Class in org.apache.cassandra.io
Provides helper to serialize, deserialize and use column indexes.
IndexHelper() - Constructor for class org.apache.cassandra.io.IndexHelper
 
IndexHelper.IndexInfo - Class in org.apache.cassandra.io
 
IndexHelper.IndexInfo(byte[], byte[], long, long) - Constructor for class org.apache.cassandra.io.IndexHelper.IndexInfo
 
indexInterval() - Static method in class org.apache.cassandra.io.SSTableReader
 
indexPosition - Variable in class org.apache.cassandra.io.IndexSummary.KeyPosition
 
IndexSummary - Class in org.apache.cassandra.io
 
IndexSummary() - Constructor for class org.apache.cassandra.io.IndexSummary
 
indexSummary - Variable in class org.apache.cassandra.io.SSTable
 
IndexSummary.KeyPosition - Class in org.apache.cassandra.io
This is a simple container for the index Key and its corresponding position in the index file.
IndexSummary.KeyPosition(DecoratedKey, long) - Constructor for class org.apache.cassandra.io.IndexSummary.KeyPosition
 
init() - Method in class org.apache.cassandra.service.EmbeddedCassandraService
 
init(String[]) - Method in class org.apache.cassandra.thrift.CassandraDaemon
hook for JSVC
init() - Method in class org.apache.cassandra.utils.MerkleTree
Initializes this tree by splitting it until hashdepth is reached, or until an additional level of splits would violate maxsize.
initClient() - Method in class org.apache.cassandra.service.StorageService
 
initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.cassandra.hadoop.ColumnFamilyRecordReader
 
initMetadata() - Static method in class org.apache.cassandra.db.SystemTable
 
initServer() - Method in class org.apache.cassandra.service.StorageService
 
insert(Utf8, Utf8, ColumnPath, ByteBuffer, long, ConsistencyLevel) - Method in class org.apache.cassandra.avro.CassandraServer
 
insert(String, String, ColumnPath, byte[], long, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
instance() - Static method in class org.apache.cassandra.db.commitlog.CommitLog
 
instance - Static variable in class org.apache.cassandra.db.CompactionManager
 
instance - Static variable in class org.apache.cassandra.db.HintedHandOffManager
 
instance(String) - Static method in class org.apache.cassandra.db.Table.TableMetadata
 
instance - Static variable in class org.apache.cassandra.gms.FailureDetector
 
instance - Static variable in class org.apache.cassandra.gms.Gossiper
 
instance - Static variable in class org.apache.cassandra.net.MessagingService
 
instance - Static variable in class org.apache.cassandra.service.AntiEntropyService
 
instance - Static variable in class org.apache.cassandra.service.GCInspector
 
instance - Static variable in class org.apache.cassandra.service.StorageLoadBalancer
 
instance - Static variable in class org.apache.cassandra.service.StorageService
 
instance - Static variable in class org.apache.cassandra.streaming.StreamingService
 
InstrumentedCache<K,V> - Class in org.apache.cassandra.cache
 
InstrumentedCache(int) - Constructor for class org.apache.cassandra.cache.InstrumentedCache
 
interpret(InetAddress) - Method in class org.apache.cassandra.gms.FailureDetector
 
interpret(InetAddress) - Method in interface org.apache.cassandra.gms.IFailureDetector
This method is invoked by any entity wanting to interrogate the status of an endpoint.
intersectionWith(Range) - Method in class org.apache.cassandra.dht.Range
 
intersects(Range) - Method in class org.apache.cassandra.dht.Range
 
intervalInMillis_ - Static variable in class org.apache.cassandra.gms.Gossiper
 
intToByte(int) - Static method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
 
invalidate(Token) - Method in class org.apache.cassandra.utils.MerkleTree
Invalidates the ranges containing the given token.
invalidateRowCache() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
invalidateRowCache() - Method in interface org.apache.cassandra.db.ColumnFamilyStoreMBean
invalidate the row cache; for use after bulk loading via BinaryMemtable
invalids(Range) - Method in class org.apache.cassandra.utils.MerkleTree
Returns a lazy iterator of invalid TreeRanges that need to be filled in order to make the given Range valid.
invokeAll(Collection<? extends Callable<T>>) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Executes the given tasks, returning a list of Futures holding their status and results when all complete.
invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Executes the given tasks, returning a list of Futures holding their status and results when all complete or the timeout expires, whichever happens first.
invokeAny(Collection<? extends Callable<T>>) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do.
invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do before the given timeout elapses.
IPartitioner<T extends Token> - Interface in org.apache.cassandra.dht
 
IResponseResolver<T> - Interface in org.apache.cassandra.service
 
isAlive() - Method in class org.apache.cassandra.gms.EndPointState
 
isAlive(InetAddress) - Method in class org.apache.cassandra.gms.FailureDetector
 
isAlive(InetAddress) - Method in interface org.apache.cassandra.gms.IFailureDetector
Failure Detector's knowledge of whether a node is up or down.
isAutoBootstrap() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
isBootstrapMode() - Method in class org.apache.cassandra.service.StorageService
 
isBootstrapped() - Static method in class org.apache.cassandra.db.SystemTable
 
isCapacityModified() - Method in class org.apache.cassandra.cache.InstrumentedCache
 
isClean() - Method in class org.apache.cassandra.db.BinaryMemtable
 
isClean() - Method in class org.apache.cassandra.db.Memtable
 
isClientMode() - Method in class org.apache.cassandra.service.StorageService
 
isCompressed_ - Variable in class org.apache.cassandra.net.ProtocolHeader
 
isConnected() - Static method in class org.apache.cassandra.cli.CliMain
Checks whether the thrift client is connected.
isDataPresent(Collection<Message>) - Method in interface org.apache.cassandra.service.IResponseResolver
 
isDataPresent(Collection<Message>) - Method in class org.apache.cassandra.service.RangeSliceResponseResolver
 
isDataPresent(Collection<Message>) - Method in class org.apache.cassandra.service.ReadResponseResolver
 
isDigestQuery() - Method in class org.apache.cassandra.db.ReadCommand
 
isDigestQuery() - Method in class org.apache.cassandra.db.ReadResponse
 
isDone() - Method in interface org.apache.cassandra.net.IAsyncResult
This is used to check if the task has been completed
isEmpty() - Method in class org.apache.cassandra.db.DecoratedKey
 
isEmpty() - Method in class org.apache.cassandra.db.RowMutation
 
isEmpty() - Method in class org.apache.cassandra.db.Table.TableMetadata
 
isEmpty() - Method in class org.apache.cassandra.utils.ExpiringMap
 
isEOF() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
isEOF() - Method in interface org.apache.cassandra.io.util.FileDataInput
 
isEOF() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
isEqual(IteratingRow, IteratingRow) - Method in class org.apache.cassandra.io.CompactionIterator
 
isEqual(T1, T1) - Method in class org.apache.cassandra.utils.ReducingIterator
override this if the keys you want to base the reduce on are not the same as the object itself (but can be generated from it)
isExists(String) - Static method in class org.apache.cassandra.io.util.FileUtils
 
isExpired() - Method in class org.apache.cassandra.db.Memtable
 
isInitialized() - Static method in class org.apache.cassandra.net.sink.SinkManager
 
isInSameDataCenter(InetAddress, InetAddress) - Method in class org.apache.cassandra.locator.AbstractEndpointSnitch
Determines if 2 nodes are in the same data center.
isInSameDataCenter(InetAddress, InetAddress) - Method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
This methood will return ture if the hosts are in the same DC else false.
isInSameDataCenter(InetAddress, InetAddress) - Method in class org.apache.cassandra.locator.EndPointSnitch
 
isKnownEndpoint(InetAddress) - Method in class org.apache.cassandra.gms.Gossiper
 
isLeaving(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
isMarkedForDelete() - Method in class org.apache.cassandra.db.Column
 
isMarkedForDelete() - Method in class org.apache.cassandra.db.ColumnFamily
 
isMarkedForDelete() - Method in interface org.apache.cassandra.db.IColumn
 
isMarkedForDelete() - Method in interface org.apache.cassandra.db.IColumnContainer
 
isMarkedForDelete() - Method in class org.apache.cassandra.db.SuperColumn
 
isMember(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
isOnSameRack(InetAddress, InetAddress) - Method in class org.apache.cassandra.locator.AbstractEndpointSnitch
Determines if 2 nodes are in the same rack in the data center.
isOnSameRack(InetAddress, InetAddress) - Method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
This methood will return ture if the hosts are in the same RAC else false.
isOnSameRack(InetAddress, InetAddress) - Method in class org.apache.cassandra.locator.EndPointSnitch
 
isPresent(String) - Method in class org.apache.cassandra.utils.BloomFilter
 
isPresent(byte[]) - Method in class org.apache.cassandra.utils.BloomFilter
 
isPresent(String) - Method in class org.apache.cassandra.utils.Filter
 
isRelevant(IColumn, IColumnContainer, int) - Static method in class org.apache.cassandra.db.filter.QueryFilter
 
isShutdown() - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Returns true if this executor has been shut down.
isShutdown() - Method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
isSignaled() - Method in class org.apache.cassandra.utils.SimpleCondition
 
isSnapshotBeforeCompaction() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
isStreamingMode_ - Variable in class org.apache.cassandra.net.ProtocolHeader
 
isSuccess() - Method in class org.apache.cassandra.db.WriteResponse
 
isSuper() - Method in class org.apache.cassandra.db.ColumnFamily
 
isSuper() - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
isTerminated() - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Returns true if all tasks have completed following shut down.
isTerminated() - Method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
isThriftFramed() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
 
isTokenInRanges(Token, Iterable<Range>) - Static method in class org.apache.cassandra.dht.Range
 
isWrapAround(Token, Token) - Static method in class org.apache.cassandra.dht.Range
Tells if the given range is a wrap around.
isWrapAround() - Method in class org.apache.cassandra.dht.Range
 
IteratingRow - Class in org.apache.cassandra.io
 
IteratingRow(BufferedRandomAccessFile, SSTableReader) - Constructor for class org.apache.cassandra.io.IteratingRow
 
iterator() - Method in class org.apache.cassandra.io.SSTableTracker
 
iterator() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
iterator() - Method in class org.apache.cassandra.utils.BoundedStatsDeque
 
iterator() - Method in class org.apache.cassandra.utils.MerkleTree.TreeRangeIterator
 
iterator() - Method in class org.apache.cassandra.utils.ReducingIterator
 
IVerbHandler - Interface in org.apache.cassandra.net
IVerbHandler provides the method that all verb handlers need to implement.

J

JMXConfigurableThreadPoolExecutor - Class in org.apache.cassandra.concurrent
 
JMXConfigurableThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, NamedThreadFactory) - Constructor for class org.apache.cassandra.concurrent.JMXConfigurableThreadPoolExecutor
 
JMXConfigurableThreadPoolExecutorMBean - Interface in org.apache.cassandra.concurrent
 
JMXEnabledThreadPoolExecutor - Class in org.apache.cassandra.concurrent
This is a wrapper class for the ScheduledThreadPoolExecutor.
JMXEnabledThreadPoolExecutor(String) - Constructor for class org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
 
JMXEnabledThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, NamedThreadFactory) - Constructor for class org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
 
JMXEnabledThreadPoolExecutorMBean - Interface in org.apache.cassandra.concurrent
 
JMXInstrumentedCache<K,V> - Class in org.apache.cassandra.cache
 
JMXInstrumentedCache(String, String, int) - Constructor for class org.apache.cassandra.cache.JMXInstrumentedCache
 
JMXInstrumentedCacheMBean - Interface in org.apache.cassandra.cache
 

K

key - Variable in class org.apache.cassandra.db.DecoratedKey
 
key - Variable in class org.apache.cassandra.db.filter.QueryFilter
 
key - Variable in class org.apache.cassandra.db.ReadCommand
 
key - Variable in class org.apache.cassandra.db.Row
 
key() - Method in class org.apache.cassandra.db.RowMutation
 
key() - Method in class org.apache.cassandra.db.WriteResponse
 
key - Variable in class org.apache.cassandra.io.CompactionIterator.CompactedRow
 
key - Variable in class org.apache.cassandra.io.IndexSummary.KeyPosition
 
keyCacheSize - Variable in class org.apache.cassandra.config.CFMetaData
 
keySet() - Method in class org.apache.cassandra.utils.ExpiringMap
 
keyspace - Variable in class org.apache.cassandra.cli.CliSessionState
 
keyspace - Variable in class org.apache.cassandra.db.RangeSliceCommand
 
KeyspaceNotDefinedException - Exception in org.apache.cassandra.avro
 
KeyspaceNotDefinedException(Utf8) - Constructor for exception org.apache.cassandra.avro.KeyspaceNotDefinedException
 
KeyspaceNotDefinedException - Exception in org.apache.cassandra.db
 
KeyspaceNotDefinedException(String) - Constructor for exception org.apache.cassandra.db.KeyspaceNotDefinedException
 
KSMetaData - Class in org.apache.cassandra.config
 

L

LA(int) - Method in class org.apache.cassandra.cli.CliCompiler.ANTLRNoCaseStringStream
 
last - Variable in class org.apache.cassandra.utils.ReducingIterator
 
lastName - Variable in class org.apache.cassandra.io.IndexHelper.IndexInfo
 
LatencyTracker - Class in org.apache.cassandra.utils
 
LatencyTracker() - Constructor for class org.apache.cassandra.utils.LatencyTracker
 
left - Variable in class org.apache.cassandra.dht.AbstractBounds
 
left - Variable in class org.apache.cassandra.utils.Pair
 
LEFT_NORMALLY - Static variable in class org.apache.cassandra.service.StorageService
 
length() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
length() - Method in class org.apache.cassandra.io.SSTableReader
 
length() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
LexicalUUIDType - Class in org.apache.cassandra.db.marshal
 
LexicalUUIDType() - Constructor for class org.apache.cassandra.db.marshal.LexicalUUIDType
 
listen(InetAddress) - Method in class org.apache.cassandra.net.MessagingService
Listen on the specified port.
load(String[]) - Method in class org.apache.cassandra.avro.CassandraDaemon
hook for JSVC
loadBalance() - Method in class org.apache.cassandra.service.StorageService
 
loadBalance() - Method in interface org.apache.cassandra.service.StorageServiceMBean
This node will unload its data onto its neighbors, and bootstrap to share the range of the most-loaded node in the ring.
loadBalance() - Method in class org.apache.cassandra.tools.NodeProbe
 
local - Variable in class org.apache.cassandra.service.AntiEntropyService.Differencer
 
localResponse() - Method in class org.apache.cassandra.service.WriteResponseHandler
 
localResponses - Variable in class org.apache.cassandra.service.WriteResponseHandler
 
logger - Static variable in class org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor
 
logger - Static variable in class org.apache.cassandra.service.QuorumResponseHandler
 
logger - Static variable in class org.apache.cassandra.service.WriteResponseHandler
 
logger_ - Static variable in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
login(String, AuthenticationRequest) - Method in class org.apache.cassandra.auth.AllowAllAuthenticator
 
login(String, AuthenticationRequest) - Method in interface org.apache.cassandra.auth.IAuthenticator
 
login(String, AuthenticationRequest) - Method in class org.apache.cassandra.auth.SimpleAuthenticator
 
login(String, AuthenticationRequest) - Method in class org.apache.cassandra.thrift.CassandraServer
 
LongType - Class in org.apache.cassandra.db.marshal
 
LongType() - Constructor for class org.apache.cassandra.db.marshal.LongType
 
ltree - Variable in class org.apache.cassandra.service.AntiEntropyService.Differencer
 

M

main(String[]) - Static method in class org.apache.cassandra.avro.CassandraDaemon
 
main(String[]) - Static method in class org.apache.cassandra.cli.CliMain
 
main(String[]) - Static method in class org.apache.cassandra.gms.FailureDetector
 
main(String[]) - Static method in class org.apache.cassandra.thrift.CassandraDaemon
 
main(String[]) - Static method in class org.apache.cassandra.tools.ClusterCmd
 
main(String[]) - Static method in class org.apache.cassandra.tools.NodeCmd
 
main(String[]) - Static method in class org.apache.cassandra.tools.SSTableExport
Given arguments specifying an SSTable, and optionally an output file, export the contents of the SSTable to JSON.
main(String[]) - Static method in class org.apache.cassandra.tools.SSTableImport
Converts JSON to an SSTable file.
main(String[]) - Static method in class org.apache.cassandra.utils.XMLUtils
 
makeColumnFamily() - Method in class org.apache.cassandra.io.SSTableReader
 
makeReadMessage() - Method in class org.apache.cassandra.db.ReadCommand
 
makeRowMutationMessage() - Method in class org.apache.cassandra.db.RowMutation
 
makeRowMutationMessage(StorageService.Verb) - Method in class org.apache.cassandra.db.RowMutation
 
makeRowMutationMessage() - Method in class org.apache.cassandra.db.RowMutationMessage
 
makeRowMutationMessage(StorageService.Verb) - Method in class org.apache.cassandra.db.RowMutationMessage
 
makeWriteResponseMessage(Message, WriteResponse) - Static method in class org.apache.cassandra.db.WriteResponse
 
MappedFileDataInput - Class in org.apache.cassandra.io.util
 
MappedFileDataInput(MappedByteBuffer, String, long) - Constructor for class org.apache.cassandra.io.util.MappedFileDataInput
 
MappedFileDataInput(MappedByteBuffer, String, long, int) - Constructor for class org.apache.cassandra.io.util.MappedFileDataInput
 
mapToString(Map<?, ?>) - Static method in class org.apache.cassandra.utils.FBUtilities
 
mark() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
mark() - Method in interface org.apache.cassandra.io.util.FileDataInput
 
mark(int) - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
mark() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
markCompacted() - Method in class org.apache.cassandra.io.SSTableReader
 
markCompacted(Collection<SSTableReader>) - Method in class org.apache.cassandra.io.SSTableTracker
 
markForDeleteAt(int, long) - Method in class org.apache.cassandra.db.SuperColumn
Deprecated. 
markSupported() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
MarshalException - Exception in org.apache.cassandra.db.marshal
 
MarshalException(String) - Constructor for exception org.apache.cassandra.db.marshal.MarshalException
 
max_keys - Variable in class org.apache.cassandra.db.RangeSliceCommand
 
MAX_NAME_LENGTH - Static variable in interface org.apache.cassandra.db.IColumn
 
MAX_RETRIES - Static variable in class org.apache.cassandra.io.DeletionService
 
maxsize() - Method in class org.apache.cassandra.utils.MerkleTree
 
maxsize(long) - Method in class org.apache.cassandra.utils.MerkleTree
 
maybeAddEntry(DecoratedKey, long, long, long, long) - Method in class org.apache.cassandra.io.IndexSummary
 
maybeScheduleRepairs(ColumnFamily, String, String, List<ColumnFamily>, List<InetAddress>) - Static method in class org.apache.cassandra.service.ReadResponseResolver
For each row version, compare with resolved (the superset of all row versions); if it is missing anything, send a mutation to the endpoint it come from.
MBEAN_OBJECT_NAME - Static variable in class org.apache.cassandra.db.CompactionManager
 
MBEAN_OBJECT_NAME - Static variable in class org.apache.cassandra.streaming.StreamingService
 
mean() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
Memtable - Class in org.apache.cassandra.db
 
Memtable(ColumnFamilyStore) - Constructor for class org.apache.cassandra.db.Memtable
 
memtableKeyIterator(DecoratedKey) - Method in class org.apache.cassandra.db.ColumnFamilyStore
 
MerkleTree - Class in org.apache.cassandra.utils
A MerkleTree implemented as a binary tree.
MerkleTree(IPartitioner, byte, long) - Constructor for class org.apache.cassandra.utils.MerkleTree
 
MerkleTree.RowHash - Class in org.apache.cassandra.utils
Hash value representing a row, to be used to pass hashes to the MerkleTree.
MerkleTree.RowHash(Token, byte[]) - Constructor for class org.apache.cassandra.utils.MerkleTree.RowHash
 
MerkleTree.TreeRange - Class in org.apache.cassandra.utils
The public interface to a range in the tree.
MerkleTree.TreeRangeIterator - Class in org.apache.cassandra.utils
Performs a depth-first, inorder traversal of invalid nodes under the given root and intersecting the given range.
Message - Class in org.apache.cassandra.net
 
Message(InetAddress, String, StorageService.Verb, byte[]) - Constructor for class org.apache.cassandra.net.Message
 
MessageDeliveryTask - Class in org.apache.cassandra.net
 
MessageDeliveryTask(Message) - Constructor for class org.apache.cassandra.net.MessageDeliveryTask
 
MessagingService - Class in org.apache.cassandra.net
 
MessagingService() - Constructor for class org.apache.cassandra.net.MessagingService
 
midpoint(BytesToken, BytesToken) - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
midpoint(T, T) - Method in interface org.apache.cassandra.dht.IPartitioner
Calculate a Token representing the approximate "middle" of the given range.
midpoint(StringToken, StringToken) - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
midpoint(BigIntegerToken, BigIntegerToken) - Method in class org.apache.cassandra.dht.RandomPartitioner
 
midpoint(BigInteger, BigInteger, int) - Static method in class org.apache.cassandra.utils.FBUtilities
Given two bit arrays represented as BigIntegers, containing the given number of significant bits, calculate a midpoint.
MINIMUM - Static variable in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
MINIMUM - Static variable in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
MINIMUM - Static variable in class org.apache.cassandra.dht.RandomPartitioner
 
modifications_ - Variable in class org.apache.cassandra.db.RowMutation
 
mostRecentLiveChangeAt() - Method in class org.apache.cassandra.db.Column
 
mostRecentLiveChangeAt() - Method in interface org.apache.cassandra.db.IColumn
 
mostRecentLiveChangeAt() - Method in class org.apache.cassandra.db.SuperColumn
 
move(String) - Method in class org.apache.cassandra.service.StorageService
 
move(String) - Method in interface org.apache.cassandra.service.StorageServiceMBean
 
move(String) - Method in class org.apache.cassandra.tools.NodeProbe
 
MOVE_STATE - Static variable in class org.apache.cassandra.service.StorageService
 
multiget(String, List<String>, ColumnPath, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
always returns a ColumnOrSuperColumn for each key, even if there is no data for it
multiget_slice(String, List<String>, ColumnParent, SlicePredicate, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
MurmurHash - Class in org.apache.cassandra.utils
This is a very fast, non-cryptographic hash suitable for general hash-based lookup.
MurmurHash() - Constructor for class org.apache.cassandra.utils.MurmurHash
 
mutate(List<RowMutation>) - Static method in class org.apache.cassandra.service.StorageProxy
Use this method to have these RowMutations applied across all replicas.
mutateBlocking(List<RowMutation>, ConsistencyLevel) - Static method in class org.apache.cassandra.service.StorageProxy
 
MUTATION_STAGE - Static variable in class org.apache.cassandra.concurrent.StageManager
 

N

n - Variable in class org.apache.cassandra.concurrent.NamedThreadFactory
 
name - Variable in class org.apache.cassandra.config.KSMetaData
 
name() - Method in class org.apache.cassandra.db.Column
 
name() - Method in class org.apache.cassandra.db.ColumnFamily
 
name() - Method in interface org.apache.cassandra.db.IColumn
 
name() - Method in class org.apache.cassandra.db.SuperColumn
 
name - Variable in class org.apache.cassandra.db.Table
 
NamedThreadFactory - Class in org.apache.cassandra.concurrent
This class is an implementation of the ThreadFactory interface.
NamedThreadFactory(String) - Constructor for class org.apache.cassandra.concurrent.NamedThreadFactory
 
NamesQueryFilter - Class in org.apache.cassandra.db.filter
 
NamesQueryFilter(String, QueryPath, SortedSet<byte[]>) - Constructor for class org.apache.cassandra.db.filter.NamesQueryFilter
 
NamesQueryFilter(String, QueryPath, byte[]) - Constructor for class org.apache.cassandra.db.filter.NamesQueryFilter
 
NATURAL_REPAIR_FREQUENCY - Static variable in class org.apache.cassandra.service.AntiEntropyService
 
newThread(Runnable) - Method in class org.apache.cassandra.concurrent.NamedThreadFactory
 
next() - Method in class org.apache.cassandra.io.SSTableScanner
 
next() - Method in class org.apache.cassandra.utils.DestructivePQIterator
 
nextKeyValue() - Method in class org.apache.cassandra.hadoop.ColumnFamilyRecordReader
 
NodeCmd - Class in org.apache.cassandra.tools
 
NodeCmd(NodeProbe) - Constructor for class org.apache.cassandra.tools.NodeCmd
 
NodeProbe - Class in org.apache.cassandra.tools
JMX client operations for Cassandra.
NodeProbe(String, int) - Constructor for class org.apache.cassandra.tools.NodeProbe
Creates a NodeProbe using the specified JMX host and port.
NodeProbe(String) - Constructor for class org.apache.cassandra.tools.NodeProbe
Creates a NodeProbe using the specified JMX host and default port.
numColumnSpecifiers(CommonTree) - Static method in class org.apache.cassandra.cli.CliCompiler
 

O

offset - Variable in class org.apache.cassandra.io.IndexHelper.IndexInfo
 
onAlive(InetAddress, EndPointState) - Method in interface org.apache.cassandra.gms.IEndPointStateChangeSubscriber
 
onAlive(InetAddress, EndPointState) - Method in class org.apache.cassandra.service.StorageLoadBalancer
 
onAlive(InetAddress, EndPointState) - Method in class org.apache.cassandra.service.StorageService
 
onChange(InetAddress, String, ApplicationState) - Method in interface org.apache.cassandra.gms.IEndPointStateChangeSubscriber
 
onChange(InetAddress, String, ApplicationState) - Method in class org.apache.cassandra.service.StorageLoadBalancer
 
onChange(InetAddress, String, ApplicationState) - Method in class org.apache.cassandra.service.StorageService
 
onDead(InetAddress, EndPointState) - Method in interface org.apache.cassandra.gms.IEndPointStateChangeSubscriber
 
onDead(InetAddress, EndPointState) - Method in class org.apache.cassandra.service.StorageLoadBalancer
 
onDead(InetAddress, EndPointState) - Method in class org.apache.cassandra.service.StorageService
 
onJoin(InetAddress, EndPointState) - Method in interface org.apache.cassandra.gms.IEndPointStateChangeSubscriber
Use to inform interested parties about the change in the state for specified endpoint
onJoin(InetAddress, EndPointState) - Method in class org.apache.cassandra.service.StorageLoadBalancer
 
onJoin(InetAddress, EndPointState) - Method in class org.apache.cassandra.service.StorageService
 
open(String) - Static method in class org.apache.cassandra.db.Table
 
open(String) - Static method in class org.apache.cassandra.io.SSTableReader
 
open(String, IPartitioner) - Static method in class org.apache.cassandra.io.SSTableReader
public, but only for tests
ophf - Static variable in class org.apache.cassandra.config.DatabaseDescriptor
 
OrderPreservingPartitioner - Class in org.apache.cassandra.dht
 
OrderPreservingPartitioner() - Constructor for class org.apache.cassandra.dht.OrderPreservingPartitioner
 
org.apache.cassandra.auth - package org.apache.cassandra.auth
 
org.apache.cassandra.avro - package org.apache.cassandra.avro
 
org.apache.cassandra.cache - package org.apache.cassandra.cache
 
org.apache.cassandra.cli - package org.apache.cassandra.cli
 
org.apache.cassandra.client - package org.apache.cassandra.client
 
org.apache.cassandra.concurrent - package org.apache.cassandra.concurrent
 
org.apache.cassandra.config - package org.apache.cassandra.config
 
org.apache.cassandra.db - package org.apache.cassandra.db
 
org.apache.cassandra.db.commitlog - package org.apache.cassandra.db.commitlog
 
org.apache.cassandra.db.filter - package org.apache.cassandra.db.filter
 
org.apache.cassandra.db.marshal - package org.apache.cassandra.db.marshal
 
org.apache.cassandra.dht - package org.apache.cassandra.dht
 
org.apache.cassandra.gms - package org.apache.cassandra.gms
 
org.apache.cassandra.hadoop - package org.apache.cassandra.hadoop
 
org.apache.cassandra.io - package org.apache.cassandra.io
 
org.apache.cassandra.io.util - package org.apache.cassandra.io.util
 
org.apache.cassandra.locator - package org.apache.cassandra.locator
 
org.apache.cassandra.net - package org.apache.cassandra.net
 
org.apache.cassandra.net.io - package org.apache.cassandra.net.io
 
org.apache.cassandra.net.sink - package org.apache.cassandra.net.sink
 
org.apache.cassandra.service - package org.apache.cassandra.service
 
org.apache.cassandra.streaming - package org.apache.cassandra.streaming
 
org.apache.cassandra.thrift - package org.apache.cassandra.thrift
 
org.apache.cassandra.tools - package org.apache.cassandra.tools
 
org.apache.cassandra.utils - package org.apache.cassandra.utils
 
out - Variable in class org.apache.cassandra.cli.CliSessionState
 
OutboundTcpConnection - Class in org.apache.cassandra.net
 
OutboundTcpConnection(OutboundTcpConnectionPool, InetAddress) - Constructor for class org.apache.cassandra.net.OutboundTcpConnection
 

P

packIt(byte[], boolean) - Static method in class org.apache.cassandra.net.MessagingService
 
Pair<T1,T2> - Class in org.apache.cassandra.utils
 
Pair(T1, T2) - Constructor for class org.apache.cassandra.utils.Pair
 
parseColumnFamilyName(String) - Static method in class org.apache.cassandra.io.SSTable
 
parseDoubleOrPercent(String) - Static method in class org.apache.cassandra.utils.FBUtilities
Parses a string representing either a fraction, absolute value or percentage.
parseTableName(String) - Static method in class org.apache.cassandra.io.SSTable
 
PARTIALLY_INCONSISTENT - Static variable in class org.apache.cassandra.utils.MerkleTree
 
partitioner - Variable in class org.apache.cassandra.dht.AbstractBounds
 
partitioner - Variable in class org.apache.cassandra.io.SSTable
 
partitioner() - Method in class org.apache.cassandra.utils.MerkleTree
 
partitioner(IPartitioner) - Method in class org.apache.cassandra.utils.MerkleTree
TODO: Find another way to use the local partitioner after serialization.
PASSWD_FILENAME_PROPERTY - Static variable in class org.apache.cassandra.auth.SimpleAuthenticator
 
password - Variable in class org.apache.cassandra.cli.CliSessionState
 
PASSWORD_KEY - Static variable in class org.apache.cassandra.auth.SimpleAuthenticator
 
path - Variable in class org.apache.cassandra.db.filter.QueryFilter
 
path - Variable in class org.apache.cassandra.io.SSTable
 
path - Variable in class org.apache.cassandra.io.SSTableDeletingReference
 
pendingDestinations - Static variable in class org.apache.cassandra.streaming.StreamOutManager
 
pendingRangeChanges(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
PeriodicCommitLogExecutorServiceMBean - Interface in org.apache.cassandra.db.commitlog
 
PMODE_PROPERTY - Static variable in class org.apache.cassandra.auth.SimpleAuthenticator
 
position - Variable in class org.apache.cassandra.db.commitlog.CommitLogSegment.CommitLogContext
 
position - Variable in class org.apache.cassandra.io.SSTable.PositionSize
 
predicate - Variable in class org.apache.cassandra.db.RangeSliceCommand
 
prepare() - Method in interface org.apache.cassandra.service.AntiEntropyService.IValidator
 
prepare() - Method in class org.apache.cassandra.service.AntiEntropyService.NoopValidator
Does nothing.
prepare() - Method in class org.apache.cassandra.service.AntiEntropyService.Validator
 
preservesOrder() - Method in class org.apache.cassandra.dht.CollatingOrderPreservingPartitioner
 
preservesOrder() - Method in interface org.apache.cassandra.dht.IPartitioner
 
preservesOrder() - Method in class org.apache.cassandra.dht.OrderPreservingPartitioner
 
preservesOrder() - Method in class org.apache.cassandra.dht.RandomPartitioner
 
pretty() - Method in class org.apache.cassandra.config.CFMetaData
 
printColumnFamilyStats(PrintStream) - Method in class org.apache.cassandra.tools.NodeCmd
 
printEndPoints(String, String) - Method in class org.apache.cassandra.tools.ClusterCmd
 
printInfo(PrintStream) - Method in class org.apache.cassandra.tools.NodeCmd
Write node information.
printPendingRanges() - Method in class org.apache.cassandra.locator.TokenMetadata
 
printRing(PrintStream) - Method in class org.apache.cassandra.tools.NodeCmd
Write a textual representation of the Cassandra ring.
printRing(PrintStream) - Method in class org.apache.cassandra.tools.NodeProbe
Write a textual representation of the Cassandra ring.
printStreamInfo(InetAddress, PrintStream) - Method in class org.apache.cassandra.tools.NodeCmd
 
printThreadPoolStats(PrintStream) - Method in class org.apache.cassandra.tools.NodeCmd
 
processArgs(CliSessionState, String[]) - Method in class org.apache.cassandra.cli.CliOptions
 
processClientMessageSink(Message) - Static method in class org.apache.cassandra.net.sink.SinkManager
 
processServerMessageSink(Message) - Static method in class org.apache.cassandra.net.sink.SinkManager
 
PROMPT - Static variable in class org.apache.cassandra.cli.CliMain
 
PROTOCOL_MAGIC - Static variable in class org.apache.cassandra.net.MessagingService
we preface every message with this number so the recipient can validate the sender is sane
ProtocolHeader - Class in org.apache.cassandra.net
 
ProtocolHeader() - Constructor for class org.apache.cassandra.net.ProtocolHeader
 
put(K, V) - Method in class org.apache.cassandra.cache.InstrumentedCache
 
put(Object, Object) - Method in class org.apache.cassandra.concurrent.Context
 
put(K, V) - Method in class org.apache.cassandra.utils.ExpiringMap
 
put(K, V, ICacheExpungeHook<K, V>) - Method in class org.apache.cassandra.utils.ExpiringMap
 
putColumn(IColumn) - Method in class org.apache.cassandra.db.SuperColumn
 

Q

QueryFilter - Class in org.apache.cassandra.db.filter
 
QueryFilter(String, QueryPath) - Constructor for class org.apache.cassandra.db.filter.QueryFilter
 
QueryPath - Class in org.apache.cassandra.db.filter
 
QueryPath(String, byte[], byte[]) - Constructor for class org.apache.cassandra.db.filter.QueryPath
 
QueryPath(ColumnParent) - Constructor for class org.apache.cassandra.db.filter.QueryPath
 
QueryPath(String, byte[]) - Constructor for class org.apache.cassandra.db.filter.QueryPath
 
QueryPath(String) - Constructor for class org.apache.cassandra.db.filter.QueryPath
 
QueryPath(ColumnPath) - Constructor for class org.apache.cassandra.db.filter.QueryPath
 
queryPath - Variable in class org.apache.cassandra.db.ReadCommand
 
QuorumResponseHandler<T> - Class in org.apache.cassandra.service
 
QuorumResponseHandler(int, IResponseResolver<T>) - Constructor for class org.apache.cassandra.service.QuorumResponseHandler
 

R

RackAwareStrategy - Class in org.apache.cassandra.locator
 
RackAwareStrategy(TokenMetadata, IEndPointSnitch) - Constructor for class org.apache.cassandra.locator.RackAwareStrategy
 
RackUnawareStrategy - Class in org.apache.cassandra.locator
This class returns the nodes responsible for a given key but does not respect rack awareness.
RackUnawareStrategy(TokenMetadata, IEndPointSnitch) - Constructor for class org.apache.cassandra.locator.RackUnawareStrategy
 
random - Static variable in class org.apache.cassandra.config.DatabaseDescriptor
 
RandomPartitioner - Class in org.apache.cassandra.dht
This class generates a BigIntegerToken using MD5 hash.
RandomPartitioner() - Constructor for class org.apache.cassandra.dht.RandomPartitioner
 
range - Variable in class org.apache.cassandra.db.RangeSliceCommand
 
Range - Class in org.apache.cassandra.dht
A representation of the range that a node is responsible for on the DHT ring.
Range(Token, Token) - Constructor for class org.apache.cassandra.dht.Range
 
Range(Token, Token, IPartitioner) - Constructor for class org.apache.cassandra.dht.Range
 
rangeSet(Range...) - Static method in class org.apache.cassandra.dht.Range
 
RangeSliceCommand - Class in org.apache.cassandra.db
 
RangeSliceCommand(String, ColumnParent, SlicePredicate, AbstractBounds, int) - Constructor for class org.apache.cassandra.db.RangeSliceCommand
 
RangeSliceCommand(String, String, byte[], SlicePredicate, AbstractBounds, int) - Constructor for class org.apache.cassandra.db.RangeSliceCommand
 
RangeSliceReply - Class in org.apache.cassandra.db
 
RangeSliceReply(List<Row>) - Constructor for class org.apache.cassandra.db.RangeSliceReply
 
RangeSliceResponseResolver - Class in org.apache.cassandra.service
Turns RangeSliceReply objects into row (string -> CF) maps, resolving to the most recent ColumnFamily and setting up read repairs as necessary.
RangeSliceResponseResolver(String, List<InetAddress>) - Constructor for class org.apache.cassandra.service.RangeSliceResponseResolver
 
RangeSliceVerbHandler - Class in org.apache.cassandra.service
 
RangeSliceVerbHandler() - Constructor for class org.apache.cassandra.service.RangeSliceVerbHandler
 
read(Message) - Static method in class org.apache.cassandra.db.RangeSliceCommand
 
read(byte[]) - Static method in class org.apache.cassandra.db.RangeSliceReply
 
read(DataInput) - Static method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
read() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
read(byte[]) - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
read(byte[], int, int) - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
read() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
read() - Method in class org.apache.cassandra.streaming.IncomingStreamReader
 
READ_STAGE - Static variable in class org.apache.cassandra.concurrent.StageManager
 
readBoolean() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a boolean from the current position in this file.
readByte() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads an 8-bit byte from the current position in this file.
readChar() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a 16-bit character from the current position in this file.
readColumnFamily(List<ReadCommand>, ConsistencyLevel) - Method in class org.apache.cassandra.avro.CassandraServer
 
readColumnFamily(List<ReadCommand>, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
ReadCommand - Class in org.apache.cassandra.db
 
ReadCommand(String, String, QueryPath, byte) - Constructor for class org.apache.cassandra.db.ReadCommand
 
readDouble() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a 64-bit double from the current position in this file.
readFields(DataInput) - Method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
readFloat() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a 32-bit float from the current position in this file.
readFully(byte[]) - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads bytes from this file into buffer.
readFully(byte[], int, int) - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Read bytes from this file into buffer starting at offset offset.
readInt() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a 32-bit integer from the current position in this file.
readLine() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a line of text form the current position in this file.
readLong() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a 64-bit long from the current position in this file.
readName(DataInput) - Static method in class org.apache.cassandra.db.ColumnSerializer
 
readNullableString(DataInput) - Static method in class org.apache.cassandra.utils.FBUtilities
 
readProtocol(List<ReadCommand>, ConsistencyLevel) - Static method in class org.apache.cassandra.service.StorageProxy
Performs the actual reading of a row out of the StorageService, fetching a specific set of column names from a given column family.
ReadRepairVerbHandler - Class in org.apache.cassandra.db
 
ReadRepairVerbHandler() - Constructor for class org.apache.cassandra.db.ReadRepairVerbHandler
 
ReadResponse - Class in org.apache.cassandra.db
 
ReadResponse(byte[]) - Constructor for class org.apache.cassandra.db.ReadResponse
 
ReadResponse(Row) - Constructor for class org.apache.cassandra.db.ReadResponse
 
ReadResponseResolver - Class in org.apache.cassandra.service
Turns ReadResponse messages into Row objects, resolving to the most recent version and setting up read repairs as necessary.
ReadResponseResolver(String, int) - Constructor for class org.apache.cassandra.service.ReadResponseResolver
 
readShort() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a 16-bit short from the current position in this file.
readUnsignedByte() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads an unsigned 8-bit byte from the current position in this file and returns it as an integer.
readUnsignedShort() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads an unsigned 16-bit short from the current position in this file and returns it as an integer.
readUTF() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
Reads a string that is encoded in modified UTF-8 from this file.
ReadVerbHandler - Class in org.apache.cassandra.db
 
ReadVerbHandler() - Constructor for class org.apache.cassandra.db.ReadVerbHandler
 
ReadVerbHandler.ReadContext - Class in org.apache.cassandra.db
 
ReadVerbHandler.ReadContext() - Constructor for class org.apache.cassandra.db.ReadVerbHandler.ReadContext
 
receive(Message) - Static method in class org.apache.cassandra.net.MessagingService
 
RECOMMENDED_DEPTH - Static variable in class org.apache.cassandra.utils.MerkleTree
 
recover() - Static method in class org.apache.cassandra.db.commitlog.CommitLog
 
recover(File[]) - Static method in class org.apache.cassandra.db.commitlog.CommitLog
 
reduce(IteratingRow) - Method in class org.apache.cassandra.io.CompactionIterator
 
reduce(T1) - Method in class org.apache.cassandra.utils.ReducingIterator
combine this object with the previous ones.
ReducingIterator<T1,T2> - Class in org.apache.cassandra.utils
reduces equal values from the source iterator to a single (optionally transformed) instance.
ReducingIterator(Iterator<T1>) - Constructor for class org.apache.cassandra.utils.ReducingIterator
 
refreshEndPointMap() - Method in class org.apache.cassandra.client.RingCache
 
register(IEndPointStateChangeSubscriber) - Method in class org.apache.cassandra.gms.Gossiper
Register with the Gossiper for EndPointState notifications
register(IEndPointStateChangeSubscriber) - Method in interface org.apache.cassandra.gms.IEndPointStateChangePublisher
Register for interesting state changes.
registerFailureDetectionEventListener(IFailureDetectionEventListener) - Method in class org.apache.cassandra.gms.FailureDetector
 
registerFailureDetectionEventListener(IFailureDetectionEventListener) - Method in interface org.apache.cassandra.gms.IFailureDetector
Register interest for Failure Detector events.
registerMBean(Object) - Static method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
registerVerbHandlers(StorageService.Verb, IVerbHandler) - Method in class org.apache.cassandra.net.MessagingService
Register a verb and the corresponding verb handler with the Messaging Service.
reloadConfiguration() - Method in class org.apache.cassandra.locator.DatacenterEndPointSnitch
This method will load the configuration from the xml file.
remote - Variable in class org.apache.cassandra.service.AntiEntropyService.Differencer
 
remove(K) - Method in class org.apache.cassandra.cache.InstrumentedCache
 
remove(Object) - Method in class org.apache.cassandra.concurrent.Context
 
remove(byte[]) - Method in class org.apache.cassandra.db.ColumnFamily
 
remove() - Method in class org.apache.cassandra.db.filter.AbstractColumnIterator
 
remove(byte[]) - Method in class org.apache.cassandra.db.SuperColumn
 
remove(InetAddress) - Method in class org.apache.cassandra.gms.FailureDetector
 
remove(InetAddress) - Method in interface org.apache.cassandra.gms.IFailureDetector
remove endpoint from failure detector
remove() - Method in class org.apache.cassandra.io.SSTableScanner
 
remove(InetAddress) - Static method in class org.apache.cassandra.streaming.StreamOutManager
 
remove(String, String, ColumnPath, long, ConsistencyLevel) - Method in class org.apache.cassandra.thrift.CassandraServer
 
remove() - Method in class org.apache.cassandra.utils.DestructivePQIterator
 
remove(K) - Method in class org.apache.cassandra.utils.ExpiringMap
 
REMOVE_TOKEN - Static variable in class org.apache.cassandra.service.StorageService
 
removeBootstrapSource(InetAddress, String) - Method in class org.apache.cassandra.service.StorageService
 
removeBootstrapToken(Token) - Method in class org.apache.cassandra.locator.TokenMetadata
 
removeColumnFamily(ColumnFamily) - Method in class org.apache.cassandra.db.RowMutation
should only be called by commitlog replay code
removeDeleted(ColumnFamily, int) - Static method in class org.apache.cassandra.db.ColumnFamilyStore
 
removeEndPoint(InetAddress) - Method in class org.apache.cassandra.gms.Gossiper
Removes the endpoint completely from Gossip
removeEndpoint(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
removeLeavingEndPoint(InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
removeRegisteredCallback(String) - Static method in class org.apache.cassandra.net.MessagingService
 
removeToken(String) - Method in class org.apache.cassandra.service.StorageService
 
removeToken(String) - Method in interface org.apache.cassandra.service.StorageServiceMBean
removeToken removes token (and all data associated with enpoint that had it) from the ring
removeToken(String) - Method in class org.apache.cassandra.tools.NodeProbe
 
renameAndOpen(String) - Static method in class org.apache.cassandra.io.SSTableWriter
 
renameWithConfirm(String, String) - Static method in class org.apache.cassandra.utils.FBUtilities
 
replace(Collection<SSTableReader>, Iterable<SSTableReader>) - Method in class org.apache.cassandra.io.SSTableTracker
 
replicationFactor - Variable in class org.apache.cassandra.config.KSMetaData
 
report(InetAddress) - Method in class org.apache.cassandra.gms.FailureDetector
 
report(InetAddress) - Method in interface org.apache.cassandra.gms.IFailureDetector
This method is invoked by the receiver of the heartbeat.
repStratClass - Variable in class org.apache.cassandra.config.KSMetaData
 
requestGC() - Method in class org.apache.cassandra.service.StorageService
 
requestRanges(InetAddress, String, Collection<Range>) - Static method in class org.apache.cassandra.streaming.StreamIn
Request ranges to be transferred from source to local node
reset() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
reset() - Method in class org.apache.cassandra.io.util.DataOutputBuffer
Resets the buffer to empty.
reset() - Method in interface org.apache.cassandra.io.util.FileDataInput
 
reset() - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
resolve(ColumnFamily, ColumnFamily) - Static method in class org.apache.cassandra.db.ColumnFamily
 
resolve(ColumnFamily) - Method in class org.apache.cassandra.db.ColumnFamily
 
resolve(Collection<Message>) - Method in interface org.apache.cassandra.service.IResponseResolver
 
resolve(Collection<Message>) - Method in class org.apache.cassandra.service.RangeSliceResponseResolver
 
resolve(Collection<Message>) - Method in class org.apache.cassandra.service.ReadResponseResolver
 
response(Message) - Method in interface org.apache.cassandra.net.IAsyncCallback
 
response(Message) - Method in class org.apache.cassandra.service.DatacenterSyncWriteResponseHandler
 
response(Message) - Method in class org.apache.cassandra.service.DatacenterWriteResponseHandler
 
response(Message) - Method in class org.apache.cassandra.service.QuorumResponseHandler
 
response(Message) - Method in class org.apache.cassandra.service.WriteResponseHandler
 
RESPONSE_STAGE - Static variable in class org.apache.cassandra.concurrent.StageManager
 
responses - Variable in class org.apache.cassandra.service.QuorumResponseHandler
 
responses - Variable in class org.apache.cassandra.service.WriteResponseHandler
 
ResponseVerbHandler - Class in org.apache.cassandra.net
 
ResponseVerbHandler() - Constructor for class org.apache.cassandra.net.ResponseVerbHandler
 
restrictTo(Range) - Method in class org.apache.cassandra.dht.AbstractBounds
 
restrictTo(Range) - Method in class org.apache.cassandra.dht.Bounds
 
restrictTo(Range) - Method in class org.apache.cassandra.dht.Range
 
result(Message) - Method in interface org.apache.cassandra.net.IAsyncResult
Store the result obtained for the submitted task.
RETRY_DELAY - Static variable in class org.apache.cassandra.io.SSTableDeletingReference
 
reversed - Variable in class org.apache.cassandra.db.filter.SliceQueryFilter
 
reversed - Variable in class org.apache.cassandra.db.SliceFromReadCommand
 
revive(InetAddress) - Method in interface org.apache.cassandra.gms.IFailureNotification
 
right - Variable in class org.apache.cassandra.dht.AbstractBounds
 
right - Variable in class org.apache.cassandra.utils.Pair
 
RING_DELAY - Static variable in class org.apache.cassandra.service.StorageService
 
RingCache - Class in org.apache.cassandra.client
A class for caching the ring map at the client.
RingCache() - Constructor for class org.apache.cassandra.client.RingCache
 
ringIterator(List, Token) - Static method in class org.apache.cassandra.locator.TokenMetadata
iterator over the Tokens in the given ring, starting with the token for the node owning start (which does not have to be a Token in the ring)
row() - Method in class org.apache.cassandra.db.ReadResponse
 
Row - Class in org.apache.cassandra.db
 
Row(String, ColumnFamily) - Constructor for class org.apache.cassandra.db.Row
 
rowCacheSize - Variable in class org.apache.cassandra.config.CFMetaData
 
RowMutation - Class in org.apache.cassandra.db
 
RowMutation(String, String) - Constructor for class org.apache.cassandra.db.RowMutation
 
RowMutation(String, Row) - Constructor for class org.apache.cassandra.db.RowMutation
 
RowMutation(String, String, Map<String, ColumnFamily>) - Constructor for class org.apache.cassandra.db.RowMutation
 
RowMutationMessage - Class in org.apache.cassandra.db
 
RowMutationMessage(RowMutation) - Constructor for class org.apache.cassandra.db.RowMutationMessage
 
RowMutationVerbHandler - Class in org.apache.cassandra.db
 
RowMutationVerbHandler() - Constructor for class org.apache.cassandra.db.RowMutationVerbHandler
 
rows - Variable in class org.apache.cassandra.db.RangeSliceReply
 
rtree - Variable in class org.apache.cassandra.service.AntiEntropyService.Differencer
 
run() - Method in class org.apache.cassandra.net.IncomingTcpConnection
 
run() - Method in class org.apache.cassandra.net.MessageDeliveryTask
 
run() - Method in class org.apache.cassandra.net.OutboundTcpConnection
 
run() - Method in class org.apache.cassandra.service.AntiEntropyService.Differencer
Compares our trees, and triggers repairs for any ranges that mismatch.
run() - Method in class org.apache.cassandra.service.EmbeddedCassandraService
 
run() - Method in class org.apache.cassandra.utils.WrappedRunnable
 
runMayThrow() - Method in class org.apache.cassandra.net.FileStreamTask
 
runMayThrow() - Method in class org.apache.cassandra.utils.WrappedRunnable
 

S

SafeMessageDigest - Class in org.apache.cassandra.utils
 
SafeMessageDigest(MessageDigest) - Constructor for class org.apache.cassandra.utils.SafeMessageDigest
 
seek(long) - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
seekTo(DecoratedKey) - Method in class org.apache.cassandra.io.SSTableScanner
 
sendOneWay(Message, InetAddress) - Method in class org.apache.cassandra.net.MessagingService
Send a message to a given endpoint.
sendRR(Message, InetAddress[], IAsyncCallback) - Method in class org.apache.cassandra.net.MessagingService
Send a message to a given endpoint.
sendRR(Message, InetAddress, IAsyncCallback) - Method in class org.apache.cassandra.net.MessagingService
Send a message to a given endpoint.
sendRR(Message[], InetAddress[], IAsyncCallback) - Method in class org.apache.cassandra.net.MessagingService
Send a message to a given endpoint.
sendRR(Message, InetAddress) - Method in class org.apache.cassandra.net.MessagingService
 
serialize(CFMetaData) - Static method in class org.apache.cassandra.config.CFMetaData
 
serialize(KSMetaData) - Static method in class org.apache.cassandra.config.KSMetaData
 
serialize(ColumnFamily, DataOutput) - Method in class org.apache.cassandra.db.ColumnFamilySerializer
 
serialize(ColumnFamily, DataOutput) - Static method in class org.apache.cassandra.db.ColumnIndexer
Given a column family this, function creates an in-memory structure that represents the column index for the column family, and subsequently writes it to disk.
serialize(IColumn, DataOutput) - Method in class org.apache.cassandra.db.ColumnSerializer
 
serialize(DataOutputStream) - Method in class org.apache.cassandra.db.filter.QueryPath
 
serialize(WriteResponse, DataOutputStream) - Method in class org.apache.cassandra.db.WriteResponse.WriteResponseSerializer
 
serialize(Token, DataOutput) - Method in class org.apache.cassandra.dht.Token.TokenSerializer
 
serialize(T, DataOutputStream) - Method in interface org.apache.cassandra.io.ICompactSerializer
Serialize the specified type into the specified DataOutputStream instance.
serialize(T, DataOutput) - Method in interface org.apache.cassandra.io.ICompactSerializer2
Serialize the specified type into the specified DataOutput instance.
serialize(DataOutput) - Method in class org.apache.cassandra.io.IndexHelper.IndexInfo
 
serialize(InetAddress, DataOutputStream) - Static method in class org.apache.cassandra.net.CompactEndPointSerializationHelper
 
serialize(AntiEntropyService.CFPair, DataOutputStream) - Method in class org.apache.cassandra.service.AntiEntropyService.TreeRequestVerbHandler
 
serialize(AntiEntropyService.Validator, DataOutputStream) - Method in class org.apache.cassandra.service.AntiEntropyService.TreeResponseVerbHandler
 
serialize(BitSet, DataOutputStream) - Static method in class org.apache.cassandra.utils.BitSetSerializer
 
serialize(TSerializer, TBase, DataOutput) - Static method in class org.apache.cassandra.utils.FBUtilities
 
serializedSize() - Method in class org.apache.cassandra.db.Column
 
serializedSize() - Method in interface org.apache.cassandra.db.IColumn
 
serializedSize() - Method in class org.apache.cassandra.db.SuperColumn
This returns the size of the super-column when serialized.
serializedSize() - Method in class org.apache.cassandra.io.IndexHelper.IndexInfo
 
serializeForSSTable(ColumnFamily, DataOutput) - Method in class org.apache.cassandra.db.ColumnFamilySerializer
 
serializer() - Static method in class org.apache.cassandra.db.Column
 
serializer() - Static method in class org.apache.cassandra.db.ColumnFamily
 
serializer() - Static method in class org.apache.cassandra.db.DecoratedKey
 
serializer() - Static method in class org.apache.cassandra.db.ReadCommand
 
serializer() - Static method in class org.apache.cassandra.db.ReadResponse
 
serializer() - Static method in class org.apache.cassandra.db.RowMutation
 
serializer(AbstractType) - Static method in class org.apache.cassandra.db.SuperColumn
 
serializer() - Static method in class org.apache.cassandra.db.WriteResponse
 
serializer() - Static method in class org.apache.cassandra.dht.AbstractBounds
 
serializer() - Static method in class org.apache.cassandra.dht.Token
 
serializer() - Static method in class org.apache.cassandra.gms.ApplicationState
 
serializer() - Static method in class org.apache.cassandra.gms.EndPointState
 
serializer() - Static method in class org.apache.cassandra.gms.GossipDigest
 
serializer() - Static method in class org.apache.cassandra.net.Message
 
SERIALIZER - Static variable in class org.apache.cassandra.net.ProtocolHeader
 
SERIALIZER - Static variable in class org.apache.cassandra.service.AntiEntropyService.TreeRequestVerbHandler
 
SERIALIZER - Static variable in class org.apache.cassandra.service.AntiEntropyService.TreeResponseVerbHandler
 
serializer() - Static method in class org.apache.cassandra.utils.BloomFilter
 
SerializerType - Enum in org.apache.cassandra.net.io
 
serializerType_ - Variable in class org.apache.cassandra.net.ProtocolHeader
 
serializeWithIndexes(ColumnFamily, DataOutput) - Method in class org.apache.cassandra.db.ColumnFamilySerializer
 
serialVersionUID - Static variable in class org.apache.cassandra.dht.Range
 
serialVersionUID - Static variable in class org.apache.cassandra.utils.MerkleTree.TreeRange
 
setBootstrapped(boolean) - Static method in class org.apache.cassandra.db.SystemTable
 
setCacheCapacities(String, String, int, int) - Method in class org.apache.cassandra.tools.NodeProbe
 
setCapacity(int) - Method in class org.apache.cassandra.cache.InstrumentedCache
 
setCapacity(int) - Method in interface org.apache.cassandra.cache.JMXInstrumentedCacheMBean
 
setColumnFamily(Configuration, String, String) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
Set the keyspace and column family for this job.
setCompactionThreshold(int, int) - Method in class org.apache.cassandra.tools.NodeProbe
Set the compaction threshold
setCorePoolSize(int) - Method in interface org.apache.cassandra.concurrent.JMXConfigurableThreadPoolExecutorMBean
 
setDigestQuery(boolean) - Method in class org.apache.cassandra.db.ReadCommand
 
setHasToken(boolean) - Method in class org.apache.cassandra.gms.EndPointState
 
setHeader(String, byte[]) - Method in class org.apache.cassandra.net.Message
 
setInputSplitSize(Configuration, int) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
Set the size of the input split.
setIsDigestQuery(boolean) - Method in class org.apache.cassandra.db.ReadResponse
 
setLog4jLevel(String, String) - Method in class org.apache.cassandra.service.StorageService
 
setLog4jLevel(String, String) - Method in interface org.apache.cassandra.service.StorageServiceMBean
set the logging level at runtime
setMaximumCompactionThreshold(int) - Method in class org.apache.cassandra.db.CompactionManager
Sets the maximum number of sstables in queue before compaction kicks off
setMaximumCompactionThreshold(int) - Method in interface org.apache.cassandra.db.CompactionManagerMBean
Sets the maximum number of sstables in queue before compaction kicks off
setMinimumCompactionThreshold(int) - Method in class org.apache.cassandra.db.CompactionManager
Sets the minimum number of sstables in queue before compaction kicks off
setMinimumCompactionThreshold(int) - Method in interface org.apache.cassandra.db.CompactionManagerMBean
Sets the minimum number of sstables in queue before compaction kicks off
setPendingRanges(String, Multimap<Range, InetAddress>) - Method in class org.apache.cassandra.locator.TokenMetadata
 
setPhiConvictThreshold(int) - Method in class org.apache.cassandra.gms.FailureDetector
 
setPhiConvictThreshold(int) - Method in interface org.apache.cassandra.gms.FailureDetectorMBean
 
setRangeBatchSize(Configuration, int) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
The number of rows to request with each get range slices request.
setSegmentSize(int) - Static method in class org.apache.cassandra.db.commitlog.CommitLog
 
setSlicePredicate(Configuration, SlicePredicate) - Static method in class org.apache.cassandra.hadoop.ConfigHelper
Set the predicate that determines what columns will be selected from each row.
setToken(Token) - Method in class org.apache.cassandra.db.SystemTable.StorageMetadata
 
setToken(Token) - Method in class org.apache.cassandra.service.StorageService
This method updates the local token on disk
setTrackedBy(SSTableTracker) - Method in class org.apache.cassandra.io.SSTableReader
 
shutdown() - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
shutdown() - Method in class org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
 
shutdown() - Method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
shutdown() - Static method in class org.apache.cassandra.net.MessagingService
 
shutdown() - Method in class org.apache.cassandra.utils.ExpiringMap
 
shutdownNow() - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
shutdownNow() - Method in class org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
 
shutdownNow() - Static method in class org.apache.cassandra.concurrent.StageManager
This method shuts down all registered stages.
shutdownNow() - Method in class org.apache.cassandra.db.commitlog.AbstractCommitLogExecutorService
 
signal() - Method in class org.apache.cassandra.utils.SimpleCondition
 
signalAll() - Method in class org.apache.cassandra.utils.SimpleCondition
 
SimpleAbstractColumnIterator - Class in org.apache.cassandra.db.filter
 
SimpleAbstractColumnIterator() - Constructor for class org.apache.cassandra.db.filter.SimpleAbstractColumnIterator
 
SimpleAuthenticator - Class in org.apache.cassandra.auth
 
SimpleAuthenticator() - Constructor for class org.apache.cassandra.auth.SimpleAuthenticator
 
SimpleAuthenticator.PasswordMode - Enum in org.apache.cassandra.auth
 
SimpleCondition - Class in org.apache.cassandra.utils
 
SimpleCondition() - Constructor for class org.apache.cassandra.utils.SimpleCondition
 
SinkManager - Class in org.apache.cassandra.net.sink
 
SinkManager() - Constructor for class org.apache.cassandra.net.sink.SinkManager
 
size() - Method in class org.apache.cassandra.db.Column
 
size() - Method in interface org.apache.cassandra.db.IColumn
 
size() - Method in class org.apache.cassandra.db.SuperColumn
This calculates the exact size of the sub columns on the fly
size - Variable in class org.apache.cassandra.io.SSTable.PositionSize
 
size() - Method in class org.apache.cassandra.io.SSTableTracker
 
size() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
size() - Method in class org.apache.cassandra.utils.BoundedStatsDeque
 
size() - Method in class org.apache.cassandra.utils.ExpiringMap
 
size() - Method in class org.apache.cassandra.utils.MerkleTree
The number of distinct ranges contained in this tree.
skipBloomFilter(DataInput) - Static method in class org.apache.cassandra.io.IndexHelper
Skip the bloom filter
skipBytes(int) - Method in class org.apache.cassandra.io.util.MappedFileDataInput
 
skipIndex(DataInput) - Static method in class org.apache.cassandra.io.IndexHelper
Skip the index
skipRemaining() - Method in class org.apache.cassandra.io.IteratingRow
 
SliceByNamesReadCommand - Class in org.apache.cassandra.db
 
SliceByNamesReadCommand(String, String, ColumnParent, Collection<byte[]>) - Constructor for class org.apache.cassandra.db.SliceByNamesReadCommand
 
SliceByNamesReadCommand(String, String, QueryPath, Collection<byte[]>) - Constructor for class org.apache.cassandra.db.SliceByNamesReadCommand
 
SliceFromReadCommand - Class in org.apache.cassandra.db
 
SliceFromReadCommand(String, String, ColumnParent, byte[], byte[], boolean, int) - Constructor for class org.apache.cassandra.db.SliceFromReadCommand
 
SliceFromReadCommand(String, String, QueryPath, byte[], byte[], boolean, int) - Constructor for class org.apache.cassandra.db.SliceFromReadCommand
 
SliceQueryFilter - Class in org.apache.cassandra.db.filter
 
SliceQueryFilter(String, QueryPath, byte[], byte[], boolean, int) - Constructor for class org.apache.cassandra.db.filter.SliceQueryFilter
 
snapshot(String) - Method in class org.apache.cassandra.db.ColumnFamilyStore
Take a snap shot of this columnfamily store.
snapshot(String) - Method in class org.apache.cassandra.db.Table
Take a snapshot of the entire set of column families with a given timestamp.
snitch_ - Variable in class org.apache.cassandra.locator.AbstractReplicationStrategy
 
sortByProximity(InetAddress, List<InetAddress>) - Method in class org.apache.cassandra.locator.AbstractEndpointSnitch
 
sortByProximity(InetAddress, List<InetAddress>) - Method in interface org.apache.cassandra.locator.IEndPointSnitch
This method will sort the List according to the proximity of the given address.
sortedTokens() - Method in class org.apache.cassandra.locator.TokenMetadata
 
sortSampledKeys(List<DecoratedKey>, Range) - Static method in class org.apache.cassandra.utils.FBUtilities
 
source - Variable in class org.apache.cassandra.utils.ReducingIterator
 
spaceReclaimed(long) - Method in class org.apache.cassandra.io.SSTableTracker
 
split(Token) - Method in class org.apache.cassandra.utils.MerkleTree
Splits the range containing the given token, if no tree limits would be violated.
SSTable - Class in org.apache.cassandra.io
This class is built on top of the SequenceFile.
SSTable(String, IPartitioner) - Constructor for class org.apache.cassandra.io.SSTable
 
SSTable.PositionSize - Class in org.apache.cassandra.io
 
SSTable.PositionSize(long, long) - Constructor for class org.apache.cassandra.io.SSTable.PositionSize
 
SSTableDeletingReference - Class in org.apache.cassandra.io
 
SSTableExport - Class in org.apache.cassandra.tools
Export SSTables to JSON format.
SSTableExport() - Constructor for class org.apache.cassandra.tools.SSTableExport
 
SSTableImport - Class in org.apache.cassandra.tools
Create SSTables from JSON input
SSTableImport() - Constructor for class org.apache.cassandra.tools.SSTableImport
 
SSTableNamesIterator - Class in org.apache.cassandra.db.filter
 
SSTableNamesIterator(SSTableReader, String, SortedSet<byte[]>) - Constructor for class org.apache.cassandra.db.filter.SSTableNamesIterator
 
SSTableReader - Class in org.apache.cassandra.io
SSTableReaders are open()ed by Table.onStart; after that they are created by SSTableWriter.renameAndOpen.
SSTableScanner - Class in org.apache.cassandra.io
 
SSTableTracker - Class in org.apache.cassandra.io
 
SSTableTracker(String, String) - Constructor for class org.apache.cassandra.io.SSTableTracker
 
SSTableWriter - Class in org.apache.cassandra.io
 
SSTableWriter(String, long, IPartitioner) - Constructor for class org.apache.cassandra.io.SSTableWriter
 
StageManager - Class in org.apache.cassandra.concurrent
This class manages executor services for Messages recieved: each Message requests running on a specific "stage" for concurrency control; hence the Map approach, even though stages (executors) are not created dynamically.
StageManager() - Constructor for class org.apache.cassandra.concurrent.StageManager
 
start() - Method in class org.apache.cassandra.avro.CassandraDaemon
hook for JSVC
start - Variable in class org.apache.cassandra.db.filter.SliceQueryFilter
 
start - Variable in class org.apache.cassandra.db.SliceFromReadCommand
 
start(InetAddress, int) - Method in class org.apache.cassandra.gms.Gossiper
Start the gossiper with the generation # retrieved from the System table
start() - Method in class org.apache.cassandra.service.GCInspector
 
start() - Method in class org.apache.cassandra.thrift.CassandraDaemon
hook for JSVC
startBootstrap() - Method in class org.apache.cassandra.dht.BootStrapper
 
startBroadcasting() - Method in class org.apache.cassandra.service.StorageLoadBalancer
 
startNext() - Method in class org.apache.cassandra.streaming.StreamOutManager
 
STATE_BOOTSTRAPPING - Static variable in class org.apache.cassandra.service.StorageService
 
STATE_LEAVING - Static variable in class org.apache.cassandra.service.StorageService
 
STATE_LEFT - Static variable in class org.apache.cassandra.service.StorageService
 
STATE_NORMAL - Static variable in class org.apache.cassandra.service.StorageService
 
STATUS_CF - Static variable in class org.apache.cassandra.db.SystemTable
 
stdev() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
stop() - Method in class org.apache.cassandra.avro.CassandraDaemon
hook for JSVC
stop() - Method in class org.apache.cassandra.gms.Gossiper
 
stop() - Method in class org.apache.cassandra.thrift.CassandraDaemon
hook for JSVC
stopClient() - Method in class org.apache.cassandra.service.StorageService
 
StorageLoadBalancer - Class in org.apache.cassandra.service
 
StorageProxy - Class in org.apache.cassandra.service
 
StorageProxyMBean - Interface in org.apache.cassandra.service
 
StorageService - Class in org.apache.cassandra.service
 
StorageService() - Constructor for class org.apache.cassandra.service.StorageService
 
StorageService.Verb - Enum in org.apache.cassandra.service
 
StorageServiceMBean - Interface in org.apache.cassandra.service
 
storeMetadata() - Static method in class org.apache.cassandra.config.DatabaseDescriptor
Create the metadata tables.
stream(String, long, long, InetAddress, InetAddress) - Method in class org.apache.cassandra.net.MessagingService
Stream a file from source to destination.
STREAM_STAGE - Static variable in class org.apache.cassandra.concurrent.StageManager
 
StreamFinishedVerbHandler - Class in org.apache.cassandra.streaming
 
StreamFinishedVerbHandler() - Constructor for class org.apache.cassandra.streaming.StreamFinishedVerbHandler
 
StreamIn - Class in org.apache.cassandra.streaming
for streaming data from other nodes in to this one
StreamIn() - Constructor for class org.apache.cassandra.streaming.StreamIn
 
STREAMING_SUBDIR - Static variable in class org.apache.cassandra.config.DatabaseDescriptor
 
StreamingService - Class in org.apache.cassandra.streaming
 
StreamingServiceMBean - Interface in org.apache.cassandra.streaming
 
StreamInitiateDoneVerbHandler - Class in org.apache.cassandra.streaming
 
StreamInitiateDoneVerbHandler() - Constructor for class org.apache.cassandra.streaming.StreamInitiateDoneVerbHandler
 
StreamInitiateVerbHandler - Class in org.apache.cassandra.streaming
 
StreamInitiateVerbHandler() - Constructor for class org.apache.cassandra.streaming.StreamInitiateVerbHandler
 
StreamOut - Class in org.apache.cassandra.streaming
This class handles streaming data from one node to another.
StreamOut() - Constructor for class org.apache.cassandra.streaming.StreamOut
 
StreamOutManager - Class in org.apache.cassandra.streaming
This class manages the streaming of multiple files one after the other.
StreamRequestVerbHandler - Class in org.apache.cassandra.streaming
This verb handler handles the StreamRequestMessage that is sent by the node requesting range transfer.
StreamRequestVerbHandler() - Constructor for class org.apache.cassandra.streaming.StreamRequestVerbHandler
 
stringifyFileSize(double) - Static method in class org.apache.cassandra.io.util.FileUtils
 
StringToken - Class in org.apache.cassandra.dht
 
StringToken(String) - Constructor for class org.apache.cassandra.dht.StringToken
 
strip(String, String) - Static method in class org.apache.cassandra.utils.FBUtilities
 
subcolumnComparator - Variable in class org.apache.cassandra.config.CFMetaData
 
submit(Callable<T>) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Submits a value-returning task for execution and returns a Future representing the pending results of the task.
submit(Runnable, T) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Submits a Runnable task for execution and returns a Future representing that task.
submit(Runnable) - Method in class org.apache.cassandra.concurrent.AIOExecutorService
Submits a Runnable task for execution and returns a Future representing that task.
submit(Callable<T>) - Method in interface org.apache.cassandra.db.commitlog.ICommitLogExecutorService
 
submitAnticompaction(ColumnFamilyStore, Collection<Range>, InetAddress) - Method in class org.apache.cassandra.db.CompactionManager
 
submitCleanup(ColumnFamilyStore) - Method in class org.apache.cassandra.db.CompactionManager
 
submitDelete(String) - Static method in class org.apache.cassandra.io.DeletionService
 
submitMajor(ColumnFamilyStore) - Method in class org.apache.cassandra.db.CompactionManager
 
submitMajor(ColumnFamilyStore, long, int) - Method in class org.apache.cassandra.db.CompactionManager
 
submitMinorIfNeeded(ColumnFamilyStore) - Method in class org.apache.cassandra.db.CompactionManager
Call this whenever a compaction might be needed on the given columnfamily.
submitReadonly(ColumnFamilyStore, InetAddress) - Method in class org.apache.cassandra.db.CompactionManager
 
sum() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
sumOfDeviations() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
super_column - Variable in class org.apache.cassandra.db.RangeSliceCommand
 
SuperColumn - Class in org.apache.cassandra.db
 
SuperColumn(byte[], AbstractType) - Constructor for class org.apache.cassandra.db.SuperColumn
 
superColumnName - Variable in class org.apache.cassandra.db.filter.QueryPath
 
sync() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
sync() - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
SYSTEM_TABLE - Static variable in class org.apache.cassandra.db.Table
 
SystemTable - Class in org.apache.cassandra.db
 
SystemTable() - Constructor for class org.apache.cassandra.db.SystemTable
 
SystemTable.StorageMetadata - Class in org.apache.cassandra.db
 

T

table - Variable in class org.apache.cassandra.db.ReadCommand
 
Table - Class in org.apache.cassandra.db
 
table() - Method in class org.apache.cassandra.db.WriteResponse
 
Table.TableMetadata - Class in org.apache.cassandra.db
 
Table.TableMetadata() - Constructor for class org.apache.cassandra.db.Table.TableMetadata
 
tableName - Variable in class org.apache.cassandra.config.CFMetaData
 
takeAllSnapshot(String) - Method in class org.apache.cassandra.service.StorageService
Takes a snapshot for every table.
takeAllSnapshot(String) - Method in interface org.apache.cassandra.service.StorageServiceMBean
Takes a snapshot for every table.
takeGlobalSnapshot(String) - Method in class org.apache.cassandra.tools.ClusterCmd
Take a snapshot of all tables on all (live) nodes in the cluster
takeSnapshot(String, String) - Method in class org.apache.cassandra.service.StorageService
Takes the snapshot for a given table.
takeSnapshot(String, String) - Method in interface org.apache.cassandra.service.StorageServiceMBean
Takes the snapshot for a given table.
takeSnapshot(String) - Method in class org.apache.cassandra.tools.NodeProbe
Take a snapshot of all the tables.
TASK_ID - Static variable in class org.apache.cassandra.net.HeaderTypes
 
TASK_PROFILE_CHAIN - Static variable in class org.apache.cassandra.net.HeaderTypes
 
TEMPFILE_MARKER - Static variable in class org.apache.cassandra.io.SSTable
 
ThriftGlue - Class in org.apache.cassandra.thrift
 
ThriftGlue() - Constructor for class org.apache.cassandra.thrift.ThriftGlue
 
thriftifyColumns(Collection<IColumn>, boolean) - Method in class org.apache.cassandra.thrift.CassandraServer
 
thriftifySubColumns(Collection<IColumn>) - Method in class org.apache.cassandra.thrift.CassandraServer
 
thriftPort - Variable in class org.apache.cassandra.cli.CliSessionState
 
ThriftValidation - Class in org.apache.cassandra.thrift
 
ThriftValidation() - Constructor for class org.apache.cassandra.thrift.ThriftValidation
 
timestamp() - Method in class org.apache.cassandra.db.Column
 
timestamp() - Method in interface org.apache.cassandra.db.IColumn
 
timestamp() - Method in class org.apache.cassandra.db.SuperColumn
 
TimeUUIDType - Class in org.apache.cassandra.db.marshal
 
TimeUUIDType() - Constructor for class org.apache.cassandra.db.marshal.TimeUUIDType
 
toByteArray(Token<T>) - Method in class org.apache.cassandra.dht.Token.TokenFactory
 
toByteArray(int) - Static method in class org.apache.cassandra.utils.FBUtilities
 
toByteArray(long) - Static method in class org.apache.cassandra.utils.FBUtilities
 
token - Variable in class org.apache.cassandra.db.DecoratedKey
 
token - Variable in class org.apache.cassandra.dht.BootStrapper
 
Token<T> - Class in org.apache.cassandra.dht
 
Token(T) - Constructor for class org.apache.cassandra.dht.Token
 
token - Variable in class org.apache.cassandra.utils.MerkleTree.RowHash
 
Token.TokenFactory<T> - Class in org.apache.cassandra.dht
 
Token.TokenFactory() - Constructor for class org.apache.cassandra.dht.Token.TokenFactory
 
Token.TokenSerializer - Class in org.apache.cassandra.dht
 
Token.TokenSerializer() - Constructor for class org.apache.cassandra.dht.Token.TokenSerializer
 
TOKEN_MAP - Static variable in class org.apache.cassandra.thrift.CassandraServer
 
tokenMetadata - Variable in class org.apache.cassandra.dht.BootStrapper
 
TokenMetadata - Class in org.apache.cassandra.locator
 
TokenMetadata() - Constructor for class org.apache.cassandra.locator.TokenMetadata
 
TokenMetadata(BiMap<Token, InetAddress>) - Constructor for class org.apache.cassandra.locator.TokenMetadata
 
toString() - Method in class org.apache.cassandra.db.ColumnFamily
 
toString() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment.CommitLogContext
 
toString() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
toString() - Method in class org.apache.cassandra.db.DecoratedKey
 
toString() - Method in class org.apache.cassandra.db.filter.QueryPath
 
toString() - Method in class org.apache.cassandra.db.Memtable
 
toString() - Method in class org.apache.cassandra.db.RangeSliceCommand
 
toString() - Method in class org.apache.cassandra.db.RangeSliceReply
 
toString() - Method in class org.apache.cassandra.db.Row
 
toString() - Method in class org.apache.cassandra.db.RowMutation
 
toString() - Method in class org.apache.cassandra.db.SliceByNamesReadCommand
 
toString() - Method in class org.apache.cassandra.db.SliceFromReadCommand
 
toString() - Method in class org.apache.cassandra.db.Table.TableMetadata
 
toString() - Method in class org.apache.cassandra.dht.Bounds
 
toString() - Method in class org.apache.cassandra.dht.BytesToken
 
toString() - Method in class org.apache.cassandra.dht.Range
 
toString(Token<T>) - Method in class org.apache.cassandra.dht.Token.TokenFactory
 
toString() - Method in class org.apache.cassandra.dht.Token
 
toString() - Method in class org.apache.cassandra.gms.FailureDetector
 
toString() - Method in class org.apache.cassandra.gms.GossipDigest
 
toString() - Method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
toString() - Method in class org.apache.cassandra.io.IndexSummary.KeyPosition
 
toString() - Method in class org.apache.cassandra.io.SSTable
 
toString() - Method in class org.apache.cassandra.locator.TokenMetadata
 
toString() - Method in class org.apache.cassandra.net.Message
 
toString() - Method in class org.apache.cassandra.service.AntiEntropyService.Differencer
 
toString() - Method in class org.apache.cassandra.utils.BloomFilter
 
toString() - Method in class org.apache.cassandra.utils.MerkleTree.RowHash
 
toString() - Method in class org.apache.cassandra.utils.MerkleTree
 
toString() - Method in class org.apache.cassandra.utils.MerkleTree.TreeRange
 
toString() - Method in class org.apache.cassandra.utils.Pair
 
transferRanges(InetAddress, String, Collection<Range>, Runnable) - Static method in class org.apache.cassandra.streaming.StreamOut
Split out files for all tables on disk locally for each range and then stream them to the target endpoint.
transferSSTables(InetAddress, List<SSTableReader>, String) - Static method in class org.apache.cassandra.streaming.StreamOut
Transfers a group of sstables from a single table to the target endpoint and then marks them as ready for local deletion.
tree - Variable in class org.apache.cassandra.service.AntiEntropyService.Validator
 
TREE_STORE_TIMEOUT - Static variable in class org.apache.cassandra.service.AntiEntropyService
 
TWO - Static variable in class org.apache.cassandra.dht.RandomPartitioner
 
TWO - Static variable in class org.apache.cassandra.utils.FBUtilities
 
type() - Method in class org.apache.cassandra.db.ColumnFamily
 

U

unescapeSQLString(String) - Static method in class org.apache.cassandra.cli.CliUtils
 
unprotectedDigest() - Method in class org.apache.cassandra.utils.SafeMessageDigest
 
unprotectedDigest(byte[]) - Method in class org.apache.cassandra.utils.SafeMessageDigest
 
unprotectedUpdate(byte[]) - Method in class org.apache.cassandra.utils.SafeMessageDigest
 
unregister(IEndPointStateChangeSubscriber) - Method in class org.apache.cassandra.gms.Gossiper
 
unregister(IEndPointStateChangeSubscriber) - Method in interface org.apache.cassandra.gms.IEndPointStateChangePublisher
Unregister interest for state changes.
unregisterFailureDetectionEventListener(IFailureDetectionEventListener) - Method in class org.apache.cassandra.gms.FailureDetector
 
unregisterFailureDetectionEventListener(IFailureDetectionEventListener) - Method in interface org.apache.cassandra.gms.IFailureDetector
Un-register interest for Failure Detector events.
unwrap() - Method in class org.apache.cassandra.dht.AbstractBounds
 
unwrap() - Method in class org.apache.cassandra.dht.Bounds
 
unwrap() - Method in class org.apache.cassandra.dht.Range
 
update(String, long) - Method in class org.apache.cassandra.streaming.StreamOutManager
 
update(byte[]) - Method in class org.apache.cassandra.utils.SafeMessageDigest
 
updateCacheSizes() - Method in class org.apache.cassandra.io.SSTableTracker
Resizes the key and row caches based on the current key estimate.
updateDigest(MessageDigest) - Method in class org.apache.cassandra.db.Column
 
updateDigest(MessageDigest) - Method in class org.apache.cassandra.db.ColumnFamily
 
updateDigest(MessageDigest) - Method in interface org.apache.cassandra.db.IColumn
 
updateDigest(MessageDigest) - Method in class org.apache.cassandra.db.SuperColumn
 
updateNormalToken(Token, InetAddress) - Method in class org.apache.cassandra.locator.TokenMetadata
 
updateToken(InetAddress, Token) - Static method in class org.apache.cassandra.db.SystemTable
Record token being used by another node
updateToken(Token) - Static method in class org.apache.cassandra.db.SystemTable
This method is used to update the System Table with the new token for this node
username - Variable in class org.apache.cassandra.cli.CliSessionState
 
USERNAME_KEY - Static variable in class org.apache.cassandra.auth.SimpleAuthenticator
 
UTF8Type - Class in org.apache.cassandra.db.marshal
 
UTF8Type() - Constructor for class org.apache.cassandra.db.marshal.UTF8Type
 
UtfPrefix_ - Static variable in interface org.apache.cassandra.db.IColumn
 

V

validate(byte[]) - Method in class org.apache.cassandra.db.marshal.AbstractType
validate that the byte array is a valid sequence for the type we are supposed to be comparing
validateColumnFamily(String, String) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validateColumnOrSuperColumn(String, String, ColumnOrSuperColumn) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validateColumns(String, ColumnParent, Iterable<byte[]>) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validateDeletion(String, String, Deletion) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validateKeyRange(KeyRange) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validateMagic(int) - Static method in class org.apache.cassandra.net.MessagingService
 
validateMutation(String, String, Mutation) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validatePredicate(String, ColumnParent, SlicePredicate) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validateRange(String, ColumnParent, SliceRange) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
validateSlicePredicate(String, String, byte[], SlicePredicate) - Static method in class org.apache.cassandra.thrift.ThriftValidation
 
value() - Method in class org.apache.cassandra.db.Column
 
value() - Method in interface org.apache.cassandra.db.IColumn
 
value() - Method in class org.apache.cassandra.db.SuperColumn
 
valueOf(String) - Static method in enum org.apache.cassandra.auth.SimpleAuthenticator.PasswordMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.cassandra.config.DatabaseDescriptor.CommitLogSync
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.cassandra.config.DatabaseDescriptor.DiskAccessMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.cassandra.net.io.SerializerType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.cassandra.service.StorageService.Verb
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.cassandra.auth.SimpleAuthenticator.PasswordMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.cassandra.config.DatabaseDescriptor.CommitLogSync
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.cassandra.config.DatabaseDescriptor.DiskAccessMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.cassandra.net.io.SerializerType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.cassandra.service.StorageService.Verb
Returns an array containing the constants of this enum type, in the order they are declared.
variance() - Method in class org.apache.cassandra.utils.AbstractStatsDeque
 
VERBS - Static variable in class org.apache.cassandra.service.StorageService
 
VERSION - Static variable in class org.apache.cassandra.net.ProtocolHeader
 
version_ - Variable in class org.apache.cassandra.net.ProtocolHeader
 
VersionGenerator - Class in org.apache.cassandra.gms
A unique version number generator for any state that is generated by the local node.
VersionGenerator() - Constructor for class org.apache.cassandra.gms.VersionGenerator
 

W

waitFor() - Static method in class org.apache.cassandra.io.DeletionService
 
waitFor() - Static method in class org.apache.cassandra.net.MessagingService
blocks until the processing pools are empty and done.
waitForLoadInfo() - Method in class org.apache.cassandra.service.StorageLoadBalancer
Wait for at least BROADCAST_INTERVAL ms, to give all nodes enough time to report in.
waitForStreamCompletion() - Method in class org.apache.cassandra.streaming.StreamOutManager
 
width - Variable in class org.apache.cassandra.io.IndexHelper.IndexInfo
 
WrappedRunnable - Class in org.apache.cassandra.utils
 
WrappedRunnable() - Constructor for class org.apache.cassandra.utils.WrappedRunnable
 
write(RowMutation, Object) - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
write(DataOutput) - Method in class org.apache.cassandra.hadoop.ColumnFamilySplit
 
write(int) - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
write(byte[]) - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
write(byte[], int, int) - Method in class org.apache.cassandra.io.util.BufferedRandomAccessFile
 
write(DataInput, int) - Method in class org.apache.cassandra.io.util.DataOutputBuffer
Writes bytes from a DataInput directly into the buffer.
write(ByteBuffer) - Method in class org.apache.cassandra.net.OutboundTcpConnection
 
writeByteArray(byte[], DataOutput) - Static method in class org.apache.cassandra.utils.FBUtilities
 
writeHeader() - Method in class org.apache.cassandra.db.commitlog.CommitLogSegment
 
writeName(byte[], DataOutput) - Static method in class org.apache.cassandra.db.ColumnSerializer
 
writeNullableString(String, DataOutput) - Static method in class org.apache.cassandra.utils.FBUtilities
 
WriteResponse - Class in org.apache.cassandra.db
 
WriteResponse(String, String, boolean) - Constructor for class org.apache.cassandra.db.WriteResponse
 
WriteResponse.WriteResponseSerializer - Class in org.apache.cassandra.db
 
WriteResponse.WriteResponseSerializer() - Constructor for class org.apache.cassandra.db.WriteResponse.WriteResponseSerializer
 
WriteResponseHandler - Class in org.apache.cassandra.service
 
WriteResponseHandler(int, String) - Constructor for class org.apache.cassandra.service.WriteResponseHandler
 

X

XMLUtils - Class in org.apache.cassandra.utils
 
XMLUtils(String) - Constructor for class org.apache.cassandra.utils.XMLUtils
 
xor(byte[], byte[]) - Static method in class org.apache.cassandra.utils.FBUtilities
 
A B C D E F G H I J K L M N O P Q R S T U V W X
Overview  Package  Class  Use  Tree  Deprecated   Index  Help 
 PREV   NEXT FRAMES    NO FRAMES    
Copyright © 2010 The Apache Software Foundation