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.  def build(target: SummaryEmailTargetConfig, results: ResultSet)(implicit settings: AppSettings, spark: SparkSession): Result[NotificationMessage]

   Build target output given the target configuration

   Build target output given the target configuration

   target

   Target configuration

   results

   All job results

   settings

   Implicit application settings object

   spark

   Implicit spark session object

   returns

   Target result of required type.

   Definition Classes

   SummaryNotificationBuilder → TargetBuilder

6.  def buildBody(summaryMetrics: ResultSummaryMetrics, format: TemplateFormat, template: Option[String], templateFile: Option[String])(implicit settings: AppSettings): String

   Attributes

   protected

   Definition Classes

   NotificationBuilder

7.  def buildErrorsAttachment(errors: Seq[ResultMetricError], requested: Seq[String], dumpSize: Int)(implicit settings: AppSettings): Option[BinaryAttachment]

   Attributes

   protected

   Definition Classes

   NotificationBuilder

8.  def buildFailedChecksAttachment[T <: CheckResult](checks: Seq[T], fileName: String, requested: Seq[String])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T], settings: AppSettings): Option[BinaryAttachment]

   Attributes

   protected

   Definition Classes

   NotificationBuilder

9.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... ) @native()

10.  val defaultHtmlTemplate: String

    Attributes

    protected

    Definition Classes

    SummaryNotificationBuilder → NotificationBuilder

11.  val defaultMarkdownTemplate: String

    Attributes

    protected

    Definition Classes

    SummaryNotificationBuilder → NotificationBuilder

12.  val defaultSubjectTemplate: String

    Attributes

    protected

    Definition Classes

    SummaryNotificationBuilder → NotificationBuilder

13.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

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

    Definition Classes

    AnyRef → Any

15.  def filterErrors(errors: Seq[ResultMetricError], requested: Seq[String], dumpSize: Int): Seq[ResultMetricError]

    Filters errors to be send in target.

    Filters errors to be send in target.

    errors

    Sequence of all collected metric errors

    requested

    Sequence of metric IDs for which metric errors are requested

    dumpSize

    Maximum number of errors to be collected per each metric

    returns

    Filtered sequence of metric errors

    Definition Classes

    BuildHelpers

    Note

    If requested metric IDs are not provided (sequence is empty) then errors for all metrics are returned.

16.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

18.  def getSubject(subjectTemplate: Option[String], summaryMetrics: ResultSummaryMetrics)(implicit settings: AppSettings): String

    Attributes

    protected

    Definition Classes

    NotificationBuilder

19.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

20.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

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

    Definition Classes

    AnyRef

22.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

23.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

24.  def process(target: SummaryEmailTargetConfig, results: ResultSet)(implicit jobId: String, settings: AppSettings, spark: SparkSession, connections: Map[String, DQConnection]): Result[String]

    Safely process target given the target configuration.

    Safely process target given the target configuration.

    target

    Target configuration

    results

    All job results

    returns

    "Success" string in case of successful operation or a list of errors.

    Definition Classes

    TargetProcessor

25.  def readTemplate(uri: String): Option[String]

    Safely reads template from file

    Safely reads template from file

    uri

    Path to a template file

    returns

    Template string read from path or None if read operation wasn't successful.

    Definition Classes

    BuildHelpers

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

    Definition Classes

    AnyRef

27.  val targetType: String

    Definition Classes

    SummaryTargetType

28.  def toString(): String

    Definition Classes

    AnyRef → Any

29.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

32.  def write(target: SummaryEmailTargetConfig, result: NotificationMessage)(implicit jobId: String, settings: AppSettings, spark: SparkSession, connections: Map[String, DQConnection]): Result[String]

    Writes result to required output channel given the output configuration.

    Writes result to required output channel given the output configuration.

    target

    Output configuration

    result

    Result to be written

    returns

    "Success" string in case of successful write operation or a list of errors.

    Definition Classes

    EmailWriter → OutputWriter