org.apache.spark.sql.jdbc

Class PostgresDialect

java.lang.Object

org.apache.spark.sql.jdbc.JdbcDialect

org.apache.spark.sql.jdbc.PostgresDialect

All Implemented Interfaces:

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

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

:: DeveloperApi :: Default postgres dialect, mapping bit/cidr/inet on read and string/binary/boolean on write.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PostgresDialect()

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	canHandle(java.lang.String url)
static scala.Option<DataType>	getCatalystType(int sqlType, java.lang.String typeName, int size, MetadataBuilder md)
static scala.Option<JdbcType>	getJDBCType(DataType dt)

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

canHandle, getCatalystType, getJDBCType, quoteIdentifier

Methods inherited from class java.lang.Object

clone, equals, finalize, 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

PostgresDialect

public PostgresDialect()

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)

getJDBCType

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