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, Logging, DocsPath, AnyRef, Any
Known Subclasses
DeltaErrors, DeletionVectorStoredBitmap
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DeltaErrorsBase
  2. QueryErrorsBase
  3. DataTypeErrorsBase
  4. DeltaLogging
  5. DatabricksLogging
  6. DeltaProgressReporter
  7. Logging
  8. DocsPath
  9. AnyRef
  10. 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. case class TemporallyUnstableInputException(userTimestamp: Timestamp, commitTs: Timestamp, timestampString: String, commitVersion: Long) extends AnalysisException with Product with Serializable
  3. 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 addFilePartitioningMismatchException(addFilePartitions: Seq[String], metadataPartitions: Seq[String]): Throwable
  12. def addFileWithDVsAndTightBoundsException(): Throwable
  13. def addFileWithDVsMissingNumRecordsException: Throwable
  14. def addingColumnWithInternalNameFailed(colName: String): Throwable
  15. def addingDeletionVectorsDisallowedException(): Throwable
  16. def aggsNotSupportedException(op: String, cond: Expression): Throwable
  17. def alterTableChangeColumnException(oldColumns: String, newColumns: String): Throwable
  18. def alterTableReplaceColumnsException(oldSchema: StructType, newSchema: StructType, reason: String): Throwable
  19. def alterTableSetLocationSchemaMismatchException(original: StructType, destination: StructType): Throwable
  20. def ambiguousDataTypeChange(column: String, from: StructType, to: StructType): Throwable
  21. def ambiguousPartitionColumnException(columnName: String, colMatches: Seq[StructField]): Throwable
  22. def ambiguousPathsInCreateTableException(identifier: String, location: String): Throwable
  23. def analysisException(msg: String, line: Option[Int] = None, startPosition: Option[Int] = None, plan: Option[LogicalPlan] = None, cause: Option[Throwable] = None): AnalysisException
  24. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  25. def assertValidCallingFunction(): Unit
    Definition Classes
    DocsPath
  26. def assertionFailedError(msg: String): Throwable
  27. def baseDocsPath(spark: SparkSession): String
  28. 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
  29. 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.

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

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

  63. def cdcNotAllowedInThisVersion(): Throwable
  64. def cdcWriteNotAllowedInThisVersion(): Throwable
  65. def changeColumnMappingModeNotSupported(oldMode: String, newMode: String): Throwable
  66. def changeColumnMappingModeOnOldProtocol(oldProtocol: Protocol): Throwable
  67. def changeDataNotRecordedException(version: Long, start: Long, end: Long): Throwable

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

  68. def checkConstraintNotBoolean(name: String, expr: String): AnalysisException
  69. def checkpointMismatchWithSnapshot: Throwable
  70. def checkpointNonExistTable(path: Path): Throwable
  71. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  72. def cloneAmbiguousTarget(externalLocation: String, targetIdent: TableIdentifier): Throwable
  73. def cloneFromUnsupportedSource(name: String, format: String): Throwable
  74. def cloneOnRelativePath(path: String): Throwable
  75. def cloneReplaceNonEmptyTable: Throwable
  76. def cloneReplaceUnsupported(tableIdentifier: TableIdentifier): Throwable
  77. def columnNameNotFoundException(colName: String, scheme: String): Throwable
  78. def columnNotFound(path: Seq[String], schema: StructType): Throwable
  79. def columnNotInSchemaException(column: String, schema: StructType): Throwable
  80. def columnOfTargetTableNotFoundInMergeException(targetCol: String, colNames: String): Throwable
  81. def columnPathNotNested(columnPath: String, other: DataType, column: Seq[String]): Throwable
  82. def columnRenameNotSupported: Throwable
  83. def concurrentAppendException(conflictingCommit: Option[CommitInfo], partition: String, customRetryMsg: Option[String] = None): io.delta.exceptions.ConcurrentAppendException
  84. def concurrentDeleteDeleteException(conflictingCommit: Option[CommitInfo], file: String): io.delta.exceptions.ConcurrentDeleteDeleteException
  85. def concurrentDeleteReadException(conflictingCommit: Option[CommitInfo], file: String): io.delta.exceptions.ConcurrentDeleteReadException
  86. def concurrentModificationExceptionMsg(sparkConf: SparkConf, baseMessage: String, commit: Option[CommitInfo]): String
  87. def concurrentTransactionException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ConcurrentTransactionException
  88. def concurrentWriteException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ConcurrentWriteException
  89. def configureSparkSessionWithExtensionAndCatalog(originalException: Option[Throwable]): Throwable
  90. def constraintAlreadyExists(name: String, oldExpr: String): AnalysisException
  91. def convertMetastoreMetadataMismatchException(tableProperties: Map[String, String], deltaConfiguration: Map[String, String]): Throwable
  92. def convertNonParquetTablesException(ident: TableIdentifier, sourceName: String): Throwable
  93. def convertToDeltaNoPartitionFound(tableName: String): Throwable
  94. def convertToDeltaRowTrackingEnabledWithoutStatsCollection: Throwable
  95. def convertToDeltaWithColumnMappingNotSupported(mode: DeltaColumnMappingMode): Throwable
  96. def createExternalTableWithoutLogException(path: Path, tableName: String, spark: SparkSession): Throwable
  97. def createExternalTableWithoutSchemaException(path: Path, tableName: String, spark: SparkSession): Throwable
  98. def createManagedTableWithoutSchemaException(tableName: String, spark: SparkSession): Throwable
  99. def createTableWithDifferentPartitioningException(path: Path, specifiedColumns: Seq[String], existingColumns: Seq[String]): Throwable
  100. def createTableWithDifferentPropertiesException(path: Path, specifiedProperties: Map[String, String], existingProperties: Map[String, String]): Throwable
  101. def createTableWithDifferentSchemaException(path: Path, specifiedSchema: StructType, existingSchema: StructType, diffs: Seq[String]): Throwable
  102. def createTableWithNonEmptyLocation(tableId: String, tableLocation: String): Throwable
  103. def deletionVectorCardinalityMismatch(): Throwable
  104. def deletionVectorChecksumMismatch(): Throwable
  105. def deletionVectorInvalidRowIndex(): Throwable
  106. def deletionVectorSizeMismatch(): Throwable
  107. def deltaDynamicPartitionOverwriteDisabled(): Throwable
  108. def deltaLogAlreadyExistsException(path: String): Throwable
  109. def deltaSourceIgnoreChangesError(version: Long, removedFile: String, dataPath: String): Throwable
  110. def deltaSourceIgnoreDeleteError(version: Long, removedFile: String, dataPath: String): Throwable
  111. def deltaStatsCollectionColumnNotFound(statsType: String, columnPath: String): Throwable
  112. def deltaTableFoundInExecutor(): Throwable
  113. def deltaVersionsNotContiguousException(spark: SparkSession, deltaVersions: Seq[Long]): Throwable
  114. def describeViewHistory: Throwable
  115. def differentDeltaTableReadByStreamingSource(newTableId: String, oldTableId: String): Throwable
  116. def directoryNotFoundException(path: String): Throwable
  117. def domainMetadataDuplicate(domainName: String): Throwable
  118. def domainMetadataTableFeatureNotSupported(domainNames: String): Throwable
  119. def dropColumnAtIndexLessThanZeroException(pos: Int): Throwable
  120. def dropColumnNotSupported(suggestUpgrade: Boolean): Throwable
  121. def dropNestedColumnsFromNonStructTypeException(struct: DataType): Throwable
  122. def dropPartitionColumnNotSupported(droppingPartCols: Seq[String]): Throwable
  123. def dropTableFeatureConflictRevalidationFailed(conflictingCommit: Option[CommitInfo] = None): DeltaTableFeatureException
  124. def dropTableFeatureFeatureNotSupportedByClient(feature: String): DeltaTableFeatureException
  125. def dropTableFeatureFeatureNotSupportedByProtocol(feature: String): DeltaTableFeatureException
  126. def dropTableFeatureHistoricalVersionsExist(feature: String, metadata: Metadata): DeltaTableFeatureException
  127. def dropTableFeatureNonRemovableFeature(feature: String): DeltaTableFeatureException
  128. def dropTableFeatureNotDeltaTableException(): Throwable
  129. def dropTableFeatureWaitForRetentionPeriod(feature: String, metadata: Metadata): DeltaTableFeatureException
  130. def duplicateColumnOnInsert(): Throwable
  131. def duplicateColumnsOnUpdateTable(originalException: Throwable): Throwable
  132. def duplicatedColumnId(mode: DeltaColumnMappingMode, id: Long, schema: StructType): Throwable
  133. def duplicatedPhysicalName(mode: DeltaColumnMappingMode, physicalName: String, schema: StructType): Throwable
  134. def emptyCalendarInterval: Throwable
  135. def emptyDataException: Throwable
  136. def emptyDirectoryException(directory: String): Throwable
  137. def endBeforeStartVersionInCDC(start: Long, end: Long): Throwable

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

  138. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  139. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  140. 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

  141. def excludeRegexOptionException(regexOption: String, cause: Throwable = null): Throwable
  142. def expressionsNotFoundInGeneratedColumn(column: String): Throwable
  143. def extractReferencesFieldNotFound(field: String, exception: Throwable): Throwable
  144. def failOnCheckpointRename(src: Path, dest: Path): DeltaIllegalStateException
  145. def failOnDataLossException(expectedVersion: Long, seenVersion: Long): Throwable
  146. def failRelativizePath(pathName: String): Throwable
  147. def failToDeserializeSchemaLog(location: String): Throwable
  148. def failToParseSchemaLog: Throwable
  149. def failedFindAttributeInOutputColumns(newAttrName: String, targetColNames: String): Throwable
  150. def failedFindPartitionColumnInOutputPlan(partitionColumn: String): Throwable
  151. def failedInferSchema: Throwable
  152. def failedMergeSchemaFile(file: String, schema: String, cause: Throwable): Throwable
  153. def failedReadFileFooter(file: String, e: Throwable): Throwable
  154. def failedRecognizePredicate(predicate: String, cause: Throwable): Throwable
  155. def failedScanWithHistoricalVersion(historicalVersion: Long): Throwable
  156. def failedToGetSnapshotDuringColumnMappingStreamingReadCheck(cause: Throwable): Throwable
  157. val faqRelativePath: String
  158. def fileAlreadyExists(file: String): Throwable
  159. def fileNotFoundException(path: String): Throwable
  160. def fileOrDirectoryNotFoundException(path: String): Throwable
  161. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  162. def formatColumn(colName: String): String
  163. def formatColumnList(colNames: Seq[String]): String
  164. def formatSchema(schema: StructType): String
  165. def foundDuplicateColumnsException(colType: String, duplicateCols: String): Throwable
  166. def foundInvalidCharsInColumnNames(cause: Throwable): Throwable
  167. def foundMapTypeColumnException(key: String, value: String): Throwable
  168. def foundViolatingConstraintsForColumnChange(operation: String, columnName: String, constraints: Map[String, String]): Throwable
  169. def foundViolatingGeneratedColumnsForColumnChange(operation: String, columnName: String, fields: Seq[StructField]): Throwable
  170. 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.

    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
  171. def generateManifestWithColumnMappingNotSupported: Throwable
  172. def generateNotSupportedWithDeletionVectors(): Throwable
  173. def generatedColumnsAggregateExpression(expr: Expression): Throwable
  174. def generatedColumnsNonDeterministicExpression(expr: Expression): Throwable
  175. def generatedColumnsReferToWrongColumns(e: AnalysisException): Throwable
  176. def generatedColumnsTypeMismatch(column: String, columnType: DataType, exprType: DataType): Throwable
  177. def generatedColumnsUDF(expr: Expression): Throwable
  178. def generatedColumnsUnsupportedExpression(expr: Expression): Throwable
  179. def generatedColumnsUpdateColumnType(current: StructField, update: StructField): Throwable
  180. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  181. def getCommonTags(deltaLog: DeltaLog, tahoeId: String): Map[TagDefinition, String]
    Definition Classes
    DeltaLogging
  182. def getQueryContext(sqlContext: SQLQueryContext): Array[QueryContext]
    Definition Classes
    DataTypeErrorsBase
  183. def getSummary(sqlContext: SQLQueryContext): String
    Definition Classes
    DataTypeErrorsBase
  184. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  185. def icebergClassMissing(sparkConf: SparkConf, cause: Throwable): Throwable
  186. def icebergCompatV1DisablingRequiredTableFeatureException(tf: TableFeature): Throwable
  187. def icebergCompatV1IncompatibleTableFeatureException(tf: TableFeature): Throwable
  188. def icebergCompatV1MissingRequiredTableFeatureException(tf: TableFeature): Throwable
  189. def icebergCompatV1ReplacePartitionedTableException(prevPartitionCols: Seq[String], newPartitionCols: Seq[String]): Throwable
  190. def icebergCompatV1UnsupportedDataTypeException(schema: StructType): Throwable
  191. def icebergCompatV1WrongRequiredTablePropertyException(key: String, actualValue: String, requiredValue: String): Throwable
  192. def identityColumnInconsistentMetadata(colName: String, hasStart: Boolean, hasStep: Boolean, hasInsert: Boolean): Throwable
  193. def ignoreStreamingUpdatesAndDeletesWarning(spark: SparkSession): String
  194. def illegalDeltaOptionException(name: String, input: String, explain: String): Throwable
  195. def illegalFilesFound(file: String): Throwable
  196. def illegalUsageException(option: String, operation: String): Throwable
  197. def inSubqueryNotSupportedException(operation: String): Throwable
  198. def incompatibleSchemaLogDeltaTable(persistedTableId: String, tableId: String): Throwable
  199. def incompatibleSchemaLogPartitionSchema(persistedPartitionSchema: StructType, tablePartitionSchema: StructType): Throwable
  200. def inconsistentLogStoreConfs(setKeys: Seq[(String, String)]): Throwable
  201. def incorrectArrayAccess(): Throwable
  202. def incorrectArrayAccessByName(rightName: String, wrongName: String): Throwable
  203. def incorrectLogStoreImplementationException(sparkConf: SparkConf, cause: Throwable): Throwable
  204. def indexLargerOrEqualThanStruct(pos: Int, len: Int): Throwable
  205. def indexLargerThanStruct(pos: Int, column: StructField, len: Int): Throwable
  206. def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  207. def initializeLogIfNecessary(isInterpreter: Boolean): Unit
    Attributes
    protected
    Definition Classes
    Logging
  208. def invalidColumnName(name: String): Throwable
  209. def invalidCommittedVersion(attemptVersion: Long, currentVersion: Long): Throwable
  210. def invalidConstraintName(name: String): AnalysisException
  211. def invalidFormatFromSourceVersion(wrongVersion: Long, expectedVersion: Integer): Throwable
  212. def invalidIdempotentWritesOptionsException(explain: String): Throwable
  213. def invalidInterval(interval: String): Throwable
  214. def invalidIsolationLevelException(s: String): Throwable
  215. def invalidPartitionColumn(e: AnalysisException): Throwable
  216. def invalidPartitionColumn(col: String, tbl: String): Throwable
  217. def invalidSourceVersion(version: JValue): Throwable
  218. def invalidTableValueFunction(function: String): Throwable
  219. def invalidTimestampFormat(ts: String, format: String, cause: Option[Throwable] = None): Throwable
  220. def invalidV1TableCall(callVersion: String, tableVersion: String): Throwable
  221. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  222. def isTraceEnabled(): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  223. def iteratorAlreadyClosed(): Throwable
  224. def log: Logger
    Attributes
    protected
    Definition Classes
    Logging
  225. def logConsole(line: String): Unit
    Definition Classes
    DatabricksLogging
  226. def logDebug(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  227. def logDebug(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  228. def logError(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  229. def logError(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  230. def logFailedIntegrityCheck(version: Long, mismatchOption: String): Throwable
  231. def logFileNotFoundException(path: Path, version: Long, metadata: Metadata): Throwable
  232. def logFileNotFoundExceptionForStreamingSource(e: FileNotFoundException): Throwable
  233. def logInfo(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  234. def logInfo(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  235. def logName: String
    Attributes
    protected
    Definition Classes
    Logging
  236. def logStoreConfConflicts(classConf: Seq[(String, String)], schemeConf: Seq[(String, String)]): Throwable
  237. def logTrace(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  238. def logTrace(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  239. def logWarning(msg: => String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  240. def logWarning(msg: => String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  241. def materializedRowCommitVersionMetadataMissing(tableName: String): Throwable
  242. def materializedRowIdMetadataMissing(tableName: String): Throwable
  243. def maxArraySizeExceeded(): Throwable
  244. def maxColumnIdNotSet: Throwable
  245. def maxColumnIdNotSetCorrectly(tableMax: Long, fieldMax: Long): Throwable
  246. def maxCommitRetriesExceededException(attemptNumber: Int, attemptVersion: Long, initAttemptVersion: Long, numActions: Int, totalCommitAttemptTime: Long): Throwable
  247. def metadataAbsentException(): Throwable
  248. def metadataChangedException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.MetadataChangedException
  249. def missingColumn(attr: Attribute, targetAttrs: Seq[Attribute]): Throwable
  250. def missingColumnId(mode: DeltaColumnMappingMode, field: String): Throwable
  251. def missingColumnsInInsertInto(column: String): Throwable
  252. def missingDeltaStorageJar(e: NoClassDefFoundError): Throwable
  253. def missingPartFilesException(version: Long, ae: Exception): Throwable
  254. def missingPartitionColumn(col: String, schemaCatalog: String): Throwable
  255. def missingPhysicalName(mode: DeltaColumnMappingMode, field: String): Throwable
  256. def missingProviderForConvertException(path: String): Throwable
  257. def missingTableIdentifierException(operationName: String): Throwable
  258. def modifyAppendOnlyTableException(tableName: String): Throwable
  259. def multiColumnInPredicateNotSupportedException(operation: String): Throwable
  260. 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"

  261. def multipleLoadPathsException(paths: Seq[String]): Throwable
  262. def multipleSourceRowMatchingTargetRowInMergeException(spark: SparkSession): Throwable
  263. def multipleTimeTravelSyntaxUsed: Throwable
  264. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  265. def nestedFieldNotSupported(operation: String, field: String): Throwable
  266. def nestedFieldsNeedRename(columns: Set[String], baseSchema: StructType): Throwable
  267. def nestedNotNullConstraint(parent: String, nested: DataType, nestType: String): AnalysisException
  268. def newCheckConstraintViolated(num: Long, tableName: String, expr: String): AnalysisException
  269. def newNotNullViolated(num: Long, tableName: String, col: UnresolvedAttribute): AnalysisException
  270. def noHistoryFound(logPath: Path): Throwable
  271. def noNewAttributeId(oldAttr: AttributeReference): Throwable
  272. def noRecreatableHistoryFound(logPath: Path): Throwable
  273. def noRelationTable(tableIdent: Identifier): Throwable
  274. def noStartVersionForCDC(): Throwable

    Throwable used when CDC options contain no 'start'.

  275. def nonDeterministicNotSupportedException(op: String, cond: Expression): Throwable
  276. def nonExistentColumnInSchema(column: String, schema: String): Throwable
  277. def nonExistentDeltaTable(tableId: DeltaTableIdentifier): Throwable
  278. def nonGeneratedColumnMissingUpdateExpression(column: Attribute): Throwable
  279. def nonPartitionColumnAbsentException(colsDropped: Boolean): Throwable
  280. def nonPartitionColumnReference(colName: String, partitionColumns: Seq[String]): Throwable
  281. def nonSinglePartNamespaceForCatalog(ident: String): Throwable
  282. def nonexistentConstraint(constraintName: String, tableName: String): AnalysisException
  283. def notADeltaSourceException(command: String, plan: Option[LogicalPlan] = None): Throwable
  284. def notADeltaTable(table: String): Throwable
  285. def notADeltaTableException(operation: String): Throwable
  286. def notADeltaTableException(operation: String, tableName: String): Throwable
  287. def notADeltaTableException(operation: String, deltaTableIdentifier: DeltaTableIdentifier): Throwable
  288. def notADeltaTableException(deltaTableIdentifier: DeltaTableIdentifier): Throwable
  289. def notEnoughColumnsInInsert(table: String, query: Int, target: Int, nestedField: Option[String] = None): Throwable
  290. def notFoundFileToBeRewritten(absolutePath: String, candidates: Iterable[String]): Throwable
  291. def notNullColumnMissingException(constraint: NotNull): Throwable
  292. def notNullColumnNotFoundInStruct(struct: String): Throwable
  293. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  294. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  295. def nullableParentWithNotNullNestedField: Throwable
  296. def operationNotSupportedException(operation: String): Throwable
  297. def operationNotSupportedException(operation: String, tableIdentifier: TableIdentifier): Throwable
  298. def operationOnTempViewWithGenerateColsNotSupported(op: String): Throwable
  299. def outputModeNotSupportedException(dataSource: String, outputMode: String): Throwable
  300. def overwriteSchemaUsedWithDynamicPartitionOverwrite(): Throwable
  301. def partitionColumnCastFailed(columnValue: String, dataType: String, columnName: String): Throwable
  302. def partitionColumnNotFoundException(colName: String, schema: Seq[Attribute]): Throwable
  303. def partitionPathInvolvesNonPartitionColumnException(badColumns: Seq[String], fragment: String): Throwable
  304. def partitionPathParseException(fragment: String): Throwable
  305. def partitionSchemaInIcebergTables: Throwable
  306. def pathAlreadyExistsException(path: Path): Throwable
  307. def pathNotExistsException(path: String): Throwable
  308. def pathNotSpecifiedException: Throwable
  309. def postCommitHookFailedException(failedHook: PostCommitHook, failedOnCommitVersion: Long, extraErrorMessage: String, error: Throwable): Throwable
  310. def protocolChangedException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ProtocolChangedException
  311. def protocolPropNotIntException(key: String, value: String): Throwable
  312. def provideOneOfInTimeTravel: Throwable
  313. def quoteByDefault(elem: String): String
    Attributes
    protected
    Definition Classes
    DataTypeErrorsBase
  314. def readTableWithoutSchemaException(identifier: String): Throwable
  315. 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
  316. 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
  317. 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
  318. def recordEvent(metric: MetricDefinition, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, trimBlob: Boolean = true): Unit
    Definition Classes
    DatabricksLogging
  319. def recordFrameProfile[T](group: String, name: String)(thunk: => T): T
    Attributes
    protected
    Definition Classes
    DeltaLogging
  320. 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
  321. def recordProductEvent(metric: MetricDefinition with CentralizableMetric, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, trimBlob: Boolean = true): Unit
    Definition Classes
    DatabricksLogging
  322. 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
  323. 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
  324. def removeFileCDCMissingExtendedMetadata(fileName: String): Throwable
  325. def replaceWhereMismatchException(replaceWhere: String, badPartitions: String): Throwable
  326. def replaceWhereMismatchException(replaceWhere: String, invariantViolation: InvariantViolationException): Throwable
  327. def replaceWhereUsedInOverwrite(): Throwable
  328. def replaceWhereUsedWithDynamicPartitionOverwrite(): Throwable
  329. def replaceWhereWithFilterDataChangeUnset(dataFilters: String): Throwable
  330. def restoreMissedDataFilesError(missedFiles: Array[String], version: Long): Throwable
  331. def restoreTimestampBeforeEarliestException(userTimestamp: String, earliestTimestamp: String): Throwable
  332. def restoreTimestampGreaterThanLatestException(userTimestamp: String, latestTimestamp: String): Throwable
  333. def restoreVersionNotExistException(userVersion: Long, earliest: Long, latest: Long): Throwable
  334. def rowIdAssignmentWithoutStats: Throwable
  335. def schemaChangeDuringMappingModeChangeNotSupported(oldSchema: StructType, newSchema: StructType): Throwable
  336. def schemaChangedException(readSchema: StructType, dataSchema: StructType, retryable: Boolean, version: Option[Long], includeStartingVersionOrTimestampMessage: Boolean): Throwable
  337. def schemaChangedSinceAnalysis(atAnalysis: StructType, latestSchema: StructType, mentionLegacyFlag: Boolean = false): Throwable
  338. def schemaNotConsistentWithTarget(tableSchema: String, targetAttr: String): Throwable
  339. def schemaNotProvidedException: Throwable
  340. def schemaNotSetException: Throwable
  341. def schemaTrackingLocationNotUnderCheckpointLocation(schemaTrackingLocation: String, checkpointLocation: String): Throwable
  342. def setLocationNotSupportedOnPathIdentifiers(): Throwable
  343. def setTransactionVersionConflict(appId: String, version1: Long, version2: Long): Throwable
  344. def showPartitionInNotPartitionedColumn(badColumns: Set[String]): Throwable
  345. def showPartitionInNotPartitionedTable(tableName: String): Throwable
  346. def sourceMaterializationFailedRepeatedlyInMerge: Throwable
  347. def sourceNotDeterministicInMergeException(spark: SparkSession): Throwable
  348. def sourcesWithConflictingSchemaTrackingLocation(schemaTrackingLocatiob: String, tableOrPath: String): Throwable
  349. def sparkSessionNotSetException(): Throwable
  350. def sparkTaskThreadNotFound: Throwable
  351. def specifySchemaAtReadTimeException: Throwable
  352. def startVersionAfterLatestVersion(start: Long, latest: Long): Throwable

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

  353. def startingVersionAndTimestampBothSetException(versionOptKey: String, timestampOptKey: String): Throwable
  354. def staticPartitionsNotSupportedException: Throwable
  355. def statsRecomputeNotSupportedOnDvTables(): Throwable
  356. def streamWriteNullTypeException: Throwable
  357. def streamingMetadataEvolutionException(newSchema: StructType, newConfigs: Map[String, String], newProtocol: Protocol): Throwable
  358. def streamingMetadataLogInitFailedIncompatibleMetadataException(startVersion: Long, endVersion: Long): Throwable
  359. def subqueryNotSupportedException(op: String, cond: Expression): Throwable
  360. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  361. 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.

  362. def tableAlreadyExists(table: CatalogTable): Throwable
  363. def tableFeatureDropHistoryTruncationNotAllowed(): DeltaTableFeatureException
  364. def tableFeatureMismatchException(features: Iterable[String]): DeltaTableFeatureException
  365. def tableFeatureReadRequiresWriteException(requiredWriterVersion: Int): DeltaTableFeatureException
  366. def tableFeatureRequiresHigherReaderProtocolVersion(feature: String, currentVersion: Int, requiredVersion: Int): DeltaTableFeatureException
  367. def tableFeatureRequiresHigherWriterProtocolVersion(feature: String, currentVersion: Int, requiredVersion: Int): DeltaTableFeatureException
  368. def tableFeaturesRequireManualEnablementException(unsupportedFeatures: Iterable[TableFeature], supportedFeatures: Iterable[TableFeature]): Throwable
  369. def tableLocationMismatch(table: CatalogTable, existingTable: CatalogTable): Throwable
  370. def tableNotSupportedException(operation: String): Throwable
  371. def targetTableFinalSchemaEmptyException(): Throwable
  372. def throwDeltaIllegalArgumentException(): Throwable

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

  373. def timeTravelInvalidBeginValue(timeTravelKey: String, cause: Throwable): Throwable
  374. def timeTravelNotSupportedException: Throwable
  375. def timestampGreaterThanLatestCommit(userTimestamp: Timestamp, commitTs: Timestamp, timestampString: String): Throwable
  376. def timestampInvalid(expr: Expression): Throwable
  377. def toDSOption(option: String): String
    Definition Classes
    QueryErrorsBase
  378. def toSQLConf(conf: String): String
    Definition Classes
    DataTypeErrorsBase
  379. def toSQLConfVal(conf: String): String
    Definition Classes
    QueryErrorsBase
  380. def toSQLExpr(e: Expression): String
    Definition Classes
    QueryErrorsBase
  381. def toSQLId(parts: Seq[String]): String
    Definition Classes
    DataTypeErrorsBase
  382. def toSQLId(parts: String): String
    Definition Classes
    DataTypeErrorsBase
  383. def toSQLSchema(schema: String): String
    Definition Classes
    QueryErrorsBase
  384. def toSQLStmt(text: String): String
    Definition Classes
    DataTypeErrorsBase
  385. def toSQLType(t: AbstractDataType): String
    Definition Classes
    DataTypeErrorsBase
  386. def toSQLType(text: String): String
    Definition Classes
    DataTypeErrorsBase
  387. def toSQLValue(v: Any, t: DataType): String
    Definition Classes
    QueryErrorsBase
  388. def toSQLValue(value: Double): String
    Definition Classes
    DataTypeErrorsBase
  389. def toSQLValue(value: Float): String
    Definition Classes
    DataTypeErrorsBase
  390. def toSQLValue(value: Long): String
    Definition Classes
    DataTypeErrorsBase
  391. def toSQLValue(value: Int): String
    Definition Classes
    DataTypeErrorsBase
  392. def toSQLValue(value: Short): String
    Definition Classes
    DataTypeErrorsBase
  393. def toSQLValue(value: UTF8String): String
    Definition Classes
    DataTypeErrorsBase
  394. def toSQLValue(value: String): String
    Definition Classes
    DataTypeErrorsBase
  395. def toString(): String
    Definition Classes
    AnyRef → Any
  396. def truncateTablePartitionNotSupportedException: Throwable
  397. def unSupportedInvariantNonStructType: Throwable
  398. def unexpectedAlias(alias: String): Throwable
  399. def unexpectedAttributeReference(ref: String): Throwable
  400. def unexpectedChangeFilesFound(changeFiles: String): Throwable
  401. def unexpectedDataChangeException(op: String): Throwable
  402. def unexpectedNumPartitionColumnsFromFileNameException(path: String, parsedCols: Seq[String], expectedCols: Seq[String]): Throwable
  403. def unexpectedPartialScan(path: Path): Throwable
  404. def unexpectedPartitionColumnFromFileNameException(path: String, parsedCol: String, expectedCol: String): Throwable
  405. def unexpectedPartitionSchemaFromUserException(catalogPartitionSchema: StructType, userPartitionSchema: StructType): Throwable
  406. def unexpectedProject(project: String): Throwable
  407. def uniFormIcebergRequiresIcebergCompatV1(): Throwable
  408. def unknownConfigurationKeyException(confKey: String): Throwable
  409. def unknownPrivilege(privilege: String): Throwable
  410. def unknownReadLimit(limit: String): Throwable
  411. def unrecognizedColumnChange(otherClass: String): Throwable
  412. def unrecognizedFileAction(otherAction: String, otherClass: String): Throwable
  413. def unrecognizedInvariant(): Throwable
  414. def unrecognizedLogFile(path: Path): Throwable
  415. def unsetNonExistentProperty(key: String, table: String): Throwable
  416. def unsupportSubqueryInPartitionPredicates(): Throwable
  417. def unsupportedAbsPathAddFile(str: String): Throwable
  418. 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.

  419. def unsupportedDataTypes(unsupportedDataType: UnsupportedDataTypeInfo, moreUnsupportedDataTypes: UnsupportedDataTypeInfo*): Throwable
  420. def unsupportedDeltaTableForPathHadoopConf(unsupportedOptions: Map[String, String]): Throwable
  421. def unsupportedExpression(causedBy: String, expType: DataType, supportedTypes: Seq[String]): Throwable
  422. def unsupportedGenerateModeException(modeName: String): Throwable
  423. def unsupportedReaderTableFeaturesInTableException(unsupported: Iterable[String]): DeltaTableFeatureException
  424. def unsupportedTableFeatureConfigsException(configs: Iterable[String]): DeltaTableFeatureException
  425. def unsupportedTableFeatureStatusException(feature: String, status: String): DeltaTableFeatureException
  426. def unsupportedTruncateSampleTables: Throwable
  427. def unsupportedWriteStagedTable(tableName: String): Throwable
  428. def unsupportedWriterTableFeaturesInTableException(unsupported: Iterable[String]): DeltaTableFeatureException
  429. def updateNonStructTypeFieldNotSupportedException(col: String, s: DataType): Throwable
  430. def updateSchemaMismatchExpression(from: StructType, to: StructType): Throwable
  431. def updateSetColumnNotFoundException(col: String, colList: Seq[String]): Throwable
  432. def updateSetConflictException(cols: Seq[String]): Throwable
  433. def useAddConstraints: Throwable
  434. def useSetLocation(): Throwable
  435. def vacuumBasePathMissingException(baseDeltaPath: Path): Throwable
  436. def viewInDescribeDetailException(view: TableIdentifier): Throwable
  437. def viewNotSupported(operationName: String): Throwable
  438. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  439. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  440. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  441. 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
  442. def zOrderingColumnDoesNotExistException(colName: String): Throwable
  443. def zOrderingOnColumnWithNoStatsException(colNames: Seq[String], spark: SparkSession): Throwable
  444. def zOrderingOnPartitionColumnException(colName: String): Throwable

Inherited from QueryErrorsBase

Inherited from DataTypeErrorsBase

Inherited from DeltaLogging

Inherited from DatabricksLogging

Inherited from DeltaProgressReporter

Inherited from Logging

Inherited from DocsPath

Inherited from AnyRef

Inherited from Any

Ungrouped