Checks if database exists.
Checks if database exists.
JDBC connection
Database name
true if database exists, false otherwise.
Executes 'describe formatted' on given table As of now, only populates columns and partitioned columns.
Executes 'describe formatted' on given table As of now, only populates columns and partitioned columns.
JDBC connection
Database name
Table name
DescribeTableOutput
Drops the table.
Drops the table.
JDBC connection
Database name
Table name
IF EXISTS option for DROP query
Set confs and execute the query.
Set confs and execute the query. Returns Updated row count.
JDBC connection
Database name
Confs to be set
Query to execute
Update Row Count
Maps a JDBC type to a Catalyst type.
Maps a JDBC type to a Catalyst type.
- A field of java.sql.Types
The Catalyst type corresponding to sqlType.
Gets all the column names of specified table
Gets all the column names of specified table
JDBC connection
Database name
Table name
array of column names
Takes a (schema, table) specification and returns the table's Catalyst schema.
Takes a (schema, table) specification and returns the table's Catalyst schema.
A JDBC connection to the database.
The database name.
The table name of the desired table. This may also be a SQL query wrapped in parentheses.
A StructType giving the table's Catalyst schema.
Compute the SQL schema string for the given Spark SQL Schema.
Compute the SQL schema string for the given Spark SQL Schema.
Checks if table exists in database.
Checks if table exists in database.
JDBC connection
Database name
Name of the table for which existence is to be checked
true if table exists in database, false otherwise.
Truncates the table.
Truncates the table.
JDBC connection
Database name
Table name
Unsets table properties.
Unsets table properties.
JDBC connection
Database name
Table name
IF EXISTS option, i.e. UNSET TBLPROPERTIES IF EXISTS...
property keys to unset