A B C D E F G H I K L M N O P Q R S T U V W 

A

AbstractBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
AbstractBuilder is responsible for some of the StaticBuffer to String and visa-versa required for working with the database.
AbstractBuilder() - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.AbstractBuilder
 
AbstractDynamoDBStore - Class in com.amazon.titan.diskstorage.dynamodb
The base class for the SINGLE and MULTI implementations of the Amazon DynamoDB Storage Backend for Titan distributed store type.
AbstractDynamoDBStore(DynamoDBStoreManager, String, String) - Constructor for class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
acquireLock(StaticBuffer, StaticBuffer, StaticBuffer, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
additions(List<Entry>) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleUpdateBuilder
 
addWorker(ScanSegmentWorker, int) - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner
 
APPEARED - Static variable in class com.amazon.titan.example.MarvelGraphFactory
 
areGSIsSameConfiguration(List<GlobalSecondaryIndexDescription>, List<GlobalSecondaryIndexDescription>) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
areGSIsSameConfiguration(GlobalSecondaryIndexDescription, GlobalSecondaryIndexDescription) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
AwsStore - Interface in com.amazon.titan.diskstorage.dynamodb
Responsible for communicating with a single AWS backing store table.

B

BackendDataModel - Enum in com.amazon.titan.diskstorage.dynamodb
Creates a store backend based on configuration.
BackendNotFoundException - Exception in com.amazon.titan.diskstorage.dynamodb
Interpretation of DynamoDB ResourceNotFoundException
BackendNotFoundException(String, Throwable) - Constructor for exception com.amazon.titan.diskstorage.dynamodb.BackendNotFoundException
 
BackendRuntimeException - Exception in com.amazon.titan.diskstorage.dynamodb
This class wraps around StorageExceptions in the Amazon DynamoDB Storage Backend for Titan, a checked exception
BackendRuntimeException(String) - Constructor for exception com.amazon.titan.diskstorage.dynamodb.BackendRuntimeException
 
BackendRuntimeException(BackendException) - Constructor for exception com.amazon.titan.diskstorage.dynamodb.BackendRuntimeException
 
BASE_LOGICAL_SIZE_OF_NESTED_TYPES - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
BATCH_WRITE_ITEM - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
batchWriteItem(BatchWriteItemRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
beginTransaction(BaseTransactionConfig) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
build() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ConditionExpressionBuilder
 
build() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.EntryBuilder
 
build(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.EntryBuilder
 
build() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.FilterExpressionBuilder
 
build() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ItemBuilder
 
build(String) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.KeyBuilder
 
build() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.MultiUpdateExpressionBuilder
 
build(KCVMutation) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleExpectedAttributeValueBuilder
 
build() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleUpdateBuilder
 
buildAll() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.EntryBuilder
 
buildQueryWorker(StaticBuffer, SliceQuery) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
buildRecordIterators(ScanContext) - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRowParallelScanInterpreter
This class relies heavily on the behavior of segmented scans with respect to which hash keys are scanned by each segment.
buildRecordIterators(ScanContext) - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRowSequentialScanInterpreter
 
buildRecordIterators(ScanContext) - Method in interface com.amazon.titan.diskstorage.dynamodb.iterator.ScanContextInterpreter
 
buildRecordIterators(ScanContext) - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.SingleRowScanInterpreter
 

C

calculateItemSizeInBytes(Map<String, AttributeValue>) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
calculateItemUpdateSizeInBytes(Map<String, AttributeValueUpdate>) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.DeleteItem
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.GetItem
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.Query
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.Scan
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.UpdateItem
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.GetItemWorker
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanSegmentWorker
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.mutation.DeleteItemWorker
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.mutation.SingleUpdateWithCleanupWorker
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.mutation.UpdateItemWorker
 
call() - Method in class com.amazon.titan.diskstorage.dynamodb.PaginatingTask
 
CHARACTER - Static variable in class com.amazon.titan.example.MarvelGraphFactory
 
clearStorage() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
client - Variable in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
Client - Class in com.amazon.titan.diskstorage.dynamodb
Operations setting up the DynamoDB client.
Client(Configuration) - Constructor for class com.amazon.titan.diskstorage.dynamodb.Client
 
client() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
clone(AttributeValue, IdentityHashMap<AttributeValue, AttributeValue>) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
Helper method that can clone an Attribute Value
cloneItem(Map<String, AttributeValue>) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
Helper method that clones an item
close() - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
close() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
close() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRecordIterator
 
close() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner
 
close() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanBackedKeyIterator
 
close() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.SequentialScanner
 
close() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.StaticRecordIterator
 
com.amazon.titan.diskstorage.dynamodb - package com.amazon.titan.diskstorage.dynamodb
 
com.amazon.titan.diskstorage.dynamodb.builder - package com.amazon.titan.diskstorage.dynamodb.builder
 
com.amazon.titan.diskstorage.dynamodb.iterator - package com.amazon.titan.diskstorage.dynamodb.iterator
 
com.amazon.titan.diskstorage.dynamodb.model - package com.amazon.titan.diskstorage.dynamodb.model
 
com.amazon.titan.diskstorage.dynamodb.mutation - package com.amazon.titan.diskstorage.dynamodb.mutation
 
com.amazon.titan.example - package com.amazon.titan.example
 
COMIC_BOOK - Static variable in class com.amazon.titan.example.MarvelGraphFactory
 
commit() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
computeWcu(int) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
ConditionExpressionBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
ConditionExpressionBuilder is responsible for generating a KeyConditionExpressions used in the DynamoDB scan and range queries.
ConditionExpressionBuilder() - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.ConditionExpressionBuilder
 
CONNECTION_RESET - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
Constants - Class in com.amazon.titan.diskstorage.dynamodb
Constants for the DynamoDB backend.
Constants() - Constructor for class com.amazon.titan.diskstorage.dynamodb.Constants
 
contains(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
copyScanRequest(ScanRequest) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
create(DynamoDBStoreManager, String, String) - Method in interface com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreFactory
Creates a backend store for a given table name.
create(DynamoDBStoreManager, String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.TableNameDynamoDBStoreFactory
 
CREATE_TABLE - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
createAWSCredentialsProvider(String, String[]) - Static method in class com.amazon.titan.diskstorage.dynamodb.Client
 
createMutationWorkers(Map<StaticBuffer, KCVMutation>, DynamoDBStoreTransaction) - Method in interface com.amazon.titan.diskstorage.dynamodb.AwsStore
Creates workers whose job it is to commit the actual mutations in the given mutation map.
createMutationWorkers(Map<StaticBuffer, KCVMutation>, DynamoDBStoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
createMutationWorkers(Map<StaticBuffer, KCVMutation>, DynamoDBStoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
createMutationWorkers(Map<StaticBuffer, KCVMutation>, DynamoDBStoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.MetricStore
 
createStoreBackend(DynamoDBStoreManager, String, String) - Method in enum com.amazon.titan.diskstorage.dynamodb.BackendDataModel
 
createTable(CreateTableRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
createTableAndWaitForActive(CreateTableRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
createTableRequest(String, long, long) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
createTableRequest(String, long, long) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 

D

dataModel(String) - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 
decodeKey(Map<String, AttributeValue>, String) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.AbstractBuilder
 
decodeKey(String) - Static method in class com.amazon.titan.diskstorage.dynamodb.builder.AbstractBuilder
 
decodeValue(AttributeValue) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.AbstractBuilder
 
delegate() - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 
delegate - Variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
delegate - Variable in class com.amazon.titan.diskstorage.dynamodb.PaginatingTask
 
delete(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleUpdateBuilder
 
DELETE_ITEM - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
DELETE_ITEM_RETRIES - Static variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
DELETE_TABLE - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
deleteItem(DeleteItemRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
DeleteItemWorker - Class in com.amazon.titan.diskstorage.dynamodb.mutation
 
DeleteItemWorker(DeleteItemRequest, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.mutation.DeleteItemWorker
 
DeleteRequestWrapper - Class in com.amazon.titan.diskstorage.dynamodb.model
DeleteRequestWrapper is the MutateItemRequest implementation that chooses DeleteItemRequest
DeleteRequestWrapper(DeleteItemRequest) - Constructor for class com.amazon.titan.diskstorage.dynamodb.model.DeleteRequestWrapper
 
DeleteResultWrapper - Class in com.amazon.titan.diskstorage.dynamodb.model
DeleteResultWrapper is the MutateItemResult implementation that chooses DeleteItemResult
DeleteResultWrapper(DeleteItemResult) - Constructor for class com.amazon.titan.diskstorage.dynamodb.model.DeleteResultWrapper
 
deleteStore() - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
deleteStore() - Method in interface com.amazon.titan.diskstorage.dynamodb.AwsStore
Deletes the KCV store and underlying DynamoDB tables.
deleteStore() - Method in class com.amazon.titan.diskstorage.dynamodb.MetricStore
 
deleteTable(DeleteTableRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
deleteTable(String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
deletions(List<StaticBuffer>) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleUpdateBuilder
 
DESCRIBE_TABLE - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
describeTable(String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
describeTable(DescribeTableRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
DYNAMODB_CLIENT_CONN_TIMEOUT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_CONN_TTL - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_CREDENTIALS_NAMESPACE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_ENDPOINT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_EXECUTOR_CORE_POOL_SIZE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_EXECUTOR_KEEP_ALIVE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_EXECUTOR_MAX_CONCURRENT_OPERATIONS - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_EXECUTOR_MAX_POOL_SIZE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_EXECUTOR_NAMESPACE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_EXECUTOR_QUEUE_MAX_LENGTH - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_MAX_CONN - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_MAX_ERROR_RETRY - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_NAMESPACE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_PROXY_DOMAIN - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_PROXY_HOST - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_PROXY_NAMESPACE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_PROXY_PASSWORD - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_PROXY_PORT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_PROXY_USERNAME - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_PROXY_WORKSTATION - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_SOCKET_BUFFER_RECV_HINT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_SOCKET_BUFFER_SEND_HINT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_SOCKET_NAMESPACE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_SOCKET_TCP_KEEP_ALIVE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_SOCKET_TIMEOUT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_USE_GZIP - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_USE_REAPER - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CLIENT_USER_AGENT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CONFIGURATION_NAMESPACE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CONTROL_PLANE_RATE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CREDENTIALS_CLASS_NAME - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_CREDENTIALS_CONSTRUCTOR_ARGS - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_ENABLE_PARALLEL_SCAN - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_FORCE_CONSISTENT_READ - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_INITIAL_RETRY_MILLIS - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_MAX_SELF_THROTTLED_RETRIES - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_METRICS_PREFIX - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_STORES_NAMESPACE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DYNAMODB_TABLE_PREFIX - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
DynamoDBDelegate - Class in com.amazon.titan.diskstorage.dynamodb
A wrapper on top of the DynamoDB client API that self-throttles using metric-based and context-aware estimates for all Read APIs and for DeleteItem, and that self-throttles using accurate upper-bound estimates of item size for PutItem and UpdateItem.
DynamoDBDelegate(String, AWSCredentialsProvider, ClientConfiguration, Configuration, Map<String, RateLimiter>, Map<String, RateLimiter>, long, long, String, String, RateLimiter) - Constructor for class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
DynamoDBSingleRowStore - Class in com.amazon.titan.diskstorage.dynamodb
Acts as if DynamoDB were a Column Oriented Database by using key as the hash key and each entry has their own column.
DynamoDBSingleRowStore(DynamoDBStoreManager, String, String) - Constructor for class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
DynamoDBStore - Class in com.amazon.titan.diskstorage.dynamodb
Acts as if DynamoDB were a Column Oriented Database by using range query when required.
DynamoDBStore(DynamoDBStoreManager, String, String) - Constructor for class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
DynamoDBStoreFactory - Interface in com.amazon.titan.diskstorage.dynamodb
Creates a backend store for a given table name.
DynamoDBStoreManager - Class in com.amazon.titan.diskstorage.dynamodb
The Titan manager for the Amazon DynamoDB Storage Backend for Titan.
DynamoDBStoreManager(Configuration) - Constructor for class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
DynamoDBStoreTransaction - Class in com.amazon.titan.diskstorage.dynamodb
Transaction is used to store expected values of each column for each key in a transaction
DynamoDBStoreTransaction(BaseTransactionConfig) - Constructor for class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 

E

EMPTY_BUFFER_PLACEHOLDER - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
enableParallelScan() - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 
encodeForLog(List<?>) - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
encodeForLog(SliceQuery) - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
encodeForLog(KeySliceQuery) - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
encodeKeyAsAttributeValue(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.AbstractBuilder
 
encodeKeyBuffer(StaticBuffer) - Static method in class com.amazon.titan.diskstorage.dynamodb.builder.AbstractBuilder
 
encodeKeyForLog(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
encodeKeyForLog(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
encodeValue(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.AbstractBuilder
 
ensureStore() - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
ensureStore() - Method in interface com.amazon.titan.diskstorage.dynamodb.AwsStore
Creates the KCV store and underlying DynamoDB tables.
ensureStore() - Method in class com.amazon.titan.diskstorage.dynamodb.MetricStore
 
ensureTableDeleted(String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
EntryBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
EntryBuilder is responsible for translating from DynamoDB item maps to Entry objects.
EntryBuilder(Map<String, AttributeValue>) - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.EntryBuilder
 
equals(Object) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
equals(Object) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
equals(Object) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
estimateCapacityUnits(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
ExponentialBackoff<RequestType,ResultType> - Class in com.amazon.titan.diskstorage.dynamodb
A wrapper for a client-side exponential backoff retry strategy for DynamoDB API calls
ExponentialBackoff(RequestType, DynamoDBDelegate, String) - Constructor for class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
ExponentialBackoff.DeleteItem - Class in com.amazon.titan.diskstorage.dynamodb
 
ExponentialBackoff.DeleteItem(DeleteItemRequest, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.DeleteItem
 
ExponentialBackoff.GetItem - Class in com.amazon.titan.diskstorage.dynamodb
 
ExponentialBackoff.GetItem(GetItemRequest, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.GetItem
 
ExponentialBackoff.Query - Class in com.amazon.titan.diskstorage.dynamodb
 
ExponentialBackoff.Query(QueryRequest, DynamoDBDelegate, int) - Constructor for class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.Query
 
ExponentialBackoff.Scan - Class in com.amazon.titan.diskstorage.dynamodb
 
ExponentialBackoff.Scan(ScanRequest, DynamoDBDelegate, int) - Constructor for class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.Scan
 
ExponentialBackoff.UpdateItem - Class in com.amazon.titan.diskstorage.dynamodb
 
ExponentialBackoff.UpdateItem(UpdateItemRequest, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.UpdateItem
 
Expression - Class in com.amazon.titan.diskstorage.dynamodb
Structure of update and condition expressions required for a DynamoDB conditional update.
Expression(String, String, Map<String, AttributeValue>, Map<String, String>) - Constructor for class com.amazon.titan.diskstorage.dynamodb.Expression
 

F

FilterExpressionBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
Builds filter expressions using the encoding of Titan data model
FilterExpressionBuilder() - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.FilterExpressionBuilder
 
finishSegment(int) - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner
 
forceConsistentRead - Variable in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
forceConsistentRead() - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 

G

get(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
GET_ITEM - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
GET_ITEM_RETRIES - Static variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
getAllStores() - Method in interface com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreFactory
Gets all stores created by this factory.
getAllStores() - Method in class com.amazon.titan.diskstorage.dynamodb.TableNameDynamoDBStoreFactory
 
getAttributeNames() - Method in class com.amazon.titan.diskstorage.dynamodb.Expression
 
getAttributeValues() - Method in class com.amazon.titan.diskstorage.dynamodb.Expression
 
getBackendException() - Method in exception com.amazon.titan.diskstorage.dynamodb.BackendRuntimeException
 
getBytesHistogram(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getCharacter() - Method in class com.amazon.titan.example.MarvelGraphFactory.Appeared
 
getComicBook() - Method in class com.amazon.titan.example.MarvelGraphFactory.Appeared
 
getConditionExpression() - Method in class com.amazon.titan.diskstorage.dynamodb.Expression
 
getConsumedCapacityMeter(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getDeployment() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
getDynamoDBResult() - Method in class com.amazon.titan.diskstorage.dynamodb.GetItemResultWrapper
 
getDynamoDBResult() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryResultWrapper
 
getEntries() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanBackedKeyIterator
 
getFeatures() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
getFinalItemList() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWithLimitWorker
 
getFinalItemList() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 
getHistogram(String, String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getItem(GetItemRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getItemCountMeterName(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
GetItemResultWrapper - Class in com.amazon.titan.diskstorage.dynamodb
Titan's interface for multiqueries requires us to map GetItem results to a StaticBuffer.
GetItemResultWrapper(StaticBuffer, GetItemResult) - Constructor for class com.amazon.titan.diskstorage.dynamodb.GetItemResultWrapper
 
GetItemWorker - Class in com.amazon.titan.diskstorage.dynamodb
Worker class used to execute a GetItem request as a callable.
GetItemWorker(StaticBuffer, GetItemRequest, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.GetItemWorker
 
getKey() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.SingleKeyRecordIterator
 
getKeys(KeyRangeQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
getKeys(SliceQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
getKeys(KeyRangeQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
getKeys(SliceQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
getListTablesApiName() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getLocalKeyPartition() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
getMaxConcurrentUsers() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getMaxRetries() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getMergedPages() - Method in class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
getMergedPages() - Method in class com.amazon.titan.diskstorage.dynamodb.PaginatingTask
Merges all the pages iterated through in this instance and returns them
getMergedPages() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 
getMeter(String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getMeterName(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getName() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
getName() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
getName() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
getNullableConfigValue(Configuration, ConfigOption<T>) - Static method in class com.amazon.titan.diskstorage.dynamodb.TitanConfigUtil
 
getPagesHistogram(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getPagesProcessed() - Method in class com.amazon.titan.diskstorage.dynamodb.PaginatingTask
 
getParallelScanCompletionService(ScanRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getPoolFromNs(Configuration) - Static method in class com.amazon.titan.diskstorage.dynamodb.Client
 
getPort(Configuration) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
getPrefix() - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 
getQuantityMeter(String, String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getQuantityName(String, String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getRecordIterator() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.SingleKeyRecordIterator
 
getRequest() - Method in class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
getRequest() - Method in class com.amazon.titan.diskstorage.dynamodb.model.DeleteRequestWrapper
 
getRequest() - Method in interface com.amazon.titan.diskstorage.dynamodb.model.MutateItemRequest
 
getRequest() - Method in class com.amazon.titan.diskstorage.dynamodb.model.UpdateRequestWrapper
 
getRequest() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 
getResult() - Method in class com.amazon.titan.diskstorage.dynamodb.model.MutateItemResult
 
getRetryMillis() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getReturnedCount() - Method in class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
getReturnedCount() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 
getScannedCount() - Method in class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
getScannedCount() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 
getScanRequest() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanContext
 
getScanResult() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanContext
 
getSlice(KeySliceQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
getSlice(List<StaticBuffer>, SliceQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
getSlice(KeySliceQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
getSlice(List<StaticBuffer>, SliceQuery, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
getStore(String) - Method in interface com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreFactory
Gets backend store for store name.
getStore(String) - Method in class com.amazon.titan.diskstorage.dynamodb.TableNameDynamoDBStoreFactory
 
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
getTableName() - Method in interface com.amazon.titan.diskstorage.dynamodb.AwsStore
Titan relies on static store names to be used, but we want the ability to have multiple graphs in a single region, so prepend a configurable prefix to the underlying table names of each graph and get the DynamoDB table name with this method
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.DeleteItem
 
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.GetItem
 
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.Query
 
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.Scan
 
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff.UpdateItem
 
getTableName() - Method in class com.amazon.titan.diskstorage.dynamodb.MetricStore
 
getTableSchema() - Method in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
Creates the schemata for the DynamoDB table or tables each store requires.
getTableSchema() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
getTableSchema() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
getTimer(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getTimerContext(String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
getTitanKey() - Method in class com.amazon.titan.diskstorage.dynamodb.GetItemResultWrapper
 
getTitanKey() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryResultWrapper
 
getTx(StoreTransaction) - Static method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
getUpdateExpression() - Method in class com.amazon.titan.diskstorage.dynamodb.Expression
 

H

HASH_KEY_EQUALS - Static variable in class com.amazon.titan.diskstorage.dynamodb.builder.ConditionExpressionBuilder
 
HASH_RANGE_KEY_SIZE_LIMIT - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
hashCode() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
hashCode() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
hashCode() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
hashKey(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ConditionExpressionBuilder
 
hashKey(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ConditionExpressionBuilder
 
hashKey(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ItemBuilder
 
hashKey(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.MultiUpdateExpressionBuilder
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRecordIterator
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanBackedKeyIterator
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanSegmentWorker
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.SequentialScanner
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.StaticRecordIterator
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.PaginatingTask
 
hasNext() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 
HEX_PREFIX - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 

I

interruptibleSleep(long) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
isDelete() - Method in class com.amazon.titan.diskstorage.dynamodb.model.DeleteRequestWrapper
 
isDelete() - Method in class com.amazon.titan.diskstorage.dynamodb.model.DeleteResultWrapper
 
isDelete() - Method in interface com.amazon.titan.diskstorage.dynamodb.model.MutateItemRequest
 
isDelete() - Method in class com.amazon.titan.diskstorage.dynamodb.model.MutateItemResult
 
isDelete() - Method in class com.amazon.titan.diskstorage.dynamodb.model.UpdateRequestWrapper
 
isDelete() - Method in class com.amazon.titan.diskstorage.dynamodb.model.UpdateResultWrapper
 
isEmbedded() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
isFirstResult() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanContext
 
isUpdate() - Method in class com.amazon.titan.diskstorage.dynamodb.model.DeleteRequestWrapper
 
isUpdate() - Method in class com.amazon.titan.diskstorage.dynamodb.model.DeleteResultWrapper
 
isUpdate() - Method in interface com.amazon.titan.diskstorage.dynamodb.model.MutateItemRequest
 
isUpdate() - Method in class com.amazon.titan.diskstorage.dynamodb.model.MutateItemResult
 
isUpdate() - Method in class com.amazon.titan.diskstorage.dynamodb.model.UpdateRequestWrapper
 
isUpdate() - Method in class com.amazon.titan.diskstorage.dynamodb.model.UpdateResultWrapper
 
ItemBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
ItemBuilder is responsible for translating from StaticBuffers to DynamoDB item maps.
ItemBuilder() - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.ItemBuilder
 

K

K - Static variable in class com.amazon.titan.diskstorage.dynamodb.builder.ConditionExpressionBuilder
 
key(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleExpectedAttributeValueBuilder
 
KeyBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
KeyBuilder is responsible for extracting constant string attribute names from DynamoDB item maps.
KeyBuilder(Map<String, AttributeValue>) - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.KeyBuilder
 

L

label(String) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.FilterExpressionBuilder
 
limit(int) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.EntryBuilder
 
listAllTables() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
listTables(ListTablesRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
ListTablesWorker - Class in com.amazon.titan.diskstorage.dynamodb
 
ListTablesWorker(DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
load(TitanGraph, int, boolean) - Static method in class com.amazon.titan.example.MarvelGraphFactory
 
log - Variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
log - Variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
LOGICAL_SIZE_OF_EMPTY_DOCUMENT - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 

M

manager - Variable in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
markComplete() - Method in class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
markComplete() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 
MarvelGraphFactory - Class in com.amazon.titan.example
 
MarvelGraphFactory() - Constructor for class com.amazon.titan.example.MarvelGraphFactory
 
MarvelGraphFactory.Appeared - Class in com.amazon.titan.example
 
MarvelGraphFactory.Appeared(String, String) - Constructor for class com.amazon.titan.example.MarvelGraphFactory.Appeared
 
MarvelGraphFactory.AppearedCommand - Class in com.amazon.titan.example
 
MarvelGraphFactory.AppearedCommand(TitanGraph, MarvelGraphFactory.Appeared) - Constructor for class com.amazon.titan.example.MarvelGraphFactory.AppearedCommand
 
MarvelGraphFactory.BatchCommand - Class in com.amazon.titan.example
 
MarvelGraphFactory.BatchCommand(TitanGraph, BlockingQueue<Runnable>) - Constructor for class com.amazon.titan.example.MarvelGraphFactory.BatchCommand
 
MarvelGraphFactory.CharacterCreationCommand - Class in com.amazon.titan.example
 
MarvelGraphFactory.CharacterCreationCommand(TitanGraph, String) - Constructor for class com.amazon.titan.example.MarvelGraphFactory.CharacterCreationCommand
 
MarvelGraphFactory.ComicBookCreationCommand - Class in com.amazon.titan.example
 
MarvelGraphFactory.ComicBookCreationCommand(TitanGraph, String) - Constructor for class com.amazon.titan.example.MarvelGraphFactory.ComicBookCreationCommand
 
MAX_NUMBER_OF_BYTES_FOR_NUMBER - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
measureItemCount(String, String, long) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
meterConsumedCapacity(String, ConsumedCapacity) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
metrics - Variable in class com.amazon.titan.diskstorage.dynamodb.Client
 
MetricStore - Class in com.amazon.titan.diskstorage.dynamodb
Proxies another store to centralize metrics gathering.
MetricStore(AwsStore) - Constructor for class com.amazon.titan.diskstorage.dynamodb.MetricStore
 
MultiRecordIterator - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Lazy-loading iterator that pages through columns for a given hash key.
MultiRecordIterator(QueryWorker, SliceQuery) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRecordIterator
 
MultiRowParallelScanInterpreter - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Builds RecordIterators for scan results from a parallel, segmented scan.
MultiRowParallelScanInterpreter(DynamoDBStore, SliceQuery) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRowParallelScanInterpreter
 
MultiRowSequentialScanInterpreter - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Interprets Scan results for MULTI stores and assumes that results are SEQUENTIAL.
MultiRowSequentialScanInterpreter(DynamoDBStore, SliceQuery) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRowSequentialScanInterpreter
 
MultiUpdateExpressionBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
Builder for update expressions for updating multi data model entries
MultiUpdateExpressionBuilder() - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.MultiUpdateExpressionBuilder
 
mutate(StaticBuffer, List<Entry>, List<StaticBuffer>, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
mutate(StaticBuffer, List<Entry>, List<StaticBuffer>, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
MUTATE_ITEM - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
MutateItemRequest<T extends AmazonWebServiceRequest> - Interface in com.amazon.titan.diskstorage.dynamodb.model
To serialize mutations on one primary key in a DynamoDB table, need to be able to handle UpdateItem and DeleteItem, as Items can be created but not deleted with an UpdateItem.
MutateItemResult<T> - Class in com.amazon.titan.diskstorage.dynamodb.model
To serialize mutations on one primary key in a DynamoDB table, need to be able to handle UpdateItem and DeleteItem, as Items can be created but not deleted with an UpdateItem.
MutateItemResult(T) - Constructor for class com.amazon.titan.diskstorage.dynamodb.model.MutateItemResult
 
mutateMany(Map<String, Map<StaticBuffer, KCVMutation>>, StoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 
MutateWorker - Interface in com.amazon.titan.diskstorage.dynamodb.mutation
 

N

next() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRecordIterator
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanBackedKeyIterator
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanSegmentWorker
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.SequentialScanner
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.StaticRecordIterator
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.ListTablesWorker
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.PaginatingTask
moves the iterator to the next page in preparation for another hasNext/processPage call
next() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWithLimitWorker
 
next() - Method in class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 

O

ONE_KILOBYTE - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
ONE_KILOBYTE_MINUS_ONE - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
openDatabase(String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager
 

P

PAGES - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
PaginatingTask<RequestType,ResultType> - Class in com.amazon.titan.diskstorage.dynamodb
Paginator base class for scan and query workers.
PaginatingTask(DynamoDBDelegate, String, String) - Constructor for class com.amazon.titan.diskstorage.dynamodb.PaginatingTask
 
parallelGetItem(List<GetItemWorker>) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
parallelMutate(List<MutateWorker>) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
parallelQuery(List<QueryWorker>) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
ParallelScanner - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Class lazily loads all the pages of all the segments of a parallel scan, in multiple threads.
ParallelScanner(Executor, int, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner
 
processDynamoDBAPIException(Throwable, String, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
processLine(TitanGraph, MarvelGraphFactory.Appeared) - Static method in class com.amazon.titan.example.MarvelGraphFactory
 
put(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleUpdateBuilder
 
put(StaticBuffer, StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
PUT_ITEM - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
putItem(PutItemRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 

Q

QUERY - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
query(QueryRequest, int) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
QUERY_RETRIES - Static variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
QueryResultWrapper - Class in com.amazon.titan.diskstorage.dynamodb
 
QueryResultWrapper(StaticBuffer, QueryResult) - Constructor for class com.amazon.titan.diskstorage.dynamodb.QueryResultWrapper
 
QueryWithLimitWorker - Class in com.amazon.titan.diskstorage.dynamodb
QueryWorker that also enforces a limit on the total number of results it gathers before stopping.
QueryWithLimitWorker(DynamoDBDelegate, QueryRequest, StaticBuffer, int) - Constructor for class com.amazon.titan.diskstorage.dynamodb.QueryWithLimitWorker
 
QueryWorker - Class in com.amazon.titan.diskstorage.dynamodb
QueryWorker iterates through pages of DynamoDB Query results.
QueryWorker(DynamoDBDelegate, QueryRequest, StaticBuffer) - Constructor for class com.amazon.titan.diskstorage.dynamodb.QueryWorker
 

R

range(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.FilterExpressionBuilder
 
range(SliceQuery) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.FilterExpressionBuilder
 
rangeKey(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ConditionExpressionBuilder
 
rangeKey() - Method in class com.amazon.titan.diskstorage.dynamodb.builder.FilterExpressionBuilder
 
rangeKey(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ItemBuilder
 
rangeKey(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.MultiUpdateExpressionBuilder
 
readCapacity(String) - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 
readRateLimit(String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
REGISTRY - Static variable in class com.amazon.titan.example.MarvelGraphFactory
 
remove() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.MultiRecordIterator
 
remove() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner
 
remove() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanBackedKeyIterator
 
remove() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.ScanSegmentWorker
 
remove() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.SequentialScanner
 
remove() - Method in class com.amazon.titan.diskstorage.dynamodb.iterator.StaticRecordIterator
 
REPORTER - Static variable in class com.amazon.titan.example.MarvelGraphFactory
 
request - Variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
REQUIRED_BACKEND_STORES - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
result - Variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
RETRIES - Static variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
rollback() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
run() - Method in class com.amazon.titan.example.MarvelGraphFactory.AppearedCommand
 
run() - Method in class com.amazon.titan.example.MarvelGraphFactory.BatchCommand
 
run() - Method in class com.amazon.titan.example.MarvelGraphFactory.CharacterCreationCommand
 
run() - Method in class com.amazon.titan.example.MarvelGraphFactory.ComicBookCreationCommand
 
runWithBackoff() - Method in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 

S

SCAN - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
scan(ScanRequest, int) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
SCAN_RETRIES - Static variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
scanAsync(ScanRequest, int) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
ScanBackedKeyIterator - Class in com.amazon.titan.diskstorage.dynamodb.iterator
KeyIterator that is backed by a DynamoDB scan.
ScanBackedKeyIterator(Scanner, ScanContextInterpreter) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.ScanBackedKeyIterator
 
ScanContext - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Holds the request and response for one "page" of a DynamoDB scan.
ScanContext(ScanRequest, ScanResult) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.ScanContext
 
ScanContextInterpreter - Interface in com.amazon.titan.diskstorage.dynamodb.iterator
 
scanLimit(String) - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 
Scanner - Interface in com.amazon.titan.diskstorage.dynamodb.iterator
 
ScanSegmentWorker - Class in com.amazon.titan.diskstorage.dynamodb.iterator
This class executes multiple scan requests on one segment of a table in series, as a runnable.
ScanSegmentWorker(DynamoDBDelegate, ScanRequest) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.ScanSegmentWorker
 
SequentialScanner - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Iterator that goes through a scan operation over a given DynamoDB table.
SequentialScanner(DynamoDBDelegate, ScanRequest) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.SequentialScanner
 
shutdown() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
SingleExpectedAttributeValueBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
Builder for ExpectedAttributeValue maps for updates to SINGLE records.
SingleExpectedAttributeValueBuilder() - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.SingleExpectedAttributeValueBuilder
 
SingleKeyRecordIterator - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Holds a reference to a key and a RecordIterator for entries that correspond to that key.
SingleKeyRecordIterator(StaticBuffer, RecordIterator<Entry>) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.SingleKeyRecordIterator
 
SingleRowScanInterpreter - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Turns Scan results into RecordIterators for stores using the SINGLE data model.
SingleRowScanInterpreter(SliceQuery) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.SingleRowScanInterpreter
 
SingleUpdateBuilder - Class in com.amazon.titan.diskstorage.dynamodb.builder
UpdateBuilder is responsible for building AttributeValueUpdate maps to update items in DynamoDB in the SINGLE data model.
SingleUpdateBuilder() - Constructor for class com.amazon.titan.diskstorage.dynamodb.builder.SingleUpdateBuilder
 
SingleUpdateWithCleanupWorker - Class in com.amazon.titan.diskstorage.dynamodb.mutation
 
SingleUpdateWithCleanupWorker(UpdateItemRequest, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.mutation.SingleUpdateWithCleanupWorker
 
slice(StaticBuffer, StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.EntryBuilder
 
StaticRecordIterator - Class in com.amazon.titan.diskstorage.dynamodb.iterator
Iterator for entries.
StaticRecordIterator(Iterable<Entry>) - Constructor for class com.amazon.titan.diskstorage.dynamodb.iterator.StaticRecordIterator
 
storeName - Variable in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
STORES_CAPACITY_READ - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
STORES_CAPACITY_WRITE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
STORES_DATA_MODEL - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
STORES_READ_RATE_LIMIT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
STORES_SCAN_LIMIT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
STORES_WRITE_RATE_LIMIT - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
SUBSCRIBER_THROUGHPUT_LIMIT - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 

T

tableName - Variable in class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore
 
TableNameDynamoDBStoreFactory - Class in com.amazon.titan.diskstorage.dynamodb
Creates backend store based on table name.
TableNameDynamoDBStoreFactory() - Constructor for class com.amazon.titan.diskstorage.dynamodb.TableNameDynamoDBStoreFactory
 
TITAN_HASH_KEY - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
TITAN_HASH_KEY_BYTES - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
TITAN_RANGE_KEY - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
TITAN_RANGE_KEY_BYTES - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
TITAN_USER_AGENT - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
TITAN_VALUE - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
TITAN_VALUE_BYTES - Static variable in class com.amazon.titan.diskstorage.dynamodb.Constants
 
TitanConfigUtil - Class in com.amazon.titan.diskstorage.dynamodb
 
toString() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore
 
toString() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStore
 
toString() - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreTransaction
 
transaction(DynamoDBStoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.MultiUpdateExpressionBuilder
 
transaction(DynamoDBStoreTransaction) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.SingleExpectedAttributeValueBuilder
 

U

unwrapExecutionException(ExecutionException, String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
UPDATE_ITEM - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
UPDATE_ITEM_RETRIES - Static variable in class com.amazon.titan.diskstorage.dynamodb.ExponentialBackoff
 
UPDATE_ITEM_SIZE_LIMIT - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
updateItem(UpdateItemRequest) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
UpdateItemWorker - Class in com.amazon.titan.diskstorage.dynamodb.mutation
 
UpdateItemWorker(UpdateItemRequest, DynamoDBDelegate) - Constructor for class com.amazon.titan.diskstorage.dynamodb.mutation.UpdateItemWorker
 
updatePagesHistogram(String, String, int) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
UpdateRequestWrapper - Class in com.amazon.titan.diskstorage.dynamodb.model
UpdateRequestWrapper is the MutateItemRequest implementation that chooses UpdateItemRequest
UpdateRequestWrapper(UpdateItemRequest) - Constructor for class com.amazon.titan.diskstorage.dynamodb.model.UpdateRequestWrapper
 
UpdateResultWrapper - Class in com.amazon.titan.diskstorage.dynamodb.model
UpdateResultWrapper is the MutateItemResult implementation that chooses UpdateItemResult
UpdateResultWrapper(UpdateItemResult) - Constructor for class com.amazon.titan.diskstorage.dynamodb.model.UpdateResultWrapper
 
USER_AGENT - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 

V

VALIDATION_EXCEPTION - Static variable in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
value(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.ItemBuilder
 
value(StaticBuffer) - Method in class com.amazon.titan.diskstorage.dynamodb.builder.MultiUpdateExpressionBuilder
 
valueOf(String) - Static method in enum com.amazon.titan.diskstorage.dynamodb.BackendDataModel
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.amazon.titan.diskstorage.dynamodb.BackendDataModel
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitForTableCreation(String, boolean, List<LocalSecondaryIndexDescription>, List<GlobalSecondaryIndexDescription>) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
WEAPON - Static variable in class com.amazon.titan.example.MarvelGraphFactory
 
writeCapacity(String) - Method in class com.amazon.titan.diskstorage.dynamodb.Client
 
writeRateLimit(String) - Method in class com.amazon.titan.diskstorage.dynamodb.DynamoDBDelegate
 
A B C D E F G H I K L M N O P Q R S T U V W