Packages

object Pg extends Util

Utility class to query postgres metadata and execute API calls.

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

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. def endProcess(parameters: JsObject): Unit
    Attributes
    protected
    Definition Classes
    Util
  15. lazy val environment: String
    Attributes
    protected
    Definition Classes
    Util
  16. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  18. def execute(query: String): Boolean

    Execute sql query

    Execute sql query

    query

    SQL string to execute

    returns

    Boolean true if execution returned results, otherwise false

  19. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  20. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  21. def getConnectionParameters: JsObject
    Attributes
    protected
    Definition Classes
    Util
  22. def getProcessSourceName(processId: Int): String
    Attributes
    protected
    Definition Classes
    Util
  23. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. lazy val jobRunId: Option[Int]
    Attributes
    protected
    Definition Classes
    Util
  26. def logFail(e: Exception): Unit
    Attributes
    protected
    Definition Classes
    Util
  27. val logId: Int
    Attributes
    protected
    Definition Classes
    Pg → Util
  28. val logger: Logger
    Attributes
    protected
    Definition Classes
    Util
  29. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  32. lazy val originalProcessId: Option[Int]
    Attributes
    protected
    Definition Classes
    Util
  33. val packageName: String
    Definition Classes
    Util
  34. lazy val pgConnectionLog: Connection
    Attributes
    protected
    Definition Classes
    Util
  35. implicit lazy val pgConnectionMain: Connection
    Attributes
    protected
    Definition Classes
    Util
  36. lazy val pgConnectionString: String
    Attributes
    protected
    Definition Classes
    Util
  37. val pgConnectionStringRead: String
    Attributes
    protected
    Definition Classes
    Util
  38. val process: Null
    Attributes
    protected
    Definition Classes
    Pg → Util
  39. val processId: Int
    Attributes
    protected
    Definition Classes
    Pg → Util
  40. def pull(sourceId: Int): Unit

    Initiates data pull (input) from the source

    Initiates data pull (input) from the source

    sourceId

    Int source id

  41. def select(query: String): DataFrame

    Execute select sql query

    Execute select sql query

    query

    SQL string to execute

    returns

    dataframe with results

  42. lazy val smtpSenderDomain: String
    Attributes
    protected
    Definition Classes
    Util
  43. val spark: SparkSession
    Attributes
    protected
    Definition Classes
    Util
  44. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  45. val systemConfiguration: JsValue
    Attributes
    protected
    Definition Classes
    Util
  46. def toString(): String
    Definition Classes
    AnyRef → Any
  47. def update(query: String): Int

    Execute update sql query

    Execute update sql query

    query

    SQL string to execute

    returns

    # of rows updated

  48. val version: String
    Definition Classes
    Util
  49. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  51. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  52. def writeLog(message: String, severity: String): Unit
    Attributes
    protected
    Definition Classes
    Util
  53. 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