Class 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)  
      • 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 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)