Package 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 Details

    • NoopDialect

      public NoopDialect()

  • Method Details

    • canHandle

      public static boolean canHandle(String url)

    • LogStringContext

      public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)

    • getCatalystType

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

    • getJDBCType

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

    • convertJavaTimestampToTimestamp

      public static Timestamp convertJavaTimestampToTimestamp(Timestamp t)

    • convertJavaDateToDate

      public static Date convertJavaDateToDate(Date d)

    • getYearMonthIntervalAsMonths

      public static int getYearMonthIntervalAsMonths(String yearmonthStr)

    • getDayTimeIntervalAsMicros

      public static long getDayTimeIntervalAsMicros(String daytimeStr)

    • convertJavaTimestampToTimestampNTZ

      public static LocalDateTime convertJavaTimestampToTimestampNTZ(Timestamp t)

    • convertTimestampNTZToJavaTimestamp

      public static Timestamp convertTimestampNTZToJavaTimestamp(LocalDateTime ldt)

    • createConnectionFactory

      public static scala.Function1<Object,Connection> createConnectionFactory(org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

    • quoteIdentifier

      public static String quoteIdentifier(String colName)

    • createTable

      public static void createTable(Statement statement, String tableName, String strSchema, org.apache.spark.sql.execution.datasources.jdbc.JdbcOptionsInWrite options)

    • insertIntoTable

      public static String insertIntoTable(String table, StructField[] fields)

    • getTableExistsQuery

      public static String getTableExistsQuery(String table)

    • getSchemaQuery

      public static String getSchemaQuery(String table)

    • getTruncateQuery

      public static String getTruncateQuery(String table)

    • getTruncateQuery

      public static String getTruncateQuery(String table, scala.Option<Object> cascade)

    • getTruncateQuery$default$2

      public static scala.Option<Object> getTruncateQuery$default$2()

    • beforeFetch

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

    • compileValue

      public static Object compileValue(Object value)

    • isSupportedFunction

      public static boolean isSupportedFunction(String funcName)

    • compileExpression

      public static scala.Option<String> compileExpression(Expression expr)

    • compileAggregate

      public static scala.Option<String> compileAggregate(AggregateFunc aggFunction)

    • functions

      public static scala.collection.immutable.Seq<scala.Tuple2<String,UnboundFunction>> functions()

    • createSchema

      public static void createSchema(Statement statement, String schema, String comment)

    • schemasExists

      public static boolean schemasExists(Connection conn, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options, String schema)

    • listSchemas

      public static String[][] listSchemas(Connection conn, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

    • isCascadingTruncateTable

      public static scala.Option<Object> isCascadingTruncateTable()

    • isSyntaxErrorBestEffort

      public static boolean isSyntaxErrorBestEffort(SQLException exception)

    • renameTable

      public static String renameTable(String oldTable, String newTable)

    • renameTable

      public static String renameTable(Identifier oldTable, Identifier newTable)

    • alterTable

      public static String[] alterTable(String tableName, scala.collection.immutable.Seq<TableChange> changes, int dbMajorVersion)

    • getAddColumnQuery

      public static String getAddColumnQuery(String tableName, String columnName, String dataType)

    • getRenameColumnQuery

      public static String getRenameColumnQuery(String tableName, String columnName, String newName, int dbMajorVersion)

    • getDeleteColumnQuery

      public static String getDeleteColumnQuery(String tableName, String columnName)

    • getUpdateColumnTypeQuery

      public static String getUpdateColumnTypeQuery(String tableName, String columnName, String newDataType)

    • getUpdateColumnNullabilityQuery

      public static String getUpdateColumnNullabilityQuery(String tableName, String columnName, boolean isNullable)

    • getTableCommentQuery

      public static String getTableCommentQuery(String table, String comment)

    • getSchemaCommentQuery

      public static String getSchemaCommentQuery(String schema, String comment)

    • removeSchemaCommentQuery

      public static String removeSchemaCommentQuery(String schema)

    • dropSchema

      public static String dropSchema(String schema, boolean cascade)

    • dropTable

      public static String dropTable(String table)

    • createIndex

      public static String createIndex(String indexName, Identifier tableIdent, NamedReference[] columns, Map<NamedReference,Map<String,String>> columnsProperties, Map<String,String> properties)

    • indexExists

      public static boolean indexExists(Connection conn, String indexName, Identifier tableIdent, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

    • dropIndex

      public static String dropIndex(String indexName, Identifier tableIdent)

    • listIndexes

      public static TableIndex[] listIndexes(Connection conn, Identifier tableIdent, org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

    • isObjectNotFoundException

      public static boolean isObjectNotFoundException(SQLException e)

    • classifyException

      public static Throwable classifyException(Throwable e, String condition, scala.collection.immutable.Map<String,String> messageParameters, String description, boolean isRuntime)

    • classifyException

      public static AnalysisException classifyException(String message, Throwable e)

    • getLimitClause

      public static String getLimitClause(Integer limit)

    • getOffsetClause

      public static String getOffsetClause(Integer offset)

    • getJdbcSQLQueryBuilder

      public static JdbcSQLQueryBuilder getJdbcSQLQueryBuilder(org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions options)

    • supportsLimit

      public static boolean supportsLimit()

    • supportsOffset

      public static boolean supportsOffset()

    • supportsTableSample

      public static boolean supportsTableSample()

    • getTableSample

      public static String getTableSample(org.apache.spark.sql.execution.datasources.v2.TableSampleInfo sample)

    • supportsHint

      public static boolean supportsHint()

    • supportsJoin

      public static boolean supportsJoin()

    • getFullyQualifiedQuotedTableName

      public static String getFullyQualifiedQuotedTableName(Identifier ident)

    • updateExtraColumnMeta

      public static void updateExtraColumnMeta(Connection conn, ResultSetMetaData rsmd, int columnIdx, MetadataBuilder metadata)

    • org$apache$spark$internal$Logging$$log_

      public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

    • org$apache$spark$internal$Logging$$log__$eq

      public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)