Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  val batchSize: Int
6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... ) @native()

7.  def close(): Unit

   Definition Classes

   DqJdbcStorageManager → DqStorageManager

8.  val db: DatabaseDef

   Attributes

   protected

9.  val dbType: DQStorageType

   Definition Classes

   DqJdbcStorageManager → SlickProfile

10.  val ds: DqStorageJdbcConnection

    Definition Classes

    DqJdbcStorageManager → DqStorageManager

11.  implicit val ec: ExecutionContextExecutor
12.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

13.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

14.  def filterByOffset[R <: MetricResult](records: Seq[R], offset: Int): Seq[R]

    Attributes

    protected

    Definition Classes

    DqStorageManager

15.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

16.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

17.  def getConnection: DqStorageConnection

    Definition Classes

    DqJdbcStorageManager → DqStorageManager

18.  def getTimeWindow(startDT: EnrichedDT, windowSize: String, windowOffset: Option[String]): (Timestamp, Timestamp)

    Attributes

    protected

    Definition Classes

    DqStorageManager

19.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

20.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

21.  def loadMetricResults[R <: MetricResult](jobId: String, metricIds: Seq[String], rule: TrendCheckRule, startDT: EnrichedDT, windowSize: String, windowOffset: Option[String])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[R], ops: DQTableOps[R]): Seq[R]

    Definition Classes

    DqJdbcStorageManager → DqStorageManager

22.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

23.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

24.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

25.  lazy val profile: JdbcProfile

    Attributes

    protected

    Definition Classes

    SlickProfile

26.  def saveErrors: Boolean

    Definition Classes

    DqStorageManager

27.  def saveResults[R <: DQEntity](results: Seq[R])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[R], ops: DQTableOps[R]): String

    Saves results to a corresponding table in storage database.

    Saves results to a corresponding table in storage database.

    R

    Type of results to be saved

    results

    Sequence of results to be saved

    ops

    Implicit table extension methods used to retrieve instance of Slick table that matches the result type.

    returns

    Results write operation status string.

    Definition Classes

    DqJdbcStorageManager → DqStorageManager

    Note

    Results are saved with use of upsert logic. Thus, existing records that conflicts with new ones by unique constraint are found first. Then, these records replaced with new ones and remaining records are appended to the table. Process of finding conflicting records involves multiple logical operators chaining that might lead to stack overflow error in Slick (see https://github.com/slick/slick/issues/1606). In order to avoid such error a sequence of results is split into batches of batchSize and upsert operation is performed per each batch separately.

28.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

29.  val tables: Tables

    Definition Classes

    DqJdbcStorageManager → DqStorageManager

30.  def toString(): String

    Definition Classes

    AnyRef → Any

31.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

32.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

33.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()