Class DynamoDbConnector.Default
java.lang.Object
one.microstream.afs.blobstore.types.BlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
one.microstream.afs.aws.dynamodb.types.DynamoDbConnector.Default
- All Implemented Interfaces:
AutoCloseable
,DynamoDbConnector
,BlobStoreConnector
- Enclosing interface:
- DynamoDbConnector
public static class DynamoDbConnector.Default extends BlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>> implements DynamoDbConnector
-
Nested Class Summary
Nested classes/interfaces inherited from interface one.microstream.afs.blobstore.types.BlobStoreConnector
BlobStoreConnector.Abstract<B>
Nested classes/interfaces inherited from interface one.microstream.afs.aws.dynamodb.types.DynamoDbConnector
DynamoDbConnector.Default
-
Field Summary
Fields inherited from class one.microstream.afs.blobstore.types.BlobStoreConnector.Abstract
NUMBER_SUFFIX_REGEX, NUMBER_SUFFIX_SEPARATOR, NUMBER_SUFFIX_SEPARATOR_CHAR
-
Method Summary
Modifier and Type Method Description protected long
blobNumber(Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> blob)
protected Stream<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
blobs(BlobStorePath file)
protected Stream<String>
childKeys(BlobStorePath directory)
protected String
fileNameOfKey(String key)
protected boolean
internalDeleteBlobs(BlobStorePath file, List<? extends Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>> blobs)
protected boolean
internalFileExists(BlobStorePath file)
protected void
internalReadBlobData(BlobStorePath file, Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> blob, ByteBuffer targetBuffer, long offset, long length)
protected long
internalWriteData(BlobStorePath file, Iterable<? extends ByteBuffer> sourceBuffers)
Methods inherited from class one.microstream.afs.blobstore.types.BlobStoreConnector.Abstract
blobComparator, blobKeyRegex, childKeysRegex, childKeysRegexWithContainer, close, copyFile, createDirectory, createFile, deleteFile, directoryExists, directoryNameOfKey, ensureOpen, fileExists, fileSize, internalClose, internalCopyFile, internalCreateDirectory, internalCreateFile, internalDeleteFile, internalDirectoryExists, internalFileSize, internalIsEmpty, internalMoveFile, internalReadData, internalReadData, internalReadData, internalTruncateFile, internalVisitChildren, isBlobKey, isDirectoryKey, isEmpty, moveFile, nextBlobNumber, readData, readData, removeNumberSuffix, toBlobKey, toBlobKeyPrefix, toBlobKeyPrefixWithContainer, toBlobKeyWithContainer, toChildKeysPrefix, toChildKeysPrefixWithContainer, toContainerKey, totalSize, truncateFile, visitChildren, writeData
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface one.microstream.afs.blobstore.types.BlobStoreConnector
close, copyFile, createDirectory, createFile, deleteFile, directoryExists, fileExists, fileSize, isEmpty, moveFile, readData, readData, truncateFile, visitChildren, writeData
-
Method Details
-
blobNumber
protected long blobNumber(Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> blob)- Overrides:
blobNumber
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-
blobs
protected Stream<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>> blobs(BlobStorePath file)- Specified by:
blobs
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-
childKeys
- Specified by:
childKeys
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-
fileNameOfKey
- Overrides:
fileNameOfKey
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-
internalFileExists
- Overrides:
internalFileExists
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-
internalReadBlobData
protected void internalReadBlobData(BlobStorePath file, Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> blob, ByteBuffer targetBuffer, long offset, long length)- Specified by:
internalReadBlobData
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-
internalDeleteBlobs
protected boolean internalDeleteBlobs(BlobStorePath file, List<? extends Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>> blobs)- Specified by:
internalDeleteBlobs
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-
internalWriteData
- Specified by:
internalWriteData
in classBlobStoreConnector.Abstract<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>>
-