Package one.microstream.afs.oracle.coherence.types

Class OracleCoherenceConnector.Default

java.lang.Object

one.microstream.afs.blobstore.types.BlobStoreConnector.Abstract<BlobMetadata>

one.microstream.afs.oracle.coherence.types.OracleCoherenceConnector.Default

All Implemented Interfaces:

AutoCloseable, BlobStoreConnector, OracleCoherenceConnector

Enclosing interface:

OracleCoherenceConnector

public static class OracleCoherenceConnector.Default
extends BlobStoreConnector.Abstract<BlobMetadata>
implements OracleCoherenceConnector

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.oracle.coherence.types.OracleCoherenceConnector

OracleCoherenceConnector.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 Stream<BlobMetadata>	blobs(BlobStorePath file)
protected Stream<String>	childKeys(BlobStorePath directory)
protected boolean	internalDeleteBlobs(BlobStorePath file, List<? extends BlobMetadata> blobs)
protected boolean	internalDeleteFile(BlobStorePath file)
protected long	internalFileSize(BlobStorePath file)
protected void	internalMoveFile(BlobStorePath sourceFile, BlobStorePath targetFile)
protected void	internalReadBlobData(BlobStorePath file, BlobMetadata metadata, 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, blobNumber, childKeysRegex, childKeysRegexWithContainer, close, copyFile, createDirectory, createFile, deleteFile, directoryExists, directoryNameOfKey, ensureOpen, fileExists, fileNameOfKey, fileSize, internalClose, internalCopyFile, internalCreateDirectory, internalCreateFile, internalDirectoryExists, internalFileExists, internalIsEmpty, 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

blobs

protected Stream<BlobMetadata> blobs(BlobStorePath file)

Specified by:

blobs in class BlobStoreConnector.Abstract<BlobMetadata>

childKeys

protected Stream<String> childKeys(BlobStorePath directory)

Specified by:

childKeys in class BlobStoreConnector.Abstract<BlobMetadata>

internalFileSize

protected long internalFileSize(BlobStorePath file)

Overrides:

internalFileSize in class BlobStoreConnector.Abstract<BlobMetadata>

internalReadBlobData

protected void internalReadBlobData(BlobStorePath file, BlobMetadata metadata, ByteBuffer targetBuffer, long offset, long length)

Specified by:

internalReadBlobData in class BlobStoreConnector.Abstract<BlobMetadata>

internalDeleteFile

protected boolean internalDeleteFile(BlobStorePath file)

Overrides:

internalDeleteFile in class BlobStoreConnector.Abstract<BlobMetadata>

internalDeleteBlobs

protected boolean internalDeleteBlobs(BlobStorePath file, List<? extends BlobMetadata> blobs)

Specified by:

internalDeleteBlobs in class BlobStoreConnector.Abstract<BlobMetadata>

internalWriteData

protected long internalWriteData(BlobStorePath file, Iterable<? extends ByteBuffer> sourceBuffers)

Specified by:

internalWriteData in class BlobStoreConnector.Abstract<BlobMetadata>

internalMoveFile

protected void internalMoveFile(BlobStorePath sourceFile, BlobStorePath targetFile)

Overrides:

internalMoveFile in class BlobStoreConnector.Abstract<BlobMetadata>