com.digitalasset.canton.platform.store.backend.common
UpdateStreamingQueries
Companion class UpdateStreamingQueries
object UpdateStreamingQueries
- Alphabetic
- By Inheritance
- UpdateStreamingQueries
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def fetchEventIds(tableName: String, witnessO: Option[daml.lf.data.Ref.Party], templateIdO: Option[NameTypeConRef], idFilter: Option[CompositeSql], stringInterning: StringInterning, hasFirstPerSequentialId: Boolean)(connection: Connection): (IdFilterPaginationInput) => Vector[Long]
- tableName
one of the filter tables for create, consuming or non-consuming events
- witnessO
the party for which to fetch the event ids, if None the event ids for all the parties should be fetched
- templateIdO
NOTE: this parameter is not applicable for tree tx stream only oriented filters
- idFilter
Inside of the composable SQL the event_sequential_id-s of the candidates need to be referred as filters.event_sequential_id. EXISTS and NOT EXISTS expressions suggested to trigger pointwise iteration on target indexes.
- stringInterning
the string interning instance to use for internalizing the party and template id
- hasFirstPerSequentialId
true if the table has the first_per_sequential_id column, false otherwise. If true and witnessO is None, only a single row per event_sequential_id will be fetched and thus only unique event ids will be returned
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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()