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: ResultHiveTargetConfig, results: ResultSet)(implicit settings: AppSettings, spark: SparkSession): Result[DataFrame]

   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 in form of Spark DataFrame

   Definition Classes

   ResultDataFrameBuilder → TargetBuilder

6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... ) @native()

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

   Definition Classes

   AnyRef

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

   Definition Classes

   AnyRef → Any

9.  def finalize(): Unit

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

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

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

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

11.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

12.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

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

    Definition Classes

    AnyRef

14.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

15.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

16.  def process(target: ResultHiveTargetConfig, 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

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

    Definition Classes

    AnyRef

18.  val targetType: String

    Definition Classes

    ResultTargetType

19.  def toString(): String

    Definition Classes

    AnyRef → Any

20.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

23.  def write(target: ResultHiveTargetConfig, result: DataFrame)(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

    HiveWriter → OutputWriter