org.apache.spark.sql.jdbc

Class MySQLDialect

Object

org.apache.spark.sql.jdbc.JdbcDialect

org.apache.spark.sql.jdbc.MySQLDialect

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

public class MySQLDialect
extends JdbcDialect
implements scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MySQLDialect()

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	canHandle(String url)
static scala.Option<DataType>	getCatalystType(int sqlType, String typeName, int size, MetadataBuilder md)
static String	getTableExistsQuery(String table)
static String	quoteIdentifier(String colName)

Methods inherited from class org.apache.spark.sql.jdbc.JdbcDialect

beforeFetch, canHandle, getCatalystType, getJDBCType, getTableExistsQuery, quoteIdentifier

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

MySQLDialect

public MySQLDialect()

Method Detail

canHandle

public static boolean canHandle(String url)

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)