class InMemoryUCCommitCoordinator extends AnyRef
A mock UC commit coordinator for testing purposes.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- InMemoryUCCommitCoordinator
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new InMemoryUCCommitCoordinator()
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 clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def commitToCoordinator(tableId: String, tableUri: URI, commitFileName: Option[String] = None, commitVersion: Option[Long] = None, commitFileSize: Option[Long] = None, commitFileModTime: Option[Long] = None, commitTimestamp: Option[Long] = None, lastKnownBackfilledVersion: Option[Long] = None, isDisownCommit: Boolean = false, protocolOpt: Option[AbstractProtocol] = None, metadataOpt: Option[AbstractMetadata] = None): Unit
- 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 getCommitsFromCoordinator(tableId: String, tableUri: URI, startVersion: Option[Long], endVersion: Option[Long]): GetCommitsResponse
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- var throwIOExceptionAfterCommit: Boolean
Variable to allow to control the behavior of the InMemoryUCCommitCoordinator externally.
Variable to allow to control the behavior of the InMemoryUCCommitCoordinator externally. If set to true, the coordinator will throw an IOException after a successful commit. This will be reset to false once the exception has been thrown.
- var throwIOExceptionBeforeCommit: Boolean
Variable to allow to control the behavior of the InMemoryUCCommitCoordinator externally.
Variable to allow to control the behavior of the InMemoryUCCommitCoordinator externally. If set to true, the coordinator will throw an IOException before persisting a commit to the in memory map. This will be reset to false once the exception has been thrown.
- def toString(): String
- Definition Classes
- 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)