SnappyStoreClientDialect

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. def addExtraDriverProperties(isLoner: Boolean, props: Properties): Unit

   

   Definition Classes

   JdbcExtendedDialect

5. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

6. def beforeFetch(connection: Connection, properties: Map[String, String]): Unit

   

   Override connection specific properties to run before a select is made.

   Override connection specific properties to run before a select is made. This is in place to allow dialects that need special treatment to optimize behavior.

   connection

   The connection object

   properties

   The connection properties. This is passed through from the relation.

   Definition Classes

   JdbcDialect

7. def canHandle(url: String): Boolean

   

   Check if this dialect instance can handle a certain jdbc url.

   Check if this dialect instance can handle a certain jdbc url.

   url

   the jdbc url.

   returns

   True if the dialect can be applied on the given jdbc url.

   Definition Classes

   SnappyStoreClientDialect → JdbcDialect

   Exceptions thrown

   NullPointerException if the url is null.

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. def createSchema(schemaName: String, conn: Connection): Unit

   

   Create a new schema.

   Create a new schema.

   Definition Classes

   SnappyDataBaseDialect → JdbcExtendedDialect

10. def dropTable(tableName: String, conn: Connection, context: SQLContext, ifExists: Boolean): Unit

    

    Definition Classes

    SnappyDataBaseDialect → JdbcExtendedDialect

11. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

12. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

13. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

14. def getCatalystType(sqlType: Int, typeName: String, size: Int, md: MetadataBuilder, session: Option[SparkSession]): Option[DataType]

    

    Definition Classes

    SnappyDataBaseDialect

15. def getCatalystType(sqlType: Int, typeName: String, size: Int, md: MetadataBuilder): Option[DataType]

    

    Get the custom datatype mapping for the given jdbc meta information.

    Get the custom datatype mapping for the given jdbc meta information.

    sqlType

    The sql type (see java.sql.Types)

    typeName

    The sql type name (e.g. "BIGINT UNSIGNED")

    size

    The size of the type.

    md

    Result metadata associated with this type.

    returns

    The actual DataType (subclasses of org.apache.spark.sql.types.DataType) or null if the default type mapping should be used.

    Definition Classes

    SnappyDataBaseDialect → JdbcDialect

16. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

17. def getJDBCMetadata(dt: DataType, md: Metadata, forTableDefn: Boolean): (DataType, String, Int, Int, Int)

    

    Get JDBC metadata for a catalyst column representation.

    Get JDBC metadata for a catalyst column representation.

    See SPARK-10101 issue for similar problem. If the PR raised is merged we can update VARCHAR handling here accordingly. [UPDATE] related PRs have been merged and SPARK-10101 closed but it is only for passing through full types in CREATE TABLE and not when reading unlike what is reauired for SnappyData.

    dt

    the DataType of the column

    md

    any additional Metadata for the column

    forTableDefn

    if true then the type name string returned will be suitable for column definition in CREATE TABLE etc; the differences being that it will include size definitions for CHAR/VARCHAR and complex types will be mapped to underlying storage format rather than for display (i.e. BLOB)

    Definition Classes

    SnappyDataBaseDialect

18. def getJDBCType(dt: DataType, md: Metadata): Option[JdbcType]

    

    Look SPARK-10101 issue for similar problem.

    Look SPARK-10101 issue for similar problem. If the PR raised is ever merged we can remove this method here.

    md

    The metadata

    returns

    The new JdbcType if there is an override for this DataType

    Definition Classes

    SnappyDataBaseDialect → JdbcExtendedDialect

19. def getJDBCType(dt: DataType): Option[JdbcType]

    

    Retrieve the jdbc / sql type for a given datatype.

    Retrieve the jdbc / sql type for a given datatype.

    dt

    The datatype (e.g. org.apache.spark.sql.types.StringType)

    returns

    The new JdbcType if there is an override for this DataType

    Definition Classes

    SnappyDataBaseDialect → JdbcDialect

20. def getPartitionByClause(col: String): String

    

    Definition Classes

    SnappyDataBaseDialect → JdbcExtendedDialect

21. def getSchemaQuery(table: String): String

    

    The SQL query that should be used to discover the schema of a table.

    The SQL query that should be used to discover the schema of a table. It only needs to ensure that the result set has the same schema as the table, such as by calling "SELECT * ...". Dialects can override this method to return a query that works best in a particular database.

    table

    The name of the table.

    returns

    The SQL query to use for discovering the schema.

    Definition Classes

    SnappyDataBaseDialect → JdbcDialect

22. def getTableExistsQuery(table: String): String

    

    Get the SQL query that should be used to find if the given table exists.

    Get the SQL query that should be used to find if the given table exists. Dialects can override this method to return a query that works best in a particular database.

    table

    The name of the table.

    returns

    The SQL query to use for checking the table.

    Definition Classes

    SnappyDataBaseDialect → JdbcDialect

23. def initializeTable(tableName: String, caseSensitive: Boolean, conn: Connection): Unit

    

    Definition Classes

    SnappyDataBaseDialect → JdbcExtendedDialect

24. def isCascadingTruncateTable(): Option[Boolean]

    

    Return Some[true] iff TRUNCATE TABLE causes cascading default.

    Return Some[true] iff TRUNCATE TABLE causes cascading default. Some[true] : TRUNCATE TABLE causes cascading. Some[false] : TRUNCATE TABLE does not cause cascading. None: The behavior of TRUNCATE TABLE is unknown (default).

    Definition Classes

    JdbcDialect

25. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

26. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

27. final def notify(): Unit

    

    Definition Classes

    AnyRef

28. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

29. def quoteIdentifier(colName: String): String

    

    Quotes the identifier.

    Quotes the identifier. This is used to put quotes around the identifier in case the column name is a reserved keyword, or in case it contains characters that require quotes (e.g. space).

    Definition Classes

    JdbcDialect

30. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

31. def tableExists(table: String, conn: Connection, context: SQLContext): Boolean

    

    Query string to check for existence of a table

    Query string to check for existence of a table

    Definition Classes

    SnappyDataBaseDialect → JdbcExtendedDialect

32. def truncateTable(tableName: String): String

    

    Get the DDL to truncate a table, or null/empty if truncate is not supported.

    Get the DDL to truncate a table, or null/empty if truncate is not supported.

    Definition Classes

    JdbcExtendedDialect

33. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

34. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

35. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )