final case class PrunableByTimeParameters(targetBatchSize: PositiveInt, initialInterval: NonNegativeFiniteDuration, maxBuckets: PositiveInt, controlFactors: Seq[ControlFactors] = PrunableByTimeParameters.DefaultControlFactors, maxItemsExpectedToPrunePerBatch: PositiveInt) extends Product with Serializable
Various parameter to control prunable by time batching (used for journal pruning)
- targetBatchSize
Defines the ideal pruning batch size. If the batches are larger than the target pruning size, the number of buckets is doubled. If they are substantially smaller than the target pruning size, the number of buckets is reduced by 10%.
- initialInterval
The start interval for the prune batching
- maxBuckets
maximum number of buckets to split a batch into (limit the iterations when nodes are inactive for quite a while)
- controlFactors
The adjustment parameters for the prune batch size computation (threshold, factor)
- maxItemsExpectedToPrunePerBatch
The maximum on the number of items expected to prune per batch. Implemented by select stores (e.g. ActiveContractStore) to help motivate database filtered index selection. Should be at least an order of magnitude larger than targetBatchSize to not interfere with dynamic bucketing after a participant node has been inactive for a while, but not excessively large to discourage scanning the entire table.
- Alphabetic
- By Inheritance
- PrunableByTimeParameters
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new PrunableByTimeParameters(targetBatchSize: PositiveInt, initialInterval: NonNegativeFiniteDuration, maxBuckets: PositiveInt, controlFactors: Seq[ControlFactors] = PrunableByTimeParameters.DefaultControlFactors, maxItemsExpectedToPrunePerBatch: PositiveInt)
- targetBatchSize
Defines the ideal pruning batch size. If the batches are larger than the target pruning size, the number of buckets is doubled. If they are substantially smaller than the target pruning size, the number of buckets is reduced by 10%.
- initialInterval
The start interval for the prune batching
- maxBuckets
maximum number of buckets to split a batch into (limit the iterations when nodes are inactive for quite a while)
- controlFactors
The adjustment parameters for the prune batch size computation (threshold, factor)
- maxItemsExpectedToPrunePerBatch
The maximum on the number of items expected to prune per batch. Implemented by select stores (e.g. ActiveContractStore) to help motivate database filtered index selection. Should be at least an order of magnitude larger than targetBatchSize to not interfere with dynamic bucketing after a participant node has been inactive for a while, but not excessively large to discourage scanning the entire table.
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]) @native()
- val controlFactors: Seq[ControlFactors]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val initialInterval: NonNegativeFiniteDuration
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxBuckets: PositiveInt
- val maxItemsExpectedToPrunePerBatch: PositiveInt
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val targetBatchSize: PositiveInt
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()