Packages

implicit class ResultsSerializationOps[T <: DQEntity] extends AnyRef

Implicit conversion for results to enable their unified serialization.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ResultsSerializationOps
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ResultsSerializationOps(value: T)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T], settings: AppSettings)

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 clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def getFieldsMap: Map[String, String]

    Gets flattened map of field name to string representation of field values.

    Gets flattened map of field name to string representation of field values.

    returns

    Map fieldName -> fieldValue as string

  11. def getTsvHeader: String

    Getter to retrieve TSV header (conforms to flattened tsv string)

  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  18. def toJson: String

    Serialize result entity into unified JSON string.

    Serialize result entity into unified JSON string.

    returns

    JSON string with result data

  19. def toRow: Row

    Serialize result entity into unified Spark Row that match unified schema.

    Serialize result entity into unified Spark Row that match unified schema.

    returns

    Spark Row with result data

    Note

    Data field contains Json string with data specific to given result entity.

  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. def toTsvString: String

    Serialize result entity into tab-separated string retaining order in which fields were defined.

    Serialize result entity into tab-separated string retaining order in which fields were defined.

    returns

    Tab-separated strung with result data

    Note

    This string has a flat structure and does not conform to unified schema. Used to generate attachments for notifications. Thus, tsv format with flat structure is more appropriated for visual inspection.

  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped