Packages

trait CustomParse extends Util

Linear Supertypes
Util, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CustomParse
  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
    CustomParseUtil

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