trait IngestionStorageBackend[DB_BATCH] extends AnyRef
- Alphabetic
- By Inheritance
- IngestionStorageBackend
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def batch(dbDtos: Vector[DbDto], stringInterning: StringInterning): DB_BATCH
The CPU intensive batching operation hides the batching logic, and the mapping to the database specific representation of the inserted data.
The CPU intensive batching operation hides the batching logic, and the mapping to the database specific representation of the inserted data. This should be pure CPU logic without IO.
- dbDtos
is a collection of DbDto from which the batch is formed
- stringInterning
will be used to switch ingested strings to the internal integers
- returns
the database-specific batch DTO, which can be inserted via insertBatch
- abstract def deletePartiallyIngestedData(ledgerEnd: LedgerEnd)(connection: Connection): Unit
Deletes all partially ingested data, written during a non-graceful stop of previous indexing.
Deletes all partially ingested data, written during a non-graceful stop of previous indexing. No significant CPU load, mostly blocking JDBC communication with the database backend.
- ledgerEnd
the current ledger end, or None if no ledger end exists
- connection
to be used when inserting the batch
- abstract def insertBatch(connection: Connection, batch: DB_BATCH): Unit
Using a JDBC connection, a batch will be inserted into the database.
Using a JDBC connection, a batch will be inserted into the database. No significant CPU load, mostly blocking JDBC communication with the database backend.
- connection
to be used when inserting the batch
- batch
to be inserted
Concrete 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() @IntrinsicCandidate()
- 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
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- 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() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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