Packages

t

org.apache.spark.sql.delta

DeltaErrorsBase

trait DeltaErrorsBase extends DocsPath with DeltaLogging with QueryErrorsBase

A holder object for Delta errors.

IMPORTANT: Any time you add a test that references the docs, add to the Seq defined in DeltaErrorsSuite so that the doc links that are generated can be verified to work in docs.delta.io

Linear Supertypes
QueryErrorsBase, DataTypeErrorsBase, DeltaLogging, DatabricksLogging, DeltaProgressReporter, LoggingShims, Logging, DocsPath, AnyRef, Any
Known Subclasses
DeltaErrors
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DeltaErrorsBase
  2. QueryErrorsBase
  3. DataTypeErrorsBase
  4. DeltaLogging
  5. DatabricksLogging
  6. DeltaProgressReporter
  7. LoggingShims
  8. Logging
  9. DocsPath
  10. AnyRef
  11. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. case class LogRetentionConfig(key: String, value: String, truncateHistoryRetention: String) extends Product with Serializable
  2. implicit class LogStringContext extends AnyRef
    Definition Classes
    Logging
  3. case class TemporallyUnstableInputException(userTs: Timestamp, lastCommitTs: Timestamp, maximumTsStr: String) extends DeltaAnalysisException with Product with Serializable
  4. case class TimestampEarlierThanCommitRetentionException(userTimestamp: Timestamp, commitTs: Timestamp, timestampString: String) extends AnalysisException with Product with Serializable

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. val EmptyCheckpointErrorMessage: String
  5. def actionNotFoundException(action: String, version: Long): Throwable
  6. def activeSparkSessionNotFound(): Throwable
  7. def activeTransactionAlreadySet(): Throwable
  8. def addColumnAtIndexLessThanZeroException(pos: String, col: String): Throwable
  9. def addColumnParentNotStructException(column: StructField, other: DataType): Throwable
  10. def addColumnStructNotFoundException(pos: String): Throwable
  11. def addCommentToMapArrayException(fieldPath: String): Throwable
  12. def addFilePartitioningMismatchException(addFilePartitions: Seq[String], metadataPartitions: Seq[String]): Throwable
  13. def addFileWithDVsAndTightBoundsException(): Throwable
  14. def addFileWithDVsMissingNumRecordsException: Throwable
  15. def addingColumnWithInternalNameFailed(colName: String): Throwable
  16. def addingDeletionVectorsDisallowedException(): Throwable
  17. def aggsNotSupportedException(op: String, cond: Expression): Throwable
  18. def alterClusterByNotAllowedException(): Throwable
  19. def alterClusterByNotOnDeltaTableException(): Throwable
  20. def alterTableChangeColumnException(fieldPath: String, oldField: StructField, newField: StructField): Throwable
  21. def alterTableClusterByOnPartitionedTableException(): Throwable
  22. def alterTableReplaceColumnsException(oldSchema: StructType, newSchema: StructType, reason: String): Throwable
  23. def alterTableSetClusteringTableFeatureException(tableFeature: String): Throwable
  24. def alterTableSetLocationSchemaMismatchException(original: StructType, destination: StructType): Throwable
  25. def ambiguousDataTypeChange(column: String, from: StructType, to: StructType): Throwable
  26. def ambiguousPartitionColumnException(columnName: String, colMatches: Seq[StructField]): Throwable
  27. def ambiguousPathsInCreateTableException(identifier: String, location: String): Throwable
  28. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  29. def assertValidCallingFunction(): Unit
    Definition Classes
    DocsPath
  30. def assertionFailedError(msg: String): Throwable
  31. def baseDocsPath(spark: SparkSession): String
  32. def baseDocsPath(conf: SparkConf): String

    The URL for the base path of Delta's docs.

    The URL for the base path of Delta's docs. When changing this path, ensure that the new path works with the error messages below.

    Attributes
    protected
    Definition Classes
    DocsPath
  33. def blockBatchCdfReadWithIncompatibleSchemaChange(start: Long, end: Long, readSchema: StructType, readVersion: Long, incompatVersion: Long, isSchemaChange: Boolean = true): Throwable

    If isSchemaChange is false, this means the incompatVersion actually refers to a data schema instead of a schema change.

    If isSchemaChange is false, this means the incompatVersion actually refers to a data schema instead of a schema change. This happens when we could not find any read-incompatible schema changes within the querying range, but the read schema is still NOT compatible with the data files being queried, which could happen if user falls back to legacy mode and read past data using some diverged latest schema or time-travelled schema. In this uncommon case, we should tell the user to try setting it back to endVersion, OR ask us to give them the flag to force unblock.

  34. def blockColumnMappingAndCdcOperation(op: Operation): Throwable
  35. def blockStreamingReadsWithIncompatibleNonAdditiveSchemaChanges(spark: SparkSession, readSchema: StructType, incompatibleSchema: StructType, detectedDuringStreaming: Boolean): Throwable
  36. def bloomFilterCreateOnNonExistingColumnsException(unknownColumns: Seq[String]): Throwable
  37. def bloomFilterDropOnNonExistingColumnsException(unknownColumns: Seq[String]): Throwable
  38. def bloomFilterDropOnNonIndexedColumnException(name: String): Throwable
  39. def bloomFilterInvalidParameterValueException(message: String): Throwable
  40. def bloomFilterMultipleConfForSingleColumnException(name: String): Throwable
  41. def bloomFilterOnColumnTypeNotSupportedException(name: String, dataType: DataType): Throwable
  42. def bloomFilterOnNestedColumnNotSupportedException(name: String): Throwable
  43. def bloomFilterOnPartitionColumnNotSupportedException(name: String): Throwable
  44. def canOnlyDropCheckpointProtectionWithHistoryTruncationException: DeltaTableFeatureException
  45. def cannotChangeDataType(msg: String): Throwable
  46. def cannotChangeProvider(): Throwable
  47. def cannotContinueStreamingPostSchemaEvolution(nonAdditiveSchemaChangeOpType: String, previousSchemaChangeVersion: Long, currentSchemaChangeVersion: Long, checkpointHash: Int, readerOptionsUnblock: Seq[String], sqlConfsUnblock: Seq[String], prettyColumnChangeDetails: String): Throwable
  48. def cannotCreateLogPathException(logPath: String, cause: Throwable = null): Throwable
  49. def cannotDropCheckConstraintFeature(constraintNames: Seq[String]): AnalysisException
  50. def cannotFindSourceVersionException(json: String): Throwable
  51. def cannotGenerateUpdateExpressions(): Throwable
  52. def cannotInsertIntoColumn(tableName: String, source: String, target: String, targetType: String): Throwable
  53. def cannotModifyTableProperty(prop: String): Throwable
  54. def cannotReconstructPathFromURI(uri: String): Throwable
  55. def cannotRenamePath(tempPath: String, path: String): Throwable
  56. def cannotReplaceMissingTableException(itableIdentifier: Identifier): Throwable
  57. def cannotResolveColumn(fieldName: String, schema: StructType): Throwable
  58. def cannotSetLocationMultipleTimes(locations: Seq[String]): Throwable
  59. def cannotSpecifyBothFileListAndPatternString(): Throwable
  60. def cannotUpdateArrayField(table: String, field: String): Throwable
  61. def cannotUpdateMapField(table: String, field: String): Throwable
  62. def cannotUpdateOtherField(tableName: String, dataType: DataType): Throwable
  63. def cannotUpdateStructField(table: String, field: String): Throwable
  64. def cannotUseDataTypeForPartitionColumnError(field: StructField): Throwable
  65. def cannotWriteIntoView(table: TableIdentifier): Throwable
  66. def castPartitionValueException(partitionValue: String, dataType: DataType): Throwable
  67. def castingCauseOverflowErrorInTableWrite(from: DataType, to: DataType, columnName: String): ArithmeticException
  68. def cdcColumnsInData(columns: Seq[String]): Throwable

    Thrown when main table data contains columns that are reserved for CDF, such as _change_type.

  69. def cdcNotAllowedInThisVersion(): Throwable
  70. def cdcWriteNotAllowedInThisVersion(): Throwable
  71. def changeColumnMappingModeNotSupported(oldMode: String, newMode: String): Throwable
  72. def changeDataNotRecordedException(version: Long, start: Long, end: Long): Throwable

    Throwable used when CDC is not enabled according to table metadata.

  73. def checkConstraintNotBoolean(name: String, expr: String): AnalysisException
  74. def checkpointMismatchWithSnapshot: Throwable
  75. def checkpointNonExistTable(path: Path): Throwable
  76. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  77. def cloneAmbiguousTarget(externalLocation: String, targetIdent: TableIdentifier): Throwable
  78. def cloneFromIcebergSourceWithPartitionEvolution(): Throwable
  79. def cloneFromIcebergSourceWithoutSpecs(): Throwable
  80. def cloneFromUnsupportedSource(name: String, format: String): Throwable
  81. def cloneOnRelativePath(path: String): Throwable
  82. def cloneReplaceNonEmptyTable: Throwable
  83. def cloneReplaceUnsupported(tableIdentifier: TableIdentifier): Throwable
  84. def clusterByInvalidNumColumnsException(numColumnsLimit: Int, actualNumColumns: Int): Throwable
  85. def clusterByWithPartitionedBy(): Throwable
  86. def clusteringColumnMissingStats(clusteringColumnWithoutStats: String, statsSchema: String): Throwable
  87. def clusteringColumnUnsupportedDataTypes(clusteringColumnsWithDataTypes: String): Throwable
  88. def clusteringColumnsMismatchException(providedClusteringColumns: String, existingClusteringColumns: String): Throwable
  89. def clusteringWithPartitionPredicatesException(predicates: Seq[String]): Throwable
  90. def clusteringWithZOrderByException(zOrderBy: Seq[UnresolvedAttribute]): Throwable
  91. def columnBuilderMissingDataType(colName: String): Throwable
  92. def columnMappingAdviceMessage(requiredProtocol: Protocol = ColumnMappingTableFeature.minProtocolVersion): String
    Attributes
    protected
  93. def columnNameNotFoundException(colName: String, scheme: String): Throwable
  94. def columnNotFound(path: Seq[String], schema: StructType): Throwable
  95. def columnNotInSchemaException(column: String, schema: DataType): Throwable
  96. def columnOfTargetTableNotFoundInMergeException(targetCol: String, colNames: String): Throwable
  97. def columnPathNotNested(columnPath: String, other: DataType, column: Seq[String], schema: DataType): Throwable
  98. def columnRenameNotSupported: Throwable
  99. def commandInvariantViolationException(operation: String, id: UUID): Throwable
  100. def concurrentAppendException(conflictingCommit: Option[CommitInfo], partition: String, customRetryMsg: Option[String] = None): io.delta.exceptions.ConcurrentAppendException
  101. def concurrentDeleteDeleteException(conflictingCommit: Option[CommitInfo], file: String): io.delta.exceptions.ConcurrentDeleteDeleteException
  102. def concurrentDeleteReadException(conflictingCommit: Option[CommitInfo], file: String): io.delta.exceptions.ConcurrentDeleteReadException
  103. def concurrentModificationExceptionMsg(sparkConf: SparkConf, baseMessage: String, commit: Option[CommitInfo]): String
  104. def concurrentTransactionException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ConcurrentTransactionException
  105. def concurrentWriteException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ConcurrentWriteException
  106. def configureSparkSessionWithExtensionAndCatalog(originalException: Option[Throwable]): Throwable
  107. def constraintAlreadyExists(name: String, oldExpr: String): AnalysisException
  108. def constraintDataTypeMismatch(columnPath: Seq[String], columnType: DataType, dataType: DataType, constraints: Map[String, String]): Throwable
  109. def convertMetastoreMetadataMismatchException(tableProperties: Map[String, String], deltaConfiguration: Map[String, String]): Throwable
  110. def convertNonParquetTablesException(ident: TableIdentifier, sourceName: String): Throwable
  111. def convertToDeltaNoPartitionFound(tableName: String): Throwable
  112. def convertToDeltaRowTrackingEnabledWithoutStatsCollection: Throwable
  113. def convertToDeltaWithColumnMappingNotSupported(mode: DeltaColumnMappingMode): Throwable
  114. def createExternalTableWithoutLogException(path: Path, tableName: String, spark: SparkSession): Throwable
  115. def createExternalTableWithoutSchemaException(path: Path, tableName: String, spark: SparkSession): Throwable
  116. def createManagedTableWithoutSchemaException(tableName: String, spark: SparkSession): Throwable
  117. def createTableIdentifierLocationMismatch(identifier: String, location: String): Throwable
  118. def createTableMissingTableNameOrLocation(): Throwable
  119. def createTableSetClusteringTableFeatureException(tableFeature: String): Throwable
  120. def createTableWithDifferentClusteringException(path: Path, specifiedClusterBySpec: Option[ClusterBySpec], existingClusterBySpec: Option[ClusterBySpec]): Throwable
  121. def createTableWithDifferentPartitioningException(path: Path, specifiedColumns: Seq[String], existingColumns: Seq[String]): Throwable
  122. def createTableWithDifferentPropertiesException(path: Path, specifiedProperties: Map[String, String], existingProperties: Map[String, String]): Throwable
  123. def createTableWithDifferentSchemaException(path: Path, specifiedSchema: StructType, existingSchema: StructType, diffs: Seq[String]): Throwable
  124. def createTableWithNonEmptyLocation(tableId: String, tableLocation: String): Throwable
  125. def deletedRecordCountsHistogramDeserializationException(): Throwable
  126. def deletionVectorCardinalityMismatch(): Throwable
  127. def deletionVectorChecksumMismatch(): Throwable
  128. def deletionVectorInvalidRowIndex(): Throwable
  129. def deletionVectorSizeMismatch(): Throwable
  130. def deltaAssert(check: => Boolean, name: String, msg: String, deltaLog: DeltaLog = null, data: AnyRef = null, path: Option[Path] = None): Unit

    Helper method to check invariants in Delta code.

    Helper method to check invariants in Delta code. Fails when running in tests, records a delta assertion event and logs a warning otherwise.

    Attributes
    protected
    Definition Classes
    DeltaLogging
  131. def deltaCannotCreateCatalogOwnedTable(): Throwable
  132. def deltaCannotVacuumLite(): Throwable
  133. def deltaCannotVacuumManagedTable(): Throwable
  134. def deltaDynamicPartitionOverwriteDisabled(): Throwable
  135. def deltaLogAlreadyExistsException(path: String): Throwable
  136. def deltaRelationPathMismatch(relationPath: Seq[String], targetType: String, targetPath: Seq[String]): Throwable
  137. def deltaSourceIgnoreChangesError(version: Long, removedFile: String, dataPath: String): Throwable
  138. def deltaSourceIgnoreDeleteError(version: Long, removedFile: String, dataPath: String): Throwable
  139. def deltaStatsCollectionColumnNotFound(statsType: String, columnPath: String): Throwable
  140. def deltaTableFoundInExecutor(): Throwable
  141. def deltaVersionsNotContiguousException(spark: SparkSession, deltaVersions: Seq[Long], startVersion: Long, endVersion: Long, versionToLoad: Long): Throwable
  142. def describeViewHistory: Throwable
  143. def differentDeltaTableReadByStreamingSource(newTableId: String, oldTableId: String): Throwable
  144. def directoryNotFoundException(path: String): Throwable
  145. def domainMetadataDuplicate(domainName: String): Throwable
  146. def domainMetadataTableFeatureNotSupported(domainNames: String): Throwable
  147. def dropCheckpointProtectionWaitForRetentionPeriod(metadata: Metadata): DeltaTableFeatureException
  148. def dropClusteringColumnNotSupported(droppingClusteringCols: Seq[String]): Throwable
  149. def dropColumnAtIndexLessThanZeroException(pos: Int): Throwable
  150. def dropColumnNotSupported(suggestUpgrade: Boolean): Throwable
  151. def dropColumnOnSingleFieldSchema(schema: StructType): Throwable
  152. def dropNestedColumnsFromNonStructTypeException(struct: DataType): Throwable
  153. def dropPartitionColumnNotSupported(droppingPartCols: Seq[String]): Throwable
  154. def dropTableFeatureCheckpointFailedException(featureName: String): Throwable
  155. def dropTableFeatureConflictRevalidationFailed(conflictingCommit: Option[CommitInfo] = None): DeltaTableFeatureException
  156. def dropTableFeatureFailedBecauseOfDependentFeatures(feature: String, dependentFeatures: Seq[String]): DeltaTableFeatureException
  157. def dropTableFeatureFeatureNotSupportedByClient(feature: String): DeltaTableFeatureException
  158. def dropTableFeatureFeatureNotSupportedByProtocol(feature: String): DeltaTableFeatureException
  159. def dropTableFeatureHistoricalVersionsExist(feature: String, metadata: Metadata): DeltaTableFeatureException
  160. def dropTableFeatureNonRemovableFeature(feature: String): DeltaTableFeatureException
  161. def dropTableFeatureNotDeltaTableException(): Throwable
  162. def dropTableFeatureWaitForRetentionPeriod(feature: String, metadata: Metadata): DeltaTableFeatureException
  163. def duplicateColumnOnInsert(): Throwable
  164. def duplicateColumnsOnUpdateTable(originalException: Throwable): Throwable
  165. def duplicatedColumnId(mode: DeltaColumnMappingMode, id: Long, schema: StructType): Throwable
  166. def duplicatedPhysicalName(mode: DeltaColumnMappingMode, physicalName: String, schema: StructType): Throwable
  167. def emptyCalendarInterval: Throwable
  168. def emptyDataException: Throwable
  169. def emptyDirectoryException(directory: String): Throwable
  170. def enablingColumnMappingDisallowedWhenColumnMappingMetadataAlreadyExists(): Throwable
  171. def endBeforeStartVersionInCDC(start: Long, end: Long): Throwable

    Throwable used for invalid CDC 'start' and 'end' options, where end < start

  172. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  173. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  174. def errorFindingColumnPosition(columnPath: Seq[String], schema: DataType, extraErrMsg: String): Throwable
  175. def errorsWithDocsLinks: Seq[String]

    List of error function names for all errors that have URLs.

    List of error function names for all errors that have URLs. When adding your error to this list remember to also add it to the list of errors in DeltaErrorsSuite

    Definition Classes
    DocsPath
    Note

    add your error to DeltaErrorsSuiteBase after adding it to this list so that the url can be tested

  176. def excludeRegexOptionException(regexOption: String, cause: Throwable = null): Throwable
  177. def expressionsNotFoundInGeneratedColumn(column: String): Throwable
  178. def extractReferencesFieldNotFound(field: String, exception: Throwable): Throwable
  179. def failOnCheckpointRename(src: Path, dest: Path): DeltaIllegalStateException
  180. def failOnDataLossException(expectedVersion: Long, seenVersion: Long): Throwable
  181. def failRelativizePath(pathName: String): Throwable
  182. def failToDeserializeSchemaLog(location: String): Throwable
  183. def failToParseSchemaLog: Throwable
  184. def failedFindAttributeInOutputColumns(newAttrName: String, targetColNames: String): Throwable
  185. def failedFindPartitionColumnInOutputPlan(partitionColumn: String): Throwable
  186. def failedInferSchema: Throwable
  187. def failedMergeSchemaFile(file: String, schema: String, cause: Throwable): Throwable
  188. def failedReadFileFooter(file: String, e: Throwable): Throwable
  189. def failedRecognizePredicate(predicate: String, cause: Throwable): Throwable
  190. def failedScanWithHistoricalVersion(historicalVersion: Long): Throwable
  191. def failedToGetSnapshotDuringColumnMappingStreamingReadCheck(cause: Throwable): Throwable
  192. val faqRelativePath: String
  193. def fileAlreadyExists(file: String): Throwable
  194. def fileNotFoundException(path: String): Throwable
  195. def fileOrDirectoryNotFoundException(path: String): Throwable
  196. def formatColumn(colName: String): String
  197. def formatColumnList(colNames: Seq[String]): String
  198. def formatSchema(schema: StructType): String
  199. def foundDuplicateColumnsException(colType: String, duplicateCols: String): Throwable
  200. def foundInvalidCharsInColumnNames(invalidColumnNames: Seq[String]): Throwable
  201. def foundInvalidColumnNamesWhenRemovingColumnMapping(columnNames: Seq[String]): Throwable
  202. def foundMapTypeColumnException(key: String, value: String, schema: DataType): Throwable
  203. def foundViolatingConstraintsForColumnChange(columnName: String, constraints: Map[String, String]): Throwable
  204. def foundViolatingGeneratedColumnsForColumnChange(columnName: String, generatedColumns: Map[String, String]): Throwable
  205. def generateDocsLink(conf: SparkConf, relativePath: String, skipValidation: Boolean = false): String

    Get the link to the docs for the given relativePath.

    Get the link to the docs for the given relativePath. Validates that the error generating the link is added to docsLinks. Please only use this function if SparkConf is directly available. If needed to retrieve SparkConf from SparkSession, please use more safe function generateDocsLinkOption.

    relativePath

    the relative path after the base url to access.

    skipValidation

    whether to validate that the function generating the link is in the allowlist.

    returns

    The entire URL of the documentation link

    Definition Classes
    DocsPath
  206. def generateDocsLinkOption(spark: SparkSession, relativePath: String, skipValidation: Boolean = false): Option[String]

    Safe alternative to generateDocsLink that validates sparkContext before accessing it.

    Safe alternative to generateDocsLink that validates sparkContext before accessing it.

    Definition Classes
    DocsPath
  207. def generateManifestWithColumnMappingNotSupported: Throwable
  208. def generateNotSupportedWithDeletionVectors(): Throwable
  209. def generatedColumnsAggregateExpression(expr: Expression): Throwable
  210. def generatedColumnsDataTypeMismatch(columnPath: Seq[String], columnType: DataType, dataType: DataType, generatedColumns: Map[String, String]): Throwable
  211. def generatedColumnsExprTypeMismatch(column: String, columnType: DataType, exprType: DataType): Throwable
  212. def generatedColumnsNonDeterministicExpression(expr: Expression): Throwable
  213. def generatedColumnsReferToWrongColumns(e: AnalysisException): Throwable
  214. def generatedColumnsUDF(expr: Expression): Throwable
  215. def generatedColumnsUnsupportedExpression(expr: Expression): Throwable
  216. def generatedColumnsUnsupportedType(dt: DataType): Throwable
  217. def generatedColumnsUpdateColumnType(current: StructField, update: StructField): Throwable
  218. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  219. def getCommonTags(deltaLog: DeltaLog, tahoeId: String): Map[TagDefinition, String]
    Definition Classes
    DeltaLogging
  220. def getErrorData(e: Throwable): Map[String, Any]
    Definition Classes
    DeltaLogging
  221. def getQueryContext(context: QueryContext): Array[QueryContext]
    Definition Classes
    DataTypeErrorsBase
  222. def getSummary(sqlContext: QueryContext): String
    Definition Classes
    DataTypeErrorsBase
  223. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  224. def hudiClassMissing(sparkConf: SparkConf, cause: Throwable): Throwable
  225. def icebergClassMissing(sparkConf: SparkConf, cause: Throwable): Throwable
  226. def icebergCompatChangeVersionNeedRewrite(version: Int, newVersion: Int): Throwable
  227. def icebergCompatDataFileRewriteFailedException(icebergCompatVersion: Int, cause: Throwable): Throwable
  228. def icebergCompatDeletionVectorsNotPurgedException(version: Int): Throwable
  229. def icebergCompatDeletionVectorsShouldBeDisabledException(version: Int): Throwable
  230. def icebergCompatDisablingRequiredTableFeatureException(version: Int, tf: TableFeature): Throwable
  231. def icebergCompatIncompatibleTableFeatureException(version: Int, tf: TableFeature): Throwable
  232. def icebergCompatMissingRequiredTableFeatureException(version: Int, tf: TableFeature): Throwable
  233. def icebergCompatReorgAddFileTagsMissingException(tableVersion: Long, icebergCompatVersion: Int, addFilesCount: Long, addFilesWithTagsCount: Long): Throwable
  234. def icebergCompatReplacePartitionedTableException(version: Int, prevPartitionCols: Seq[String], newPartitionCols: Seq[String]): Throwable
  235. def icebergCompatUnsupportedDataTypeException(version: Int, dataType: DataType, schema: StructType): Throwable
  236. def icebergCompatUnsupportedPartitionDataTypeException(version: Int, dataType: DataType, schema: StructType): Throwable
  237. def icebergCompatUnsupportedTypeWideningException(version: Int, fieldPath: Seq[String], oldType: DataType, newType: DataType): Throwable
  238. def icebergCompatVersionMutualExclusive(version: Int): Throwable
  239. def icebergCompatVersionNotSupportedException(currVersion: Int, maxVersion: Int): Throwable
  240. def icebergCompatWrongRequiredTablePropertyException(version: Int, key: String, actualValue: String, requiredValue: String): Throwable
  241. def identityColumnAlterColumnNotSupported(): Throwable
  242. def identityColumnAlterNonDeltaFormatError(): Throwable
  243. def identityColumnAlterNonIdentityColumnError(): Throwable
  244. def identityColumnDataTypeNotSupported(unsupportedType: DataType): Throwable
  245. def identityColumnExplicitInsertNotSupported(colName: String): Throwable
  246. def identityColumnIllegalStep(): Throwable
  247. def identityColumnInconsistentMetadata(colName: String, hasStart: Boolean, hasStep: Boolean, hasInsert: Boolean): Throwable
  248. def identityColumnPartitionNotSupported(colName: String): Throwable
  249. def identityColumnReplaceColumnsNotSupported(): Throwable
  250. def identityColumnUpdateNotSupported(colName: String): Throwable
  251. def identityColumnWithGenerationExpression(): Throwable
  252. def ignoreStreamingUpdatesAndDeletesWarning(spark: SparkSession): String
  253. def illegalDeltaOptionException(name: String, input: String, explain: String): Throwable
  254. def illegalFilesFound(file: String): Throwable
  255. def illegalUsageException(option: String, operation: String): Throwable
  256. def inSubqueryNotSupportedException(operation: String): Throwable
  257. def incompatibleSchemaLogDeltaTable(persistedTableId: String, tableId: String): Throwable
  258. def incompatibleSchemaLogPartitionSchema(persistedPartitionSchema: StructType, tablePartitionSchema: StructType): Throwable
  259. def inconsistentLogStoreConfs(setKeys: Seq[(String, String)]): Throwable
  260. def incorrectArrayAccess(): Throwable
  261. def incorrectArrayAccessByName(rightName: String, wrongName: String, schema: DataType): Throwable
  262. def incorrectLogStoreImplementationException(sparkConf: SparkConf, cause: Throwable): Throwable
  263. def indexLargerOrEqualThanStruct(pos: Int, len: Int): Throwable
  264. def indexLargerThanStruct(pos: Int, column: StructField, len: Int): Throwable
  265. def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  266. def initializeLogIfNecessary(isInterpreter: Boolean): Unit
    Attributes
    protected
    Definition Classes
    Logging
  267. def invalidAutoCompactType(value: String): Throwable
  268. def invalidColumnName(name: String): Throwable
  269. def invalidCommitIntermediateRedirectState(state: RedirectState): Throwable
  270. def invalidCommittedVersion(attemptVersion: Long, currentVersion: Long): Throwable
  271. def invalidConstraintName(name: String): AnalysisException
  272. def invalidFormatFromSourceVersion(wrongVersion: Long, expectedVersion: Integer): Throwable
  273. def invalidIdempotentWritesOptionsException(explain: String): Throwable
  274. def invalidInterval(interval: String): Throwable
  275. def invalidInventorySchema(expectedSchema: String): Throwable
  276. def invalidIsolationLevelException(s: String): Throwable
  277. def invalidPartitionColumn(e: AnalysisException): Throwable
  278. def invalidPartitionColumn(col: String, tbl: String): Throwable
  279. def invalidRedirectStateTransition(table: String, oldState: RedirectState, newState: RedirectState): Throwable
  280. def invalidRemoveTableRedirect(table: String, currentState: RedirectState): Throwable
  281. def invalidSetUnSetRedirectCommand(table: String, newProperty: String, existingProperty: String): Throwable
  282. def invalidSourceOffsetFormat(): Throwable
  283. def invalidSourceVersion(version: String): Throwable
  284. def invalidTableValueFunction(function: String): Throwable
  285. def invalidTimestampFormat(ts: String, format: String, cause: Option[Throwable] = None): Throwable
  286. def invalidV1TableCall(callVersion: String, tableVersion: String): Throwable
  287. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  288. def isTraceEnabled(): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  289. def iteratorAlreadyClosed(): Throwable
  290. def log: Logger
    Attributes
    protected
    Definition Classes
    Logging
  291. def logConsole(line: String): Unit
    Definition Classes
    DatabricksLogging
  292. def logDebug(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  293. def logDebug(entry: LogEntry, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  294. def logDebug(entry: LogEntry): Unit
    Attributes
    protected
    Definition Classes
    Logging
  295. def logDebug(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  296. def logError(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  297. def logError(entry: LogEntry, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  298. def logError(entry: LogEntry): Unit
    Attributes
    protected
    Definition Classes
    Logging
  299. def logError(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  300. def logFailedIntegrityCheck(version: Long, mismatchOption: String): Throwable
  301. def logFileNotFoundException(path: Path, version: Long, metadata: Metadata): Throwable
  302. def logFileNotFoundExceptionForStreamingSource(e: FileNotFoundException): Throwable
  303. def logInfo(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  304. def logInfo(entry: LogEntry, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  305. def logInfo(entry: LogEntry): Unit
    Attributes
    protected
    Definition Classes
    Logging
  306. def logInfo(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  307. def logName: String
    Attributes
    protected
    Definition Classes
    Logging
  308. def logStoreConfConflicts(classConf: Seq[(String, String)], schemeConf: Seq[(String, String)]): Throwable
  309. def logTrace(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  310. def logTrace(entry: LogEntry, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  311. def logTrace(entry: LogEntry): Unit
    Attributes
    protected
    Definition Classes
    Logging
  312. def logTrace(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  313. def logWarning(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  314. def logWarning(entry: LogEntry, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  315. def logWarning(entry: LogEntry): Unit
    Attributes
    protected
    Definition Classes
    Logging
  316. def logWarning(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  317. def materializedRowCommitVersionMetadataMissing(tableName: String): Throwable
  318. def materializedRowIdMetadataMissing(tableName: String): Throwable
  319. def maxArraySizeExceeded(): Throwable
  320. def maxColumnIdNotSet: Throwable
  321. def maxColumnIdNotSetCorrectly(tableMax: Long, fieldMax: Long): Throwable
  322. def maxCommitRetriesExceededException(attemptNumber: Int, attemptVersion: Long, initAttemptVersion: Long, numActions: Int, totalCommitAttemptTime: Long): Throwable
  323. def mergeAddVoidColumn(columnName: String): Throwable
  324. def metadataAbsentException(): Throwable
  325. def metadataAbsentForExistingCatalogTable(tableName: String, tablePath: String): Throwable
  326. def metadataChangedException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.MetadataChangedException
  327. def missingColumn(attr: Attribute, targetAttrs: Seq[Attribute]): Throwable
  328. def missingColumnId(mode: DeltaColumnMappingMode, field: String): Throwable
  329. def missingColumnsInInsertInto(column: String): Throwable
  330. def missingCommitInfo(featureName: String, commitVersion: String): DeltaIllegalStateException
  331. def missingCommitTimestamp(commitVersion: String): DeltaIllegalStateException
  332. def missingDeltaStorageJar(e: NoClassDefFoundError): Throwable
  333. def missingPartFilesException(version: Long, ae: Exception): Throwable
  334. def missingPartitionColumn(col: String, schemaCatalog: String): Throwable
  335. def missingPhysicalName(mode: DeltaColumnMappingMode, field: String): Throwable
  336. def missingProviderForConvertException(path: String): Throwable
  337. def missingTableIdentifierException(operationName: String): Throwable
  338. def modifyAppendOnlyTableException(tableName: String): Throwable
  339. def multiColumnInPredicateNotSupportedException(operation: String): Throwable
  340. def multipleCDCBoundaryException(position: String): Throwable

    Thrown when a CDC query contains conflict 'starting' or 'ending' options, e.g.

    Thrown when a CDC query contains conflict 'starting' or 'ending' options, e.g. when both starting version and starting timestamp are specified.

    position

    Specifies which option was duplicated in the read. Values are "starting" or "ending"

  341. def multipleLoadPathsException(paths: Seq[String]): Throwable
  342. def multipleSourceRowMatchingTargetRowInMergeException(spark: SparkSession): Throwable
  343. def multipleTimeTravelSyntaxUsed: Throwable
  344. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  345. def nestedFieldNotSupported(operation: String, field: String): Throwable
  346. def nestedNotNullConstraint(parent: String, nested: DataType, nestType: String): AnalysisException
  347. def newCheckConstraintViolated(num: Long, tableName: String, expr: String): AnalysisException
  348. def newNotNullViolated(num: Long, tableName: String, col: UnresolvedAttribute): AnalysisException
  349. def noHistoryFound(logPath: Path): Throwable
  350. def noNewAttributeId(oldAttr: AttributeReference): Throwable
  351. def noRecreatableHistoryFound(logPath: Path): Throwable
  352. def noRedirectRulesViolated(op: Operation, noRedirectRules: Set[NoRedirectRule]): Throwable
  353. def noRelationTable(tableIdent: Identifier): Throwable
  354. def noStartVersionForCDC(): Throwable

    Throwable used when CDC options contain no 'start'.

  355. def nonDeterministicNotSupportedException(op: String, cond: Expression): Throwable
  356. def nonExistentColumnInSchema(column: String, schema: String): Throwable
  357. def nonExistentDeltaTable(tableId: DeltaTableIdentifier): Throwable
  358. def nonGeneratedColumnMissingUpdateExpression(columnName: String): Throwable
  359. def nonPartitionColumnAbsentException(colsDropped: Boolean): Throwable
  360. def nonPartitionColumnReference(colName: String, partitionColumns: Seq[String]): Throwable
  361. def nonSinglePartNamespaceForCatalog(ident: String): Throwable
  362. def nonexistentConstraint(constraintName: String, tableName: String): AnalysisException
  363. def notADeltaSourceException(command: String, plan: Option[LogicalPlan] = None): Throwable
  364. def notADeltaTable(table: String): Throwable
  365. def notADeltaTableException(operation: String): Throwable
  366. def notADeltaTableException(operation: String, tableName: String): Throwable
  367. def notADeltaTableException(operation: String, deltaTableIdentifier: DeltaTableIdentifier): Throwable
  368. def notADeltaTableException(deltaTableIdentifier: DeltaTableIdentifier): Throwable
  369. def notEnoughColumnsInInsert(table: String, query: Int, target: Int, nestedField: Option[String] = None): Throwable
  370. def notFoundFileToBeRewritten(absolutePath: String, candidates: Iterable[String]): Throwable
  371. def notNullColumnMissingException(constraint: NotNull): Throwable
  372. def notNullColumnNotFoundInStruct(struct: String): Throwable
  373. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  374. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  375. def nullRangeBoundaryInCDCRead(): Throwable

    Throwable used when a null 'start' or 'end' is provided in CDC reads.

  376. def nullableParentWithNotNullNestedField: Throwable
  377. def numRecordsMismatch(operation: String, numAddedRecords: Long, numRemovedRecords: Long): Throwable
  378. def operationNotSupportedException(operation: String): Throwable
  379. def operationNotSupportedException(operation: String, tableIdentifier: TableIdentifier): Throwable
  380. def operationOnTempViewWithGenerateColsNotSupported(op: String): Throwable
  381. def optimizeFullNotSupportedException(): Throwable
  382. def ordinalNumber(i: Int): String
    Definition Classes
    QueryErrorsBase
  383. def outputModeNotSupportedException(dataSource: String, outputMode: String): Throwable
  384. def overwriteSchemaUsedWithDynamicPartitionOverwrite(): Throwable
  385. def partitionColumnCastFailed(columnValue: String, dataType: String, columnName: String): Throwable
  386. def partitionColumnNotFoundException(colName: String, schema: Seq[Attribute]): Throwable
  387. def partitionPathInvolvesNonPartitionColumnException(badColumns: Seq[String], fragment: String): Throwable
  388. def partitionPathParseException(fragment: String): Throwable
  389. def partitionSchemaInIcebergTables: Throwable
  390. def pathAlreadyExistsException(path: Path): Throwable
  391. def pathNotExistsException(path: String): Throwable
  392. def pathNotSpecifiedException: Throwable
  393. def postCommitHookFailedException(failedHook: PostCommitHook, failedOnCommitVersion: Long, extraErrorMessage: String, error: Throwable): Throwable
  394. def protocolChangedException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ProtocolChangedException
  395. def protocolPropNotIntException(key: String, value: String): Throwable
  396. def provideOneOfInTimeTravel: Throwable
  397. def quoteByDefault(elem: String): String
    Attributes
    protected
    Definition Classes
    DataTypeErrorsBase
  398. def readTableWithoutSchemaException(identifier: String): Throwable
  399. def recordDeltaEvent(deltaLog: DeltaLog, opType: String, tags: Map[TagDefinition, String] = Map.empty, data: AnyRef = null, path: Option[Path] = None): Unit

    Used to record the occurrence of a single event or report detailed, operation specific statistics.

    Used to record the occurrence of a single event or report detailed, operation specific statistics.

    path

    Used to log the path of the delta table when deltaLog is null.

    Attributes
    protected
    Definition Classes
    DeltaLogging
  400. def recordDeltaOperation[A](deltaLog: DeltaLog, opType: String, tags: Map[TagDefinition, String] = Map.empty)(thunk: => A): A

    Used to report the duration as well as the success or failure of an operation on a deltaLog.

    Used to report the duration as well as the success or failure of an operation on a deltaLog.

    Attributes
    protected
    Definition Classes
    DeltaLogging
  401. def recordDeltaOperationForTablePath[A](tablePath: String, opType: String, tags: Map[TagDefinition, String] = Map.empty)(thunk: => A): A

    Used to report the duration as well as the success or failure of an operation on a tahoePath.

    Used to report the duration as well as the success or failure of an operation on a tahoePath.

    Attributes
    protected
    Definition Classes
    DeltaLogging
  402. def recordEvent(metric: MetricDefinition, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, trimBlob: Boolean = true): Unit
    Definition Classes
    DatabricksLogging
  403. def recordFrameProfile[T](group: String, name: String)(thunk: => T): T
    Attributes
    protected
    Definition Classes
    DeltaLogging
  404. def recordOperation[S](opType: OpType, opTarget: String = null, extraTags: Map[TagDefinition, String], isSynchronous: Boolean = true, alwaysRecordStats: Boolean = false, allowAuthTags: Boolean = false, killJvmIfStuck: Boolean = false, outputMetric: MetricDefinition = METRIC_OPERATION_DURATION, silent: Boolean = true)(thunk: => S): S
    Definition Classes
    DatabricksLogging
  405. def recordProductEvent(metric: MetricDefinition with CentralizableMetric, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, trimBlob: Boolean = true): Unit
    Definition Classes
    DatabricksLogging
  406. def recordProductUsage(metric: MetricDefinition with CentralizableMetric, quantity: Double, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, forceSample: Boolean = false, trimBlob: Boolean = true, silent: Boolean = false): Unit
    Definition Classes
    DatabricksLogging
  407. def recordUsage(metric: MetricDefinition, quantity: Double, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, forceSample: Boolean = false, trimBlob: Boolean = true, silent: Boolean = false): Unit
    Definition Classes
    DatabricksLogging
  408. def removeFileCDCMissingExtendedMetadata(fileName: String): Throwable
  409. def replaceWhereMismatchException(replaceWhere: String, badPartitions: String): Throwable
  410. def replaceWhereMismatchException(replaceWhere: String, invariantViolation: InvariantViolationException): Throwable
  411. def replaceWhereUsedInOverwrite(): Throwable
  412. def replaceWhereUsedWithDynamicPartitionOverwrite(): Throwable
  413. def replaceWhereWithFilterDataChangeUnset(dataFilters: String): Throwable
  414. def replacingClusteredTableWithPartitionedTableNotAllowed(): Throwable
  415. def restoreMissedDataFilesError(missedFiles: Array[String], version: Long): Throwable
  416. def restoreTimestampBeforeEarliestException(userTimestamp: String, earliestTimestamp: String): Throwable
  417. def restoreTimestampGreaterThanLatestException(userTimestamp: String, latestTimestamp: String): Throwable
  418. def restoreVersionNotExistException(userVersion: Long, earliest: Long, latest: Long): Throwable
  419. def rowIdAssignmentWithoutStats: Throwable
  420. def schemaChangeDuringMappingModeChangeNotSupported(oldSchema: StructType, newSchema: StructType): Throwable
  421. def schemaChangedException(readSchema: StructType, dataSchema: StructType, retryable: Boolean, version: Option[Long], includeStartingVersionOrTimestampMessage: Boolean): Throwable
  422. def schemaChangedSinceAnalysis(atAnalysis: StructType, latestSchema: StructType, mentionLegacyFlag: Boolean = false): Throwable
  423. def schemaNotConsistentWithTarget(tableSchema: String, targetAttr: String): Throwable
  424. def schemaNotProvidedException: Throwable
  425. def schemaNotSetException: Throwable
  426. def schemaTrackingLocationNotUnderCheckpointLocation(schemaTrackingLocation: String, checkpointLocation: String): Throwable
  427. def setLocationNotSupportedOnPathIdentifiers(): Throwable
  428. def setTransactionVersionConflict(appId: String, version1: Long, version2: Long): Throwable
  429. def showPartitionInNotPartitionedColumn(badColumns: Set[String]): Throwable
  430. def showPartitionInNotPartitionedTable(tableName: String): Throwable
  431. def sourceMaterializationFailedRepeatedlyInMerge: Throwable
  432. def sourceNotDeterministicInMergeException(spark: SparkSession): Throwable
  433. def sourcesWithConflictingSchemaTrackingLocation(schemaTrackingLocatiob: String, tableOrPath: String): Throwable
  434. def sparkSessionNotSetException(): Throwable
  435. def sparkTaskThreadNotFound: Throwable
  436. def specifySchemaAtReadTimeException: Throwable
  437. def startVersionAfterLatestVersion(start: Long, latest: Long): Throwable

    Throwable used for invalid CDC 'start' and 'latest' options, where latest < start

  438. def startingVersionAndTimestampBothSetException(versionOptKey: String, timestampOptKey: String): Throwable
  439. def staticPartitionsNotSupportedException: Throwable
  440. def statsRecomputeNotSupportedOnDvTables(): Throwable
  441. def streamWriteNullTypeException: Throwable
  442. def streamingMetadataEvolutionException(newSchema: StructType, newConfigs: Map[String, String], newProtocol: Protocol): Throwable
  443. def streamingMetadataLogInitFailedIncompatibleMetadataException(startVersion: Long, endVersion: Long): Throwable
  444. def subqueryNotSupportedException(op: String, cond: Expression): Throwable
  445. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  446. def tableAlreadyContainsCDCColumns(columns: Seq[String]): Throwable

    Thrown when main table data already contains columns that are reserved for CDF, such as _change_type, but CDF is not yet enabled on that table.

  447. def tableAlreadyExists(table: CatalogTable): Throwable
  448. def tableFeatureDropHistoryTruncationNotAllowed(): DeltaTableFeatureException
  449. def tableFeatureMismatchException(features: Iterable[String]): DeltaTableFeatureException
  450. def tableFeatureReadRequiresWriteException(requiredWriterVersion: Int): DeltaTableFeatureException
  451. def tableFeatureRequiresHigherReaderProtocolVersion(feature: String, currentVersion: Int, requiredVersion: Int): DeltaTableFeatureException
  452. def tableFeatureRequiresHigherWriterProtocolVersion(feature: String, currentVersion: Int, requiredVersion: Int): DeltaTableFeatureException
  453. def tableFeaturesRequireManualEnablementException(unsupportedFeatures: Iterable[TableFeature], supportedFeatures: Iterable[TableFeature]): Throwable
  454. def tableLocationMismatch(table: CatalogTable, existingTable: CatalogTable): Throwable
  455. def tableNotSupportedException(operation: String): Throwable
  456. def targetTableFinalSchemaEmptyException(): Throwable
  457. def throwDeltaIllegalArgumentException(): Throwable

    This is a method only used for testing Py4J exception handling.

  458. def timeTravelInvalidBeginValue(timeTravelKey: String, cause: Throwable): Throwable
  459. def timeTravelNotSupportedException: Throwable
  460. def timestampGreaterThanLatestCommit(userTs: Timestamp, lastCommitTs: Timestamp, maximumTsStr: String): Throwable
  461. def timestampInvalid(expr: Expression): Throwable
  462. def toDSOption(option: String): String
    Definition Classes
    DataTypeErrorsBase
  463. def toSQLConf(conf: String): String
    Definition Classes
    DataTypeErrorsBase
  464. def toSQLConfVal(conf: String): String
    Definition Classes
    QueryErrorsBase
  465. def toSQLExpr(e: Expression): String
    Definition Classes
    QueryErrorsBase
  466. def toSQLId(parts: Seq[String]): String
    Definition Classes
    DataTypeErrorsBase
  467. def toSQLId(parts: String): String
    Definition Classes
    DataTypeErrorsBase
  468. def toSQLStmt(text: String): String
    Definition Classes
    DataTypeErrorsBase
  469. def toSQLType(t: AbstractDataType): String
    Definition Classes
    DataTypeErrorsBase
  470. def toSQLType(text: String): String
    Definition Classes
    DataTypeErrorsBase
  471. def toSQLValue(v: Any, t: DataType): String
    Definition Classes
    QueryErrorsBase
  472. def toSQLValue(value: Double): String
    Definition Classes
    DataTypeErrorsBase
  473. def toSQLValue(value: Float): String
    Definition Classes
    DataTypeErrorsBase
  474. def toSQLValue(value: Long): String
    Definition Classes
    DataTypeErrorsBase
  475. def toSQLValue(value: Int): String
    Definition Classes
    DataTypeErrorsBase
  476. def toSQLValue(value: Short): String
    Definition Classes
    DataTypeErrorsBase
  477. def toSQLValue(value: UTF8String): String
    Definition Classes
    DataTypeErrorsBase
  478. def toSQLValue(value: String): String
    Definition Classes
    DataTypeErrorsBase
  479. def toString(): String
    Definition Classes
    AnyRef → Any
  480. def truncateTablePartitionNotSupportedException: Throwable
  481. def unSupportedInvariantNonStructType: Throwable
  482. def unexpectedAlias(alias: String): Throwable
  483. def unexpectedAttributeReference(ref: String): Throwable
  484. def unexpectedChangeFilesFound(changeFiles: String): Throwable
  485. def unexpectedDataChangeException(op: String): Throwable
  486. def unexpectedNumPartitionColumnsFromFileNameException(path: String, parsedCols: Seq[String], expectedCols: Seq[String]): Throwable
  487. def unexpectedPartialScan(path: Path): Throwable
  488. def unexpectedPartitionColumnFromFileNameException(path: String, parsedCol: String, expectedCol: String): Throwable
  489. def unexpectedPartitionSchemaFromUserException(catalogPartitionSchema: StructType, userPartitionSchema: StructType): Throwable
  490. def unexpectedProject(project: String): Throwable
  491. def uniFormHudiDeleteVectorCompat(): Throwable
  492. def uniFormHudiSchemaCompat(unsupportedType: DataType): Throwable
  493. def uniFormIcebergRequiresIcebergCompat(): Throwable
  494. def universalFormatConversionFailedException(failedOnCommitVersion: Long, format: String, errorMessage: String): Throwable
  495. def unknownConfigurationKeyException(confKey: String): Throwable
  496. def unknownPrivilege(privilege: String): Throwable
  497. def unknownReadLimit(limit: String): Throwable
  498. def unrecognizedColumnChange(otherClass: String): Throwable
  499. def unrecognizedFileAction(otherAction: String, otherClass: String): Throwable
  500. def unrecognizedInvariant(): Throwable
  501. def unrecognizedLogFile(path: Path): Throwable
  502. def unrecognizedRedirectSpec(spec: RedirectSpec): Throwable
  503. def unsetNonExistentProperty(key: String, table: String): Throwable
  504. def unsupportSubqueryInPartitionPredicates(): Throwable
  505. def unsupportedAbsPathAddFile(str: String): Throwable
  506. def unsupportedColumnMappingMode(mode: String): Throwable

    We have plans to support more column mapping modes, but they are not implemented yet, so we error for now to be forward compatible with tables created in the future.

  507. def unsupportedColumnMappingModeException(modeName: String): Throwable
  508. def unsupportedDataTypes(unsupportedDataType: UnsupportedDataTypeInfo, moreUnsupportedDataTypes: UnsupportedDataTypeInfo*): Throwable
  509. def unsupportedDeepCloneException(): Throwable
  510. def unsupportedDeltaTableForPathHadoopConf(unsupportedOptions: Map[String, String]): Throwable
  511. def unsupportedExpression(causedBy: String, expType: DataType, supportedTypes: Seq[String]): Throwable
  512. def unsupportedGenerateModeException(modeName: String): Throwable
  513. def unsupportedReaderTableFeaturesInTableException(tableNameOrPath: String, unsupported: Iterable[String]): DeltaUnsupportedTableFeatureException
  514. def unsupportedTableFeatureConfigsException(configs: Iterable[String]): DeltaTableFeatureException
  515. def unsupportedTableFeatureStatusException(feature: String, status: String): DeltaTableFeatureException
  516. def unsupportedTruncateSampleTables: Throwable
  517. def unsupportedTypeChangeInPreview(fieldPath: Seq[String], fromType: DataType, toType: DataType, feature: TypeWideningTableFeatureBase): Throwable
  518. def unsupportedTypeChangeInSchema(fieldPath: Seq[String], fromType: DataType, toType: DataType): Throwable
  519. def unsupportedWriteStagedTable(tableName: String): Throwable
  520. def unsupportedWriterTableFeaturesInTableException(tableNameOrPath: String, unsupported: Iterable[String]): DeltaUnsupportedTableFeatureException
  521. def unsupportedWritesWithMissingCoordinators(coordinatorName: String): Throwable
  522. def updateNonStructTypeFieldNotSupportedException(col: String, s: DataType): Throwable
  523. def updateSchemaMismatchExpression(from: StructType, to: StructType): Throwable
  524. def updateSetColumnNotFoundException(col: String, colList: Seq[String]): Throwable
  525. def updateSetConflictException(cols: Seq[String]): Throwable
  526. def useAddConstraints: Throwable
  527. def useSetLocation(): Throwable
  528. def vacuumBasePathMissingException(baseDeltaPath: Path): Throwable
  529. def variantShreddingUnsupported(): Throwable
  530. def versionInvalid(version: String): Throwable
  531. def viewInDescribeDetailException(view: TableIdentifier): Throwable
  532. def viewNotSupported(operationName: String): Throwable
  533. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  534. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  535. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  536. def withLogContext(context: Map[String, String])(body: => Unit): Unit
    Attributes
    protected
    Definition Classes
    Logging
  537. def withStatusCode[T](statusCode: String, defaultMessage: String, data: Map[String, Any] = Map.empty)(body: => T): T

    Report a log to indicate some command is running.

    Report a log to indicate some command is running.

    Definition Classes
    DeltaProgressReporter
  538. def zOrderingColumnDoesNotExistException(colName: String): Throwable
  539. def zOrderingOnColumnWithNoStatsException(colNames: Seq[String], spark: SparkSession): Throwable
  540. def zOrderingOnPartitionColumnException(colName: String): Throwable

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from QueryErrorsBase

Inherited from DataTypeErrorsBase

Inherited from DeltaLogging

Inherited from DatabricksLogging

Inherited from DeltaProgressReporter

Inherited from LoggingShims

Inherited from Logging

Inherited from DocsPath

Inherited from AnyRef

Inherited from Any

Ungrouped