A B C D E F G H I J M N O P Q R S T U

A

add(double) - Method in class com.splout.db.benchmark.HistogramWithStats

add(double) - Method in class com.splout.db.benchmark.PositiveHistogram

Add a new value to the histogram

adjustEmptyPartitions(List<PartitionEntry>) - Static method in class com.splout.db.common.PartitionMap

Method that can be used to adjust PartitionEntries that may contain partitions that will become empty.

B

BalanceFileReceivingProgress - Class in com.splout.db.dnode.beans

This bean describes the state of a file transaction (tablespace/partition/version) between DNodes in progress.

BalanceFileReceivingProgress() - Constructor for class com.splout.db.dnode.beans.BalanceFileReceivingProgress

BalanceFileReceivingProgress(String, int, long) - Constructor for class com.splout.db.dnode.beans.BalanceFileReceivingProgress

BaseBean - Class in com.splout.db.common

For convenience, beans will extend this class for having a neat toString() method.

BaseBean() - Constructor for class com.splout.db.common.BaseBean

binaryFileReceived(File) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

bucketFor(Double) - Method in class com.splout.db.benchmark.PositiveHistogram

Return the bucket index for a given value.

buckets - Variable in class com.splout.db.benchmark.PositiveHistogram

C

close() - Method in interface com.splout.db.common.ISQLiteManager

close() - Method in class com.splout.db.common.SQLite4JavaManager

close() - Method in class com.splout.db.common.SQLiteJDBCManager

com.splout.db.benchmark - package com.splout.db.benchmark

com.splout.db.common - package com.splout.db.common

com.splout.db.dnode.beans - package com.splout.db.dnode.beans

Java beans used by / in interactions with the DNode service.

com.splout.db.qnode.beans - package com.splout.db.qnode.beans

Java beans used by / in interaction with the QNode service.

compareTo(PartitionEntry) - Method in class com.splout.db.common.PartitionEntry

compareTo(ReplicationEntry) - Method in class com.splout.db.common.ReplicationEntry

count - Variable in class com.splout.db.benchmark.PositiveHistogram

D

DeployInfo - Class in com.splout.db.qnode.beans

If a deployment is in progress, this bean is serialized as JSON in a file in ZooKeeper so that any QNode can know that there is a deploy in progress and at what time it started, etc.

DeployInfo() - Constructor for class com.splout.db.qnode.beans.DeployInfo

DeployInfo(String) - Constructor for class com.splout.db.qnode.beans.DeployInfo

DeployRequest - Class in com.splout.db.qnode.beans

Bean that is serialized as JSON and sent to the QNodes for requesting a deploy.

DeployRequest() - Constructor for class com.splout.db.qnode.beans.DeployRequest

deSer(String, TypeReference<T>) - Static method in class com.splout.db.common.JSONSerDe

deSer(String, Class<T>) - Static method in class com.splout.db.common.JSONSerDe

DNodeStatusResponse - Class in com.splout.db.dnode.beans

JSON bean that is returned as response to asynchronous commands like deploy.

DNodeStatusResponse(String) - Constructor for class com.splout.db.dnode.beans.DNodeStatusResponse

DNodeSystemStatus - Class in com.splout.db.dnode.beans

JSON bean that is returned when requesting for the status of the DNode.

DNodeSystemStatus() - Constructor for class com.splout.db.dnode.beans.DNodeSystemStatus

E

endQuery(SQLiteConnection) - Method in class com.splout.db.common.TimeoutThread

The same Thread that provided this connection in startQuery() removes it from the monitoring list.

equals(Object) - Method in class com.splout.db.common.PartitionEntry

equals(Object) - Method in class com.splout.db.common.ReplicationEntry

error - Variable in class com.splout.db.qnode.beans.QueryStatus

ErrorQueryStatus - Class in com.splout.db.qnode.beans

A QueryStatus that failed.

ErrorQueryStatus(String) - Constructor for class com.splout.db.qnode.beans.ErrorQueryStatus

exec(String) - Method in interface com.splout.db.common.ISQLiteManager

exec(String) - Method in class com.splout.db.common.SQLite4JavaManager

exec(String) - Method in class com.splout.db.common.SQLiteJDBCManager

F

findPartition(String) - Method in class com.splout.db.common.PartitionMap

Given a key, return the partition that it belongs to, or PartitionMap.NO_PARTITION if none matches.

findPartitions(String, String) - Method in class com.splout.db.common.PartitionMap

Given a min and a max key, return all the partitions that impact this range.

G

getAccum() - Method in class com.splout.db.benchmark.HistogramWithStats

getAverage() - Method in class com.splout.db.benchmark.HistogramWithStats

getAverage() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getBalanceActionsStateMap() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getBinaryFile() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

getBinaryFileSize() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

getBuckets() - Method in class com.splout.db.benchmark.PositiveHistogram

Return the list of buckets.

getBucketSize() - Method in class com.splout.db.benchmark.PositiveHistogram

getClusterSize() - Method in class com.splout.db.qnode.beans.QNodeStatus

getConnectionFromPool() - Method in interface com.splout.db.common.ISQLiteManager

getConnectionFromPool() - Method in class com.splout.db.common.SQLite4JavaManager

getConnectionFromPool() - Method in class com.splout.db.common.SQLiteJDBCManager

getCount() - Method in class com.splout.db.benchmark.PositiveHistogram

Returns the number of elements that was added to the histogram.

getCreationDate() - Method in class com.splout.db.common.Tablespace

getData_uri() - Method in class com.splout.db.qnode.beans.DeployRequest

getdNodes() - Method in class com.splout.db.qnode.beans.QNodeStatus

getError() - Method in class com.splout.db.qnode.beans.DeployInfo

getError() - Method in class com.splout.db.qnode.beans.QueryStatus

getExpectedReplicationFactor() - Method in class com.splout.db.common.ReplicationEntry

getFailedQueries() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getFiles() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getFreeSpaceInDisk() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getHttpExchangerAddress() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getInitStatements() - Method in class com.splout.db.qnode.beans.DeployRequest

getLastExceptionTime() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getLeftAccumulatedProbability(double) - Method in class com.splout.db.benchmark.PositiveHistogram

Computes the accumulated probability for the values at the left of the provided value

getMax() - Method in class com.splout.db.benchmark.HistogramWithStats

Return the maximun value

getMax() - Method in class com.splout.db.common.PartitionEntry

getMetaFile() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

getMillis() - Method in class com.splout.db.qnode.beans.QueryStatus

getMin() - Method in class com.splout.db.benchmark.HistogramWithStats

Return the minimun value

getMin() - Method in class com.splout.db.common.PartitionEntry

getNodes() - Method in class com.splout.db.common.ReplicationEntry

getNormalizedHistogram() - Method in class com.splout.db.benchmark.PositiveHistogram

getnQueries() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getOccupiedSpaceInDisk() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getPartition() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

getPartitionEntries() - Method in class com.splout.db.common.PartitionMap

getPartitionMap() - Method in class com.splout.db.common.Tablespace

getPartitionMap() - Method in class com.splout.db.qnode.beans.DeployRequest

getReceivedSizeSoFar() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

getReplicationEntries() - Method in class com.splout.db.common.ReplicationMap

getReplicationMap() - Method in class com.splout.db.common.Tablespace

getReplicationMap() - Method in class com.splout.db.qnode.beans.DeployRequest

getResult() - Method in class com.splout.db.qnode.beans.QueryStatus

getRigthAccumulatedProbability(double) - Method in class com.splout.db.benchmark.PositiveHistogram

Computes the accumulated probability for the values at the right of the provided value

getShard() - Method in class com.splout.db.common.PartitionEntry

getShard() - Method in class com.splout.db.common.ReplicationEntry

getShard() - Method in class com.splout.db.qnode.beans.QueryStatus

getSlowQueries() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getStartedAt() - Method in class com.splout.db.qnode.beans.DeployInfo

getStatus() - Method in class com.splout.db.dnode.beans.DNodeStatusResponse

getStatus() - Method in class com.splout.db.qnode.beans.StatusMessage

getStdev() - Method in class com.splout.db.benchmark.HistogramWithStats

Returns the stdev.

getSystemStatus() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getTablespace() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

getTablespace() - Method in class com.splout.db.qnode.beans.DeployRequest

getTablespace() - Method in class com.splout.db.qnode.beans.SwitchVersionRequest

getTablespaceMap() - Method in class com.splout.db.qnode.beans.QNodeStatus

getUpperLimit() - Method in class com.splout.db.benchmark.PositiveHistogram

Returns the maximum value that can be keep if the current histogram without needing to redistribute the buckets.

getUpSince() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

getVersion() - Method in class com.splout.db.common.Tablespace

getVersion() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

getVersion() - Method in class com.splout.db.qnode.beans.DeployInfo

getVersion() - Method in class com.splout.db.qnode.beans.SwitchVersionRequest

H

hashCode() - Method in class com.splout.db.common.PartitionEntry

hashCode() - Method in class com.splout.db.common.ReplicationEntry

HistogramWithStats - Class in com.splout.db.benchmark

A PositiveHistogram but that also keeps average, stdev, min and max values.

HistogramWithStats(int, double) - Constructor for class com.splout.db.benchmark.HistogramWithStats

HistogramWithStats(int) - Constructor for class com.splout.db.benchmark.HistogramWithStats

HistogramWithStats() - Constructor for class com.splout.db.benchmark.HistogramWithStats

HistogramWithStats(HistogramWithStats) - Constructor for class com.splout.db.benchmark.HistogramWithStats

I

isDeployInProgress() - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

ISQLiteManager - Interface in com.splout.db.common

Contract for implementing several SQL interfaces.

isReceivedBinaryFile() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

isReceivedMetaFile() - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

J

JSONSerDe - Class in com.splout.db.common

Helper class for serializing / deserializing from / to JSON using Jackson

JSONSerDe() - Constructor for class com.splout.db.common.JSONSerDe

JSONSerDe.JSONSerDeException - Exception in com.splout.db.common

JSONSerDe.JSONSerDeException(Exception) - Constructor for exception com.splout.db.common.JSONSerDe.JSONSerDeException

M

metaFileReceived(File) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

millis - Variable in class com.splout.db.qnode.beans.QueryStatus

N

NO_PARTITION - Static variable in class com.splout.db.common.PartitionMap

O

oneShardOpenedMap() - Static method in class com.splout.db.common.PartitionMap

Use this method for creating a PartitionMap that has only one shard (0) and whose range is -Infinity, +Infinity

oneToOneMap(String...) - Static method in class com.splout.db.common.ReplicationMap

Returns a one to one replication map with consecutive shard Ids from a list of hosts.

P

PARTITION_MAP_REF - Static variable in class com.splout.db.common.PartitionMap

PartitionEntry - Class in com.splout.db.common

An entry in a PartitionMap.

PartitionEntry() - Constructor for class com.splout.db.common.PartitionEntry

PartitionMap - Class in com.splout.db.common

A Splout's partition map definition - The generic type is the type of the Key.

PartitionMap() - Constructor for class com.splout.db.common.PartitionMap

PartitionMap(List<PartitionEntry>) - Constructor for class com.splout.db.common.PartitionMap

PositiveHistogram - Class in com.splout.db.benchmark

A class for computing approximated histograms, keeping a constant resolution, constant amount of memory, and without the needed of pre or post processing.

PositiveHistogram(int, double) - Constructor for class com.splout.db.benchmark.PositiveHistogram

2^bits will be number of buckets.

progressBinaryFile(long, long) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

Q

QNodeStatus - Class in com.splout.db.qnode.beans

All the information available to the QNode including the alive DNodes, the partition map info, etc.

QNodeStatus() - Constructor for class com.splout.db.qnode.beans.QNodeStatus

query(String, int) - Method in interface com.splout.db.common.ISQLiteManager

query(String, int) - Method in class com.splout.db.common.SQLite4JavaManager

query(String, int) - Method in class com.splout.db.common.SQLiteJDBCManager

The contract of this function is to return a JSON-ized ArrayList of JSON Objects which in Java are represented as Map.

QueryStatus - Class in com.splout.db.qnode.beans

JSON bean that is returned by the QNode as response to a query.

QueryStatus() - Constructor for class com.splout.db.qnode.beans.QueryStatus

R

ReplicationEntry - Class in com.splout.db.common

An entry in a ReplicationMap.

ReplicationEntry() - Constructor for class com.splout.db.common.ReplicationEntry

ReplicationEntry(int, String...) - Constructor for class com.splout.db.common.ReplicationEntry

ReplicationMap - Class in com.splout.db.common

A Splout's replication map definition.

ReplicationMap() - Constructor for class com.splout.db.common.ReplicationMap

ReplicationMap(List<ReplicationEntry>) - Constructor for class com.splout.db.common.ReplicationMap

resize(double) - Method in class com.splout.db.benchmark.PositiveHistogram

result - Variable in class com.splout.db.qnode.beans.QueryStatus

roundRobinMap(int, int, String...) - Static method in class com.splout.db.common.ReplicationMap

run() - Method in class com.splout.db.common.TimeoutThread

S

ser(Object) - Static method in class com.splout.db.common.JSONSerDe

setAverage(double) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setBalanceActionsStateMap(Map<String, BalanceFileReceivingProgress>) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setBinaryFile(String) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setBinaryFileSize(long) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setClusterSize(int) - Method in class com.splout.db.qnode.beans.QNodeStatus

setCreationDate(long) - Method in class com.splout.db.common.Tablespace

setData_uri(String) - Method in class com.splout.db.qnode.beans.DeployRequest

setDeployInProgress(boolean) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setdNodes(Map<String, DNodeSystemStatus>) - Method in class com.splout.db.qnode.beans.QNodeStatus

setError(String) - Method in class com.splout.db.qnode.beans.DeployInfo

setError(String) - Method in class com.splout.db.qnode.beans.QueryStatus

setExpectedReplicationFactor(int) - Method in class com.splout.db.common.ReplicationEntry

setFailedQueries(int) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setFiles(List<String>) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setFreeSpaceInDisk(long) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setHttpExchangerAddress(String) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setInitStatements(List<String>) - Method in class com.splout.db.qnode.beans.DeployRequest

setLastExceptionTime(long) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setMax(String) - Method in class com.splout.db.common.PartitionEntry

setMetaFile(String) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setMillis(Long) - Method in class com.splout.db.qnode.beans.QueryStatus

setMin(String) - Method in class com.splout.db.common.PartitionEntry

setNodes(List<String>) - Method in class com.splout.db.common.ReplicationEntry

setnQueries(int) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setOccupiedSpaceInDisk(long) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setPartition(int) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setPartitionEntries(List<PartitionEntry>) - Method in class com.splout.db.common.PartitionMap

setPartitionMap(PartitionMap) - Method in class com.splout.db.common.Tablespace

setPartitionMap(List<PartitionEntry>) - Method in class com.splout.db.qnode.beans.DeployRequest

setReceivedBinaryFile(boolean) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setReceivedMetaFile(boolean) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setReceivedSizeSoFar(long) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setReplicationEntries(List<ReplicationEntry>) - Method in class com.splout.db.common.ReplicationMap

setReplicationMap(ReplicationMap) - Method in class com.splout.db.common.Tablespace

setReplicationMap(List<ReplicationEntry>) - Method in class com.splout.db.qnode.beans.DeployRequest

setResult(ArrayList) - Method in class com.splout.db.qnode.beans.QueryStatus

setShard(Integer) - Method in class com.splout.db.common.PartitionEntry

setShard(Integer) - Method in class com.splout.db.common.ReplicationEntry

setShard(Integer) - Method in class com.splout.db.qnode.beans.QueryStatus

setSlowQueries(double) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setStartedAt(String) - Method in class com.splout.db.qnode.beans.DeployInfo

setStatus(String) - Method in class com.splout.db.dnode.beans.DNodeStatusResponse

setStatus(String) - Method in class com.splout.db.qnode.beans.StatusMessage

setSystemStatus(String) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setTablespace(String) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setTablespace(String) - Method in class com.splout.db.qnode.beans.DeployRequest

setTablespace(String) - Method in class com.splout.db.qnode.beans.SwitchVersionRequest

setTablespaceMap(Map<String, Tablespace>) - Method in class com.splout.db.qnode.beans.QNodeStatus

setTimeoutThread(TimeoutThread) - Method in class com.splout.db.common.SQLite4JavaManager

Optionally sets a TimeoutThread that will take care of cancelling long-running queries.

setUpSince(long) - Method in class com.splout.db.dnode.beans.DNodeSystemStatus

setVersion(long) - Method in class com.splout.db.common.Tablespace

setVersion(long) - Method in class com.splout.db.dnode.beans.BalanceFileReceivingProgress

setVersion(Long) - Method in class com.splout.db.qnode.beans.DeployInfo

setVersion(long) - Method in class com.splout.db.qnode.beans.SwitchVersionRequest

shard - Variable in class com.splout.db.qnode.beans.QueryStatus

SQLite4JavaManager - Class in com.splout.db.common

SQL Wrapper for querying SQLite by using sqlite4java (http://code.google.com/p/sqlite4java).

SQLite4JavaManager(String, List<String>) - Constructor for class com.splout.db.common.SQLite4JavaManager

SQLiteJDBCManager - Class in com.splout.db.common

SQL Wrapper for querying SQLite through a connection pool using BoneCP (http://jolbox.com/).

SQLiteJDBCManager(String, int) - Constructor for class com.splout.db.common.SQLiteJDBCManager

startQuery(SQLiteConnection, String) - Method in class com.splout.db.common.TimeoutThread

A Thread provides its thread-local connection to be monitored when a query starts.

StatusMessage - Class in com.splout.db.qnode.beans

Just a status message and nothing more, returned by rollback() method.

StatusMessage() - Constructor for class com.splout.db.qnode.beans.StatusMessage

StatusMessage(String) - Constructor for class com.splout.db.qnode.beans.StatusMessage

SwitchVersionRequest - Class in com.splout.db.qnode.beans

Like DeployRequest, but used to request a rollback instead of a deploy.

SwitchVersionRequest() - Constructor for class com.splout.db.qnode.beans.SwitchVersionRequest

SwitchVersionRequest(String, long) - Constructor for class com.splout.db.qnode.beans.SwitchVersionRequest

T

Tablespace - Class in com.splout.db.common

A tablespace is made up by: A PartitionMap A ReplicationMap A version string A creation date The Tablespace entity is necessary for safely storing each tablespace's information in memory and atomically updating it, for instance in com.splout.db.qnode.QNodeHandler.

Tablespace() - Constructor for class com.splout.db.common.Tablespace

Tablespace(PartitionMap, ReplicationMap, long, long) - Constructor for class com.splout.db.common.Tablespace

TimeoutThread - Class in com.splout.db.common

A Thread that is in charge of killing long-running queries.

TimeoutThread(long) - Constructor for class com.splout.db.common.TimeoutThread

toString() - Method in class com.splout.db.common.BaseBean

toString() - Method in class com.splout.db.common.PartitionEntry

toString() - Method in class com.splout.db.common.PartitionMap

toString() - Method in class com.splout.db.common.ReplicationEntry

toString() - Method in class com.splout.db.common.ReplicationMap

toString() - Method in class com.splout.db.common.Tablespace

toTSV() - Method in class com.splout.db.benchmark.PositiveHistogram

U

upperLimit - Variable in class com.splout.db.benchmark.PositiveHistogram

A B C D E F G H I J M N O P Q R S T U