Packages

trait CustomIngest extends Util

Linear Supertypes
Util, AnyRef, Any
Known Subclasses
IngestionSession
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CustomIngest
  2. Util
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. case class NormalizedAttribute(rawAttributeName: String, columnAlias: String, hiveDdlType: String, upcastExpr: Option[String]) extends Product with Serializable
    Definition Classes
    Util

Abstract Value Members

  1. abstract def customParameters: JsObject
    Attributes
    protected
  2. abstract def process: JsValue
    Attributes
    protected
    Definition Classes
    CustomIngest → Util

Concrete 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. implicit val AttributeSchemaReads: Reads[NormalizedAttribute]
    Definition Classes
    Util
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. def close: Unit
    Attributes
    protected
    Definition Classes
    Util
  8. lazy val cloud: String
    Attributes
    protected
    Definition Classes
    Util
  9. implicit val config: Aux[MacroOptions]
    Definition Classes
    Util
  10. lazy val connectionId: Option[Int]
    Attributes
    protected
    Definition Classes
    Util
  11. def convertToObject(j: JsValue): Object
    Attributes
    protected
    Definition Classes
    Util
  12. def coreApiCall(route: String, verb: String = "GET", body: Option[JsValue] = None): JsValue
    Attributes
    protected
    Definition Classes
    Util
  13. val coreUri: String
    Attributes
    protected
    Definition Classes
    Util
  14. lazy val datalakePath: String
    Attributes
    protected
  15. lazy val destFilePath: String
    Attributes
    protected
  16. def endProcess(parameters: JsObject): Unit
    Attributes
    protected
    Definition Classes
    Util
  17. lazy val environment: String
    Attributes
    protected
    Definition Classes
    Util
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  20. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  21. lazy val forceCaseInsensitiveFlag: Boolean
    Attributes
    protected
  22. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. def getConnectionParameters: JsObject
    Attributes
    protected
    Definition Classes
    Util
  24. def getProcessSourceName(processId: Int): String
    Attributes
    protected
    Definition Classes
    Util
  25. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  26. lazy val inputId: Int
    Attributes
    protected
  27. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  28. lazy val jobRunId: Option[Int]
    Attributes
    protected
    Definition Classes
    Util
  29. def logFail(e: Exception): Unit
    Attributes
    protected
    Definition Classes
    Util
  30. lazy val logId: Int
    Attributes
    protected
    Definition Classes
    CustomIngest → Util
  31. val logger: Logger
    Attributes
    protected
    Definition Classes
    Util
  32. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  33. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  34. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  35. lazy val originalProcessId: Option[Int]
    Attributes
    protected
    Definition Classes
    Util
  36. val packageName: String
    Definition Classes
    Util
  37. lazy val pgConnectionLog: Connection
    Attributes
    protected
    Definition Classes
    Util
  38. implicit lazy val pgConnectionMain: Connection
    Attributes
    protected
    Definition Classes
    Util
  39. lazy val pgConnectionString: String
    Attributes
    protected
    Definition Classes
    Util
  40. val pgConnectionStringRead: String
    Attributes
    protected
    Definition Classes
    Util
  41. lazy val processId: Int
    Attributes
    protected
    Definition Classes
    CustomIngest → Util
  42. def runIngest(getDataFrame: () ⇒ DataFrame): Unit
    Attributes
    protected
  43. lazy val smtpSenderDomain: String
    Attributes
    protected
    Definition Classes
    Util
  44. lazy val sourceId: Int
    Attributes
    protected
  45. val spark: SparkSession
    Attributes
    protected
    Definition Classes
    Util
  46. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  47. val systemConfiguration: JsValue
    Attributes
    protected
    Definition Classes
    Util
  48. def toString(): String
    Definition Classes
    AnyRef → Any
  49. val version: String
    Definition Classes
    Util
  50. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  51. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  52. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  53. def writeLog(message: String, severity: String): Unit
    Attributes
    protected
    Definition Classes
    Util
  54. def writeParsedData(inDf: DataFrame, sourceId: Int, inputId: Int, destFilePath: String, forceCaseInsensitiveFlag: Boolean): (Long, Long)
    Attributes
    protected
    Definition Classes
    Util

Inherited from Util

Inherited from AnyRef

Inherited from Any

Ungrouped