Packages

c

io.dataos.spark.dialects

TrinoDialect

class TrinoDialect extends JdbcDialect

Custom JDBC dialect for Trino.

Linear Supertypes
JdbcDialect, Logging, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TrinoDialect
  2. JdbcDialect
  3. Logging
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TrinoDialect()

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 alterTable(tableName: String, changes: Seq[TableChange], dbMajorVersion: Int): Array[String]
    Definition Classes
    JdbcDialect
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def beforeFetch(connection: Connection, properties: Map[String, String]): Unit
    Definition Classes
    JdbcDialect
  7. def canHandle(url: String): Boolean

    Checks if this dialect can handle the provided JDBC URL.

    Checks if this dialect can handle the provided JDBC URL.

    url

    The JDBC URL.

    returns

    true if this dialect can handle the URL, false otherwise.

    Definition Classes
    TrinoDialect → JdbcDialect
  8. def classifyException(message: String, e: Throwable): AnalysisException
    Definition Classes
    JdbcDialect
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  10. def compileAggregate(aggFunction: AggregateFunc): Option[String]
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "3.3.0" )
  11. def compileExpression(expr: Expression): Option[String]
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "3.3.0" )
  12. def compileValue(value: Any): Any
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "2.3.0" )
  13. def createConnectionFactory(options: JDBCOptions): (Int) ⇒ Connection
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "3.3.0" )
  14. def createIndex(indexName: String, tableName: String, columns: Array[NamedReference], columnsProperties: Map[NamedReference, Map[String, String]], properties: Map[String, String]): String
    Definition Classes
    JdbcDialect
  15. def createSchema(statement: Statement, schema: String, comment: String): Unit
    Definition Classes
    JdbcDialect
  16. def dropIndex(indexName: String, tableName: String): String
    Definition Classes
    JdbcDialect
  17. def dropSchema(schema: String, cascade: Boolean): String
    Definition Classes
    JdbcDialect
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  20. def escapeSql(value: String): String
    Attributes
    protected[jdbc]
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "2.3.0" )
  21. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  22. def getAddColumnQuery(tableName: String, columnName: String, dataType: String): String
    Definition Classes
    JdbcDialect
  23. def getCatalystType(sqlType: Int, typeName: String, size: Int, md: MetadataBuilder): Option[DataType]

    Retrieves the Catalyst type based on the provided SQL type and metadata.

    Retrieves the Catalyst type based on the provided SQL type and metadata.

    sqlType

    The SQL type.

    typeName

    The type name.

    size

    The size.

    md

    The metadata builder.

    returns

    An option containing the Catalyst data type, or None if the type is not supported.

    Definition Classes
    TrinoDialect → JdbcDialect
  24. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  25. def getDeleteColumnQuery(tableName: String, columnName: String): String
    Definition Classes
    JdbcDialect
  26. def getJDBCType(dt: DataType): Option[JdbcType]
    Definition Classes
    JdbcDialect
  27. def getLimitClause(limit: Integer): String
    Definition Classes
    JdbcDialect
  28. def getRenameColumnQuery(tableName: String, columnName: String, newName: String, dbMajorVersion: Int): String
    Definition Classes
    JdbcDialect
  29. def getSchemaCommentQuery(schema: String, comment: String): String
    Definition Classes
    JdbcDialect
  30. def getSchemaQuery(table: String): String
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "2.1.0" )
  31. def getTableCommentQuery(table: String, comment: String): String
    Definition Classes
    JdbcDialect
  32. def getTableExistsQuery(table: String): String
    Definition Classes
    JdbcDialect
  33. def getTableSample(sample: TableSampleInfo): String
    Definition Classes
    JdbcDialect
  34. def getTruncateQuery(table: String, cascade: Option[Boolean]): String
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "2.4.0" )
  35. def getTruncateQuery(table: String): String
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "2.3.0" )
  36. def getUpdateColumnNullabilityQuery(tableName: String, columnName: String, isNullable: Boolean): String
    Definition Classes
    JdbcDialect
  37. def getUpdateColumnTypeQuery(tableName: String, columnName: String, newDataType: String): String
    Definition Classes
    JdbcDialect
  38. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  39. def indexExists(conn: Connection, indexName: String, tableName: String, options: JDBCOptions): Boolean
    Definition Classes
    JdbcDialect
  40. def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  41. def initializeLogIfNecessary(isInterpreter: Boolean): Unit
    Attributes
    protected
    Definition Classes
    Logging
  42. def isCascadingTruncateTable(): Option[Boolean]
    Definition Classes
    JdbcDialect
  43. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  44. def isSupportedFunction(funcName: String): Boolean
    Definition Classes
    JdbcDialect
    Annotations
    @Since( "3.3.0" )
  45. def isTraceEnabled(): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  46. def listIndexes(conn: Connection, tableName: String, options: JDBCOptions): Array[TableIndex]
    Definition Classes
    JdbcDialect
  47. def listSchemas(conn: Connection, options: JDBCOptions): Array[Array[String]]
    Definition Classes
    JdbcDialect
  48. def log: Logger
    Attributes
    protected
    Definition Classes
    Logging
  49. def logDebug(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  50. def logDebug(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  51. def logError(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  52. def logError(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  53. def logInfo(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  54. def logInfo(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  55. def logName: String
    Attributes
    protected
    Definition Classes
    Logging
  56. def logTrace(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  57. def logTrace(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  58. def logWarning(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  59. def logWarning(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  60. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  61. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  62. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  63. def quoteIdentifier(colName: String): String
    Definition Classes
    JdbcDialect
  64. def removeSchemaCommentQuery(schema: String): String
    Definition Classes
    JdbcDialect
  65. def renameTable(oldTable: String, newTable: String): String
    Definition Classes
    JdbcDialect
  66. def schemasExists(conn: Connection, options: JDBCOptions, schema: String): Boolean
    Definition Classes
    JdbcDialect
  67. def supportsTableSample: Boolean
    Definition Classes
    JdbcDialect
  68. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  69. def toString(): String
    Definition Classes
    AnyRef → Any
  70. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  71. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  72. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from JdbcDialect

Inherited from Logging

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped