org.apache.spark.sql.jdbc

Class DB2Dialect

Object

org.apache.spark.sql.jdbc.DB2Dialect

public class DB2Dialect
extends Object

Constructor Summary

Constructors

Constructor and Description
DB2Dialect()

Method Summary

Methods

Modifier and Type	Method and Description
static void	beforeFetch(java.sql.Connection connection, scala.collection.immutable.Map<String,String> properties)
static boolean	canHandle(String url)
static scala.Option<DataType>	getCatalystType(int sqlType, String typeName, int size, MetadataBuilder md)
static scala.Option<JdbcType>	getJDBCType(DataType dt)
static String	getTableExistsQuery(String table)
static String	quoteIdentifier(String colName)

Methods inherited from class Object

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

Constructor Detail

DB2Dialect

public DB2Dialect()

Method Detail

canHandle

public static boolean canHandle(String url)

getJDBCType

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

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)

beforeFetch

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