Class DynamoDBClient
- java.lang.Object
-
- org.apache.jackrabbit.oak.segment.aws.DynamoDBClient
-
public final class DynamoDBClient extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
TABLE_ATTR_CONTENT
-
Constructor Summary
Constructors Constructor Description DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb, java.lang.String journalTableName, java.lang.String lockTableName)
DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb, java.lang.String journalTableName, java.lang.String lockTableName, DynamoDBProvisioningData provisioningData)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
batchPutDocument(java.lang.String fileName, java.util.List<java.lang.String> lines)
void
batchPutDocumentItems(java.lang.String fileName, java.util.List<com.amazonaws.services.dynamodbv2.document.Item> items)
void
deleteAllDocuments(java.lang.String fileName)
void
ensureTables()
java.lang.String
getConfig()
java.util.List<java.lang.String>
getDocumentContents(java.lang.String fileName)
java.util.stream.Stream<com.amazonaws.services.dynamodbv2.document.Item>
getDocumentsStream(java.lang.String fileName)
com.amazonaws.services.dynamodbv2.AmazonDynamoDBLockClientOptions.AmazonDynamoDBLockClientOptionsBuilder
getLockClientOptionsBuilder()
void
putDocument(java.lang.String fileName, java.lang.String line)
com.amazonaws.services.dynamodbv2.document.Item
toItem(java.lang.String fileName, java.lang.String line)
-
-
-
Field Detail
-
TABLE_ATTR_CONTENT
public static final java.lang.String TABLE_ATTR_CONTENT
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
DynamoDBClient
public DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb, java.lang.String journalTableName, java.lang.String lockTableName)
-
DynamoDBClient
public DynamoDBClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddb, java.lang.String journalTableName, java.lang.String lockTableName, DynamoDBProvisioningData provisioningData)
-
-
Method Detail
-
ensureTables
public void ensureTables() throws java.io.IOException
- Throws:
java.io.IOException
-
getConfig
public java.lang.String getConfig()
-
getLockClientOptionsBuilder
public com.amazonaws.services.dynamodbv2.AmazonDynamoDBLockClientOptions.AmazonDynamoDBLockClientOptionsBuilder getLockClientOptionsBuilder()
-
deleteAllDocuments
public void deleteAllDocuments(java.lang.String fileName) throws java.io.IOException
- Throws:
java.io.IOException
-
getDocumentContents
public java.util.List<java.lang.String> getDocumentContents(java.lang.String fileName) throws java.io.IOException
- Throws:
java.io.IOException
-
getDocumentsStream
public java.util.stream.Stream<com.amazonaws.services.dynamodbv2.document.Item> getDocumentsStream(java.lang.String fileName) throws java.io.IOException
- Throws:
java.io.IOException
-
batchPutDocument
public void batchPutDocument(java.lang.String fileName, java.util.List<java.lang.String> lines)
-
batchPutDocumentItems
public void batchPutDocumentItems(java.lang.String fileName, java.util.List<com.amazonaws.services.dynamodbv2.document.Item> items)
-
putDocument
public void putDocument(java.lang.String fileName, java.lang.String line) throws java.io.IOException
- Throws:
java.io.IOException
-
toItem
public com.amazonaws.services.dynamodbv2.document.Item toItem(java.lang.String fileName, java.lang.String line)
-
-