Package org.apache.jackrabbit.oak.segment.aws

Class DynamoDBClient

java.lang.Object

org.apache.jackrabbit.oak.segment.aws.DynamoDBClient

public final class DynamoDBClient
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	TABLE_ATTR_CONTENT

Constructor Summary

Constructors

Constructor	Description
DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb, String journalTableName, String lockTableName)
DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb, String journalTableName, String lockTableName, DynamoDBProvisioningData provisioningData)

Method Summary

Modifier and Type	Method	Description
void	batchPutDocument(String fileName, List<String> lines)
void	batchPutDocumentItems(String fileName, List<com.amazonaws.services.dynamodbv2.document.Item> items)
void	deleteAllDocuments(String fileName)
void	ensureTables()
String	getConfig()
List<String>	getDocumentContents(String fileName)
Stream<com.amazonaws.services.dynamodbv2.document.Item>	getDocumentsStream(String fileName)
com.amazonaws.services.dynamodbv2.AmazonDynamoDBLockClientOptions.AmazonDynamoDBLockClientOptionsBuilder	getLockClientOptionsBuilder()
void	putDocument(String fileName, String line)
com.amazonaws.services.dynamodbv2.document.Item	toItem(String fileName, String line)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TABLE_ATTR_CONTENT

public static final String TABLE_ATTR_CONTENT

See Also:

Constant Field Values

Constructor Detail

DynamoDBClient

public DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb,
                      String journalTableName,
                      String lockTableName)

DynamoDBClient

public DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb,
                      String journalTableName,
                      String lockTableName,
                      DynamoDBProvisioningData provisioningData)

Method Detail

ensureTables

public void ensureTables()
                  throws IOException

Throws:

IOException

getConfig

public String getConfig()

getLockClientOptionsBuilder

public com.amazonaws.services.dynamodbv2.AmazonDynamoDBLockClientOptions.AmazonDynamoDBLockClientOptionsBuilder getLockClientOptionsBuilder()

deleteAllDocuments

public void deleteAllDocuments(String fileName)
                        throws IOException

Throws:

IOException

getDocumentContents

public List<String> getDocumentContents(String fileName)
                                 throws IOException

Throws:

IOException

getDocumentsStream

public Stream<com.amazonaws.services.dynamodbv2.document.Item> getDocumentsStream(String fileName)
                                                                           throws IOException

Throws:

IOException

batchPutDocument

public void batchPutDocument(String fileName,
                             List<String> lines)

batchPutDocumentItems

public void batchPutDocumentItems(String fileName,
                                  List<com.amazonaws.services.dynamodbv2.document.Item> items)

putDocument

public void putDocument(String fileName,
                        String line)
                 throws IOException

Throws:

IOException

toItem

public com.amazonaws.services.dynamodbv2.document.Item toItem(String fileName,
                                                              String line)