org.apache.spark.sql.jdbc

Class NoopDialect

Object

org.apache.spark.sql.jdbc.NoopDialect

public class NoopDialect
extends Object

NOOP dialect object, always returning the neutral element.

Constructor Summary

Constructors

Constructor and Description
NoopDialect()

Method Summary

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 Object	compileValue(Object value)
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)
static scala.Option<Object>	isCascadingTruncateTable()
static String	quoteIdentifier(String colName)

Methods inherited from class Object

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

Constructor Detail

NoopDialect

public NoopDialect()

Method Detail

canHandle

public static boolean canHandle(String url)

getCatalystType

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

getJDBCType

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

quoteIdentifier

public static String quoteIdentifier(String colName)

getTableExistsQuery

public static String getTableExistsQuery(String table)

getSchemaQuery

public static String getSchemaQuery(String table)

getTruncateQuery

public static String getTruncateQuery(String table)

beforeFetch

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

compileValue

public static Object compileValue(Object value)

isCascadingTruncateTable

public static scala.Option<Object> isCascadingTruncateTable()