Packages

o

com.datasolvr.services.spark

DatabaseUtils

object DatabaseUtils

Utility class with methods to help export data frames to a database

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

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() @HotSpotIntrinsicCandidate()
  6. def databaseUrl(database: String, connection: ConnectionInfo): String

    Builds the URL for connecting to a database through JDBC.

    Builds the URL for connecting to a database through JDBC.

    database

    The name of the database.

    connection

    The 

    ConnectionInfo
  7. def deleteRows(scope: PipelineExecutionScopeApi, table: String, database: String, connection: String, filter: Option[String]): Unit

    Deletes rows from a table that match a given filter.

    Deletes rows from a table that match a given filter.

    scope

    The 

    PipelineExecutionScopeApi
    table

    The table to delete data from.

    database

    The name of the database.

    connection

    The unique ID of the connection object.

    filter

    The filter describing what rows to delete. Leave empty to truncate the table.

  8. def deleteRows(databaseUrl: String, table: String, filter: Option[String]): Unit

    Deletes rows from a table that match a given filter.

    Deletes rows from a table that match a given filter.

    databaseUrl

    The URL for connecting to the database.

    table

    The table to delete data from.

    filter

    The filter describing what rows to delete. Leave empty to truncate the table.

  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  11. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. def insertFrame(frame: DataFrame, scope: PipelineExecutionScopeApi, table: String, database: String, connection: String, properties: Properties = new Properties()): Unit

    Deletes rows from a table that match a given filter.

    Deletes rows from a table that match a given filter.

    frame

    The 

    DataFrame
    scope

    The 

    PipelineExecutionScopeApi
    table

    The table to delete data from.

    database

    The name of the database.

    connection

    The unique ID of the connection object.

    properties

    The 

    Properties
  14. def insertFrame(frame: DataFrame, databaseUrl: String, table: String, properties: Properties): Unit

    Insert a data frame into a database.

    Insert a data frame into a database.

    frame

    The 

    DataFrame
    databaseUrl

    The URL for connecting to the database.

    table

    The table to delete data from.

    properties

    The 

    Properties
  15. def insertOrUpdateFrame(frame: DataFrame, scope: PipelineExecutionScopeApi, table: String, database: String, connection: String, keyColumns: List[String], properties: Properties = new Properties()): Unit

    Deletes rows from a table that match a given filter.

    Deletes rows from a table that match a given filter.

    frame

    The 

    DataFrame
    scope

    The 

    PipelineExecutionScopeApi
    table

    The table to delete data from.

    database

    The name of the database.

    connection

    The unique ID of the connection object.

    keyColumns

    The list of columns whose combined values determine the rows to delete before the insert.

    properties

    The 

    Properties
  16. def insertOrUpdateFrame(frame: DataFrame, databaseUrl: String, table: String, keyColumns: List[String], properties: Properties): Unit

    Deletes rows from a table that match a given filter.

    Deletes rows from a table that match a given filter.

    frame

    The 

    DataFrame
    databaseUrl

    The URL for connecting to the database.

    table

    The table to delete data from.

    keyColumns

    The list of columns whose combined values determine the rows to delete before the insert.

    properties

    The 

    Properties
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  21. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  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()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped