org.apache.spark.sql.jdbc

Class MySQLDialect

java.lang.Object

org.apache.spark.sql.jdbc.MySQLDialect

public class MySQLDialect
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MySQLDialect()

Method Summary

Methods

Modifier and Type	Method and Description
static void	beforeFetch(java.sql.Connection connection, scala.collection.immutable.Map<java.lang.String,java.lang.String> properties)
abstract static boolean	canEqual(java.lang.Object that)
static boolean	canHandle(java.lang.String url)
abstract static boolean	equals(java.lang.Object that)
static scala.Option<DataType>	getCatalystType(int sqlType, java.lang.String typeName, int size, MetadataBuilder md)
static scala.Option<JdbcType>	getJDBCType(DataType dt)
static java.lang.String	getTableExistsQuery(java.lang.String table)
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
static java.lang.String	quoteIdentifier(java.lang.String colName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MySQLDialect

public MySQLDialect()

Method Detail

canHandle

public static boolean canHandle(java.lang.String url)

getCatalystType

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

quoteIdentifier

public static java.lang.String quoteIdentifier(java.lang.String colName)

getTableExistsQuery

public static java.lang.String getTableExistsQuery(java.lang.String table)

getJDBCType

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

beforeFetch

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

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

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

productPrefix

public static java.lang.String productPrefix()