class RocksDBFileMapping extends AnyRef
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- RocksDBFileMapping
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new RocksDBFileMapping()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clear(): Unit
Clear everything stored in the file mapping.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def createSnapshotFileMapping(fileManager: RocksDBFileManager, checkpointDir: File, version: Long): (String, Map[String, RocksDBSnapshotFile])
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getDfsFileForLoad(fileManager: RocksDBFileManager, localFileName: String, versionToLoad: Long): Option[RocksDBImmutableFile]
Get the mapped DFS file for the given local file for a DFS load operation.
Get the mapped DFS file for the given local file for a DFS load operation. If the currently mapped DFS file was mapped in the same or newer version as the version we want to load (or was generated in a version which has not been uploaded to DFS yet), the mapped DFS file is ignored. In this scenario, the local mapping to this DFS file will be cleared, and function will return None.
- returns
- Option with the DFS file or None
- Note
For same version number, this is because we want to make sure we are using the latest files in DFS, in case the previous zip file has been overwritten in DFS.
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def mapToDfsFile(localFileName: String, dfsFile: RocksDBImmutableFile, version: Long): Unit
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def remove(localFileName: String): Unit
- val snapshotsPendingUpload: Set[RocksDBVersionSnapshotInfo]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- RocksDBFileMapping → AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)