org.apache.spark.sql.jdbc

Class TeradataDialect

Object

org.apache.spark.sql.jdbc.TeradataDialect

public class TeradataDialect
extends Object

Constructor Summary

Constructors

Constructor and Description
TeradataDialect()

Method Summary

Modifier and Type	Method and Description
static void	beforeFetch(java.sql.Connection connection, scala.collection.immutable.Map<String,String> properties)
abstract static boolean	canEqual(Object that)
static boolean	canHandle(String url)
static Object	compileValue(Object value)
abstract static boolean	equals(Object that)
static scala.Option<DataType>	getCatalystType(int sqlType, String typeName, int size, MetadataBuilder md)
static scala.Option<JdbcType>	getJDBCType(DataType dt)
static String	getSchemaQuery(String table)
static String	getTableExistsQuery(String table)
static String	getTruncateQuery(String table, scala.Option<Object> cascade) The SQL query used to truncate a table.
static scala.Option<Object>	getTruncateQuery$default$2()
static scala.Option<Object>	isCascadingTruncateTable()
abstract static int	productArity()
abstract static Object	productElement(int n)
static scala.collection.Iterator<Object>	productIterator()
static String	productPrefix()
static String	quoteIdentifier(String colName)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TeradataDialect

public TeradataDialect()

Method Detail

canHandle

public static boolean canHandle(String url)

getJDBCType

public static scala.Option<JdbcType> getJDBCType(DataType dt)

isCascadingTruncateTable

public static scala.Option<Object> isCascadingTruncateTable()

getTruncateQuery

public static String getTruncateQuery(String table,
                                      scala.Option<Object> cascade)

The SQL query used to truncate a table. Teradata does not support the 'TRUNCATE' syntax that other dialects use. Instead, we need to use a 'DELETE FROM' statement.

Parameters:

table - The table to truncate.

cascade - Whether or not to cascade the truncation. Default value is the value of isCascadingTruncateTable(). Teradata does not support cascading a 'DELETE FROM' statement (and as mentioned, does not support 'TRUNCATE' syntax)

Returns:

The SQL query to use for truncating a table

getCatalystType

public static scala.Option<DataType> getCatalystType(int sqlType,
                                                     String typeName,
                                                     int size,
                                                     MetadataBuilder md)

quoteIdentifier

public static String quoteIdentifier(String colName)

getTableExistsQuery

public static String getTableExistsQuery(String table)

getSchemaQuery

public static String getSchemaQuery(String table)

getTruncateQuery$default$2

public static scala.Option<Object> getTruncateQuery$default$2()

beforeFetch

public static void beforeFetch(java.sql.Connection connection,
                               scala.collection.immutable.Map<String,String> properties)

compileValue

public static Object compileValue(Object value)

canEqual

public abstract static boolean canEqual(Object that)

equals

public abstract static boolean equals(Object that)

productElement

public abstract static Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<Object> productIterator()

productPrefix

public static String productPrefix()