Packages

trait HiveWriter[T <: HiveOutputConfig] extends OutputWriter[DataFrame, T]

Linear Supertypes
OutputWriter[DataFrame, T], AnyRef, Any
Known Subclasses
ErrorCollHiveTargetProcessor, ResultHiveTargetProcessor
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. HiveWriter
  2. OutputWriter
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Concrete Value Members

  1. def write(target: T, 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