object DeltaErrors extends DeltaErrorsBase
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DeltaErrors
- DeltaErrorsBase
- QueryErrorsBase
- DataTypeErrorsBase
- DeltaLogging
- DatabricksLogging
- DeltaProgressReporter
- LoggingShims
- Logging
- DocsPath
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- implicit class LogStringContext extends AnyRef
- Definition Classes
- Logging
- case class LogRetentionConfig(key: String, value: String, truncateHistoryRetention: String) extends Product with Serializable
- Definition Classes
- DeltaErrorsBase
- case class TemporallyUnstableInputException(userTs: Timestamp, lastCommitTs: Timestamp, maximumTsStr: String) extends DeltaAnalysisException with Product with Serializable
- Definition Classes
- DeltaErrorsBase
- case class TimestampEarlierThanCommitRetentionException(userTimestamp: Timestamp, commitTs: Timestamp, timestampString: String) extends AnalysisException with Product with Serializable
- Definition Classes
- DeltaErrorsBase
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val EmptyCheckpointErrorMessage: String
- Definition Classes
- DeltaErrorsBase
- def actionNotFoundException(action: String, version: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def activeSparkSessionNotFound(): Throwable
- Definition Classes
- DeltaErrorsBase
- def activeTransactionAlreadySet(): Throwable
- Definition Classes
- DeltaErrorsBase
- def addColumnAtIndexLessThanZeroException(pos: String, col: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def addColumnParentNotStructException(column: StructField, other: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def addColumnStructNotFoundException(pos: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def addCommentToMapArrayException(fieldPath: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def addFilePartitioningMismatchException(addFilePartitions: Seq[String], metadataPartitions: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def addFileWithDVsAndTightBoundsException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def addFileWithDVsMissingNumRecordsException: Throwable
- Definition Classes
- DeltaErrorsBase
- def addingColumnWithInternalNameFailed(colName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def addingDeletionVectorsDisallowedException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def aggsNotSupportedException(op: String, cond: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- def alterClusterByNotAllowedException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def alterClusterByNotOnDeltaTableException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def alterTableChangeColumnException(fieldPath: String, oldField: StructField, newField: StructField): Throwable
- Definition Classes
- DeltaErrorsBase
- def alterTableClusterByOnPartitionedTableException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def alterTableReplaceColumnsException(oldSchema: StructType, newSchema: StructType, reason: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def alterTableSetClusteringTableFeatureException(tableFeature: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def alterTableSetLocationSchemaMismatchException(original: StructType, destination: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def ambiguousDataTypeChange(column: String, from: StructType, to: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def ambiguousPartitionColumnException(columnName: String, colMatches: Seq[StructField]): Throwable
- Definition Classes
- DeltaErrorsBase
- def ambiguousPathsInCreateTableException(identifier: String, location: String): Throwable
- Definition Classes
- DeltaErrorsBase
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def assertValidCallingFunction(): Unit
- Definition Classes
- DocsPath
- def assertionFailedError(msg: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def baseDocsPath(spark: SparkSession): String
- Definition Classes
- DeltaErrorsBase
- 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
- def blockBatchCdfReadWithIncompatibleSchemaChange(start: Long, end: Long, readSchema: StructType, readVersion: Long, incompatVersion: Long, isSchemaChange: Boolean = true): Throwable
If
isSchemaChangeis false, this means theincompatVersionactually refers to a data schema instead of a schema change.If
isSchemaChangeis false, this means theincompatVersionactually 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 tolegacymode 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.- Definition Classes
- DeltaErrorsBase
- def blockColumnMappingAndCdcOperation(op: Operation): Throwable
- Definition Classes
- DeltaErrorsBase
- def blockStreamingReadsWithIncompatibleNonAdditiveSchemaChanges(spark: SparkSession, readSchema: StructType, incompatibleSchema: StructType, detectedDuringStreaming: Boolean): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterCreateOnNonExistingColumnsException(unknownColumns: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterDropOnNonExistingColumnsException(unknownColumns: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterDropOnNonIndexedColumnException(name: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterInvalidParameterValueException(message: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterMultipleConfForSingleColumnException(name: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterOnColumnTypeNotSupportedException(name: String, dataType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterOnNestedColumnNotSupportedException(name: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def bloomFilterOnPartitionColumnNotSupportedException(name: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def canOnlyDropCheckpointProtectionWithHistoryTruncationException: DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def cannotChangeDataType(msg: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotChangeProvider(): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotContinueStreamingPostSchemaEvolution(nonAdditiveSchemaChangeOpType: String, previousSchemaChangeVersion: Long, currentSchemaChangeVersion: Long, checkpointHash: Int, readerOptionsUnblock: Seq[String], sqlConfsUnblock: Seq[String], prettyColumnChangeDetails: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotCreateLogPathException(logPath: String, cause: Throwable = null): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotDropCheckConstraintFeature(constraintNames: Seq[String]): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def cannotFindSourceVersionException(json: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotGenerateUpdateExpressions(): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotInsertIntoColumn(tableName: String, source: String, target: String, targetType: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotModifyTableProperty(prop: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotReconstructPathFromURI(uri: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotRenamePath(tempPath: String, path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotReplaceMissingTableException(itableIdentifier: Identifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotResolveColumn(fieldName: String, schema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotSetLocationMultipleTimes(locations: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotSpecifyBothFileListAndPatternString(): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotUpdateArrayField(table: String, field: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotUpdateMapField(table: String, field: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotUpdateOtherField(tableName: String, dataType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotUpdateStructField(table: String, field: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotUseDataTypeForPartitionColumnError(field: StructField): Throwable
- Definition Classes
- DeltaErrorsBase
- def cannotWriteIntoView(table: TableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def castPartitionValueException(partitionValue: String, dataType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def castingCauseOverflowErrorInTableWrite(from: DataType, to: DataType, columnName: String): ArithmeticException
- Definition Classes
- DeltaErrorsBase
- def cdcColumnsInData(columns: Seq[String]): Throwable
Thrown when main table data contains columns that are reserved for CDF, such as
_change_type.Thrown when main table data contains columns that are reserved for CDF, such as
_change_type.- Definition Classes
- DeltaErrorsBase
- def cdcNotAllowedInThisVersion(): Throwable
- Definition Classes
- DeltaErrorsBase
- def cdcWriteNotAllowedInThisVersion(): Throwable
- Definition Classes
- DeltaErrorsBase
- def changeColumnMappingModeNotSupported(oldMode: String, newMode: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def changeDataNotRecordedException(version: Long, start: Long, end: Long): Throwable
Throwable used when CDC is not enabled according to table metadata.
Throwable used when CDC is not enabled according to table metadata.
- Definition Classes
- DeltaErrorsBase
- def checkConstraintNotBoolean(name: String, expr: String): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def checkpointMismatchWithSnapshot: Throwable
- Definition Classes
- DeltaErrorsBase
- def checkpointNonExistTable(path: Path): Throwable
- Definition Classes
- DeltaErrorsBase
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def cloneAmbiguousTarget(externalLocation: String, targetIdent: TableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def cloneFromIcebergSourceWithPartitionEvolution(): Throwable
- Definition Classes
- DeltaErrorsBase
- def cloneFromIcebergSourceWithoutSpecs(): Throwable
- Definition Classes
- DeltaErrorsBase
- def cloneFromUnsupportedSource(name: String, format: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cloneOnRelativePath(path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def cloneReplaceNonEmptyTable: Throwable
- Definition Classes
- DeltaErrorsBase
- def cloneReplaceUnsupported(tableIdentifier: TableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def clusterByInvalidNumColumnsException(numColumnsLimit: Int, actualNumColumns: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def clusterByWithPartitionedBy(): Throwable
- Definition Classes
- DeltaErrorsBase
- def clusteringColumnMissingStats(clusteringColumnWithoutStats: String, statsSchema: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def clusteringColumnUnsupportedDataTypes(clusteringColumnsWithDataTypes: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def clusteringColumnsMismatchException(providedClusteringColumns: String, existingClusteringColumns: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def clusteringWithPartitionPredicatesException(predicates: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def clusteringWithZOrderByException(zOrderBy: Seq[UnresolvedAttribute]): Throwable
- Definition Classes
- DeltaErrorsBase
- def columnBuilderMissingDataType(colName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def columnMappingAdviceMessage(requiredProtocol: Protocol = ColumnMappingTableFeature.minProtocolVersion): String
- Attributes
- protected
- Definition Classes
- DeltaErrorsBase
- def columnNameNotFoundException(colName: String, scheme: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def columnNotFound(path: Seq[String], schema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def columnNotInSchemaException(column: String, schema: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def columnOfTargetTableNotFoundInMergeException(targetCol: String, colNames: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def columnPathNotNested(columnPath: String, other: DataType, column: Seq[String], schema: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def columnRenameNotSupported: Throwable
- Definition Classes
- DeltaErrorsBase
- def commandInvariantViolationException(operation: String, id: UUID): Throwable
- Definition Classes
- DeltaErrorsBase
- def concurrentAppendException(conflictingCommit: Option[CommitInfo], partition: String, customRetryMsg: Option[String] = None): io.delta.exceptions.ConcurrentAppendException
- Definition Classes
- DeltaErrorsBase
- def concurrentDeleteDeleteException(conflictingCommit: Option[CommitInfo], file: String): io.delta.exceptions.ConcurrentDeleteDeleteException
- Definition Classes
- DeltaErrorsBase
- def concurrentDeleteReadException(conflictingCommit: Option[CommitInfo], file: String): io.delta.exceptions.ConcurrentDeleteReadException
- Definition Classes
- DeltaErrorsBase
- def concurrentModificationExceptionMsg(sparkConf: SparkConf, baseMessage: String, commit: Option[CommitInfo]): String
- Definition Classes
- DeltaErrorsBase
- def concurrentTransactionException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ConcurrentTransactionException
- Definition Classes
- DeltaErrorsBase
- def concurrentWriteException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ConcurrentWriteException
- Definition Classes
- DeltaErrorsBase
- def configureSparkSessionWithExtensionAndCatalog(originalException: Option[Throwable]): Throwable
- Definition Classes
- DeltaErrorsBase
- def constraintAlreadyExists(name: String, oldExpr: String): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def constraintDataTypeMismatch(columnPath: Seq[String], columnType: DataType, dataType: DataType, constraints: Map[String, String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def convertMetastoreMetadataMismatchException(tableProperties: Map[String, String], deltaConfiguration: Map[String, String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def convertNonParquetTablesException(ident: TableIdentifier, sourceName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def convertToDeltaNoPartitionFound(tableName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def convertToDeltaRowTrackingEnabledWithoutStatsCollection: Throwable
- Definition Classes
- DeltaErrorsBase
- def convertToDeltaWithColumnMappingNotSupported(mode: DeltaColumnMappingMode): Throwable
- Definition Classes
- DeltaErrorsBase
- def createExternalTableWithoutLogException(path: Path, tableName: String, spark: SparkSession): Throwable
- Definition Classes
- DeltaErrorsBase
- def createExternalTableWithoutSchemaException(path: Path, tableName: String, spark: SparkSession): Throwable
- Definition Classes
- DeltaErrorsBase
- def createManagedTableWithoutSchemaException(tableName: String, spark: SparkSession): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableIdentifierLocationMismatch(identifier: String, location: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableMissingTableNameOrLocation(): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableSetClusteringTableFeatureException(tableFeature: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableWithDifferentClusteringException(path: Path, specifiedClusterBySpec: Option[ClusterBySpec], existingClusterBySpec: Option[ClusterBySpec]): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableWithDifferentPartitioningException(path: Path, specifiedColumns: Seq[String], existingColumns: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableWithDifferentPropertiesException(path: Path, specifiedProperties: Map[String, String], existingProperties: Map[String, String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableWithDifferentSchemaException(path: Path, specifiedSchema: StructType, existingSchema: StructType, diffs: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def createTableWithNonEmptyLocation(tableId: String, tableLocation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def deletedRecordCountsHistogramDeserializationException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deletionVectorCardinalityMismatch(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deletionVectorChecksumMismatch(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deletionVectorInvalidRowIndex(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deletionVectorSizeMismatch(): Throwable
- Definition Classes
- DeltaErrorsBase
- 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
- def deltaCannotCreateCatalogOwnedTable(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaCannotVacuumLite(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaCannotVacuumManagedTable(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaDynamicPartitionOverwriteDisabled(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaLogAlreadyExistsException(path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaRelationPathMismatch(relationPath: Seq[String], targetType: String, targetPath: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaSourceIgnoreChangesError(version: Long, removedFile: String, dataPath: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaSourceIgnoreDeleteError(version: Long, removedFile: String, dataPath: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaStatsCollectionColumnNotFound(statsType: String, columnPath: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaTableFoundInExecutor(): Throwable
- Definition Classes
- DeltaErrorsBase
- def deltaVersionsNotContiguousException(spark: SparkSession, deltaVersions: Seq[Long], startVersion: Long, endVersion: Long, versionToLoad: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def describeViewHistory: Throwable
- Definition Classes
- DeltaErrorsBase
- def differentDeltaTableReadByStreamingSource(newTableId: String, oldTableId: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def directoryNotFoundException(path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def domainMetadataDuplicate(domainName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def domainMetadataTableFeatureNotSupported(domainNames: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropCheckpointProtectionWaitForRetentionPeriod(metadata: Metadata): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def dropClusteringColumnNotSupported(droppingClusteringCols: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropColumnAtIndexLessThanZeroException(pos: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropColumnNotSupported(suggestUpgrade: Boolean): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropColumnOnSingleFieldSchema(schema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropNestedColumnsFromNonStructTypeException(struct: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropPartitionColumnNotSupported(droppingPartCols: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureCheckpointFailedException(featureName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureConflictRevalidationFailed(conflictingCommit: Option[CommitInfo] = None): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureFailedBecauseOfDependentFeatures(feature: String, dependentFeatures: Seq[String]): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureFeatureNotSupportedByClient(feature: String): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureFeatureNotSupportedByProtocol(feature: String): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureHistoricalVersionsExist(feature: String, metadata: Metadata): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureNonRemovableFeature(feature: String): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureNotDeltaTableException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def dropTableFeatureWaitForRetentionPeriod(feature: String, metadata: Metadata): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def duplicateColumnOnInsert(): Throwable
- Definition Classes
- DeltaErrorsBase
- def duplicateColumnsOnUpdateTable(originalException: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def duplicatedColumnId(mode: DeltaColumnMappingMode, id: Long, schema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def duplicatedPhysicalName(mode: DeltaColumnMappingMode, physicalName: String, schema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def emptyCalendarInterval: Throwable
- Definition Classes
- DeltaErrorsBase
- def emptyDataException: Throwable
- Definition Classes
- DeltaErrorsBase
- def emptyDirectoryException(directory: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def enablingColumnMappingDisallowedWhenColumnMappingMetadataAlreadyExists(): Throwable
- Definition Classes
- DeltaErrorsBase
- def endBeforeStartVersionInCDC(start: Long, end: Long): Throwable
Throwable used for invalid CDC 'start' and 'end' options, where end < start
Throwable used for invalid CDC 'start' and 'end' options, where end < start
- Definition Classes
- DeltaErrorsBase
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def errorFindingColumnPosition(columnPath: Seq[String], schema: DataType, extraErrMsg: String): Throwable
- Definition Classes
- DeltaErrorsBase
- 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
- def excludeRegexOptionException(regexOption: String, cause: Throwable = null): Throwable
- Definition Classes
- DeltaErrorsBase
- def expressionsNotFoundInGeneratedColumn(column: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def extractReferencesFieldNotFound(field: String, exception: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def failOnCheckpointRename(src: Path, dest: Path): DeltaIllegalStateException
- Definition Classes
- DeltaErrorsBase
- def failOnDataLossException(expectedVersion: Long, seenVersion: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def failRelativizePath(pathName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def failToDeserializeSchemaLog(location: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def failToParseSchemaLog: Throwable
- Definition Classes
- DeltaErrorsBase
- def failedFindAttributeInOutputColumns(newAttrName: String, targetColNames: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def failedFindPartitionColumnInOutputPlan(partitionColumn: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def failedInferSchema: Throwable
- Definition Classes
- DeltaErrorsBase
- def failedMergeSchemaFile(file: String, schema: String, cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def failedReadFileFooter(file: String, e: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def failedRecognizePredicate(predicate: String, cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def failedScanWithHistoricalVersion(historicalVersion: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def failedToGetSnapshotDuringColumnMappingStreamingReadCheck(cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- val faqRelativePath: String
- Definition Classes
- DeltaErrorsBase
- def fileAlreadyExists(file: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def fileNotFoundException(path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def fileOrDirectoryNotFoundException(path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def formatColumn(colName: String): String
- Definition Classes
- DeltaErrorsBase
- def formatColumnList(colNames: Seq[String]): String
- Definition Classes
- DeltaErrorsBase
- def formatSchema(schema: StructType): String
- Definition Classes
- DeltaErrorsBase
- def foundDuplicateColumnsException(colType: String, duplicateCols: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def foundInvalidCharsInColumnNames(invalidColumnNames: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def foundInvalidColumnNamesWhenRemovingColumnMapping(columnNames: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def foundMapTypeColumnException(key: String, value: String, schema: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def foundViolatingConstraintsForColumnChange(columnName: String, constraints: Map[String, String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def foundViolatingGeneratedColumnsForColumnChange(columnName: String, generatedColumns: Map[String, String]): Throwable
- Definition Classes
- DeltaErrorsBase
- 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
- 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
- def generateManifestWithColumnMappingNotSupported: Throwable
- Definition Classes
- DeltaErrorsBase
- def generateNotSupportedWithDeletionVectors(): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsAggregateExpression(expr: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsDataTypeMismatch(columnPath: Seq[String], columnType: DataType, dataType: DataType, generatedColumns: Map[String, String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsExprTypeMismatch(column: String, columnType: DataType, exprType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsNonDeterministicExpression(expr: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsReferToWrongColumns(e: AnalysisException): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsUDF(expr: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsUnsupportedExpression(expr: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsUnsupportedType(dt: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def generatedColumnsUpdateColumnType(current: StructField, update: StructField): Throwable
- Definition Classes
- DeltaErrorsBase
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getCommonTags(deltaLog: DeltaLog, tahoeId: String): Map[TagDefinition, String]
- Definition Classes
- DeltaLogging
- def getErrorData(e: Throwable): Map[String, Any]
- Definition Classes
- DeltaLogging
- def getQueryContext(context: QueryContext): Array[QueryContext]
- Definition Classes
- DataTypeErrorsBase
- def getSummary(sqlContext: QueryContext): String
- Definition Classes
- DataTypeErrorsBase
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hudiClassMissing(sparkConf: SparkConf, cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergClassMissing(sparkConf: SparkConf, cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatChangeVersionNeedRewrite(version: Int, newVersion: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatDataFileRewriteFailedException(icebergCompatVersion: Int, cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatDeletionVectorsNotPurgedException(version: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatDeletionVectorsShouldBeDisabledException(version: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatDisablingRequiredTableFeatureException(version: Int, tf: TableFeature): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatIncompatibleTableFeatureException(version: Int, tf: TableFeature): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatMissingRequiredTableFeatureException(version: Int, tf: TableFeature): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatReorgAddFileTagsMissingException(tableVersion: Long, icebergCompatVersion: Int, addFilesCount: Long, addFilesWithTagsCount: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatReplacePartitionedTableException(version: Int, prevPartitionCols: Seq[String], newPartitionCols: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatUnsupportedDataTypeException(version: Int, dataType: DataType, schema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatUnsupportedPartitionDataTypeException(version: Int, dataType: DataType, schema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatUnsupportedTypeWideningException(version: Int, fieldPath: Seq[String], oldType: DataType, newType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatVersionMutualExclusive(version: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatVersionNotSupportedException(currVersion: Int, maxVersion: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def icebergCompatWrongRequiredTablePropertyException(version: Int, key: String, actualValue: String, requiredValue: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnAlterColumnNotSupported(): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnAlterNonDeltaFormatError(): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnAlterNonIdentityColumnError(): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnDataTypeNotSupported(unsupportedType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnExplicitInsertNotSupported(colName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnIllegalStep(): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnInconsistentMetadata(colName: String, hasStart: Boolean, hasStep: Boolean, hasInsert: Boolean): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnPartitionNotSupported(colName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnReplaceColumnsNotSupported(): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnUpdateNotSupported(colName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def identityColumnWithGenerationExpression(): Throwable
- Definition Classes
- DeltaErrorsBase
- def ignoreStreamingUpdatesAndDeletesWarning(spark: SparkSession): String
- Definition Classes
- DeltaErrorsBase
- def illegalDeltaOptionException(name: String, input: String, explain: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def illegalFilesFound(file: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def illegalUsageException(option: String, operation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def inSubqueryNotSupportedException(operation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def incompatibleSchemaLogDeltaTable(persistedTableId: String, tableId: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def incompatibleSchemaLogPartitionSchema(persistedPartitionSchema: StructType, tablePartitionSchema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def inconsistentLogStoreConfs(setKeys: Seq[(String, String)]): Throwable
- Definition Classes
- DeltaErrorsBase
- def incorrectArrayAccess(): Throwable
- Definition Classes
- DeltaErrorsBase
- def incorrectArrayAccessByName(rightName: String, wrongName: String, schema: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def incorrectLogStoreImplementationException(sparkConf: SparkConf, cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def indexLargerOrEqualThanStruct(pos: Int, len: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def indexLargerThanStruct(pos: Int, column: StructField, len: Int): Throwable
- Definition Classes
- DeltaErrorsBase
- def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
- Attributes
- protected
- Definition Classes
- Logging
- def initializeLogIfNecessary(isInterpreter: Boolean): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def invalidAutoCompactType(value: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidColumnName(name: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidCommitIntermediateRedirectState(state: RedirectState): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidCommittedVersion(attemptVersion: Long, currentVersion: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidConstraintName(name: String): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def invalidFormatFromSourceVersion(wrongVersion: Long, expectedVersion: Integer): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidIdempotentWritesOptionsException(explain: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidInterval(interval: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidInventorySchema(expectedSchema: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidIsolationLevelException(s: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidPartitionColumn(e: AnalysisException): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidPartitionColumn(col: String, tbl: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidRedirectStateTransition(table: String, oldState: RedirectState, newState: RedirectState): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidRemoveTableRedirect(table: String, currentState: RedirectState): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidSetUnSetRedirectCommand(table: String, newProperty: String, existingProperty: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidSourceOffsetFormat(): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidSourceVersion(version: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidTableValueFunction(function: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidTimestampFormat(ts: String, format: String, cause: Option[Throwable] = None): Throwable
- Definition Classes
- DeltaErrorsBase
- def invalidV1TableCall(callVersion: String, tableVersion: String): Throwable
- Definition Classes
- DeltaErrorsBase
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isTraceEnabled(): Boolean
- Attributes
- protected
- Definition Classes
- Logging
- def iteratorAlreadyClosed(): Throwable
- Definition Classes
- DeltaErrorsBase
- def log: Logger
- Attributes
- protected
- Definition Classes
- Logging
- def logConsole(line: String): Unit
- Definition Classes
- DatabricksLogging
- def logDebug(msg: => String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logDebug(entry: LogEntry, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logDebug(entry: LogEntry): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logDebug(msg: => String): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logError(msg: => String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logError(entry: LogEntry, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logError(entry: LogEntry): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logError(msg: => String): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logFailedIntegrityCheck(version: Long, mismatchOption: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def logFileNotFoundException(path: Path, version: Long, metadata: Metadata): Throwable
- Definition Classes
- DeltaErrorsBase
- def logFileNotFoundExceptionForStreamingSource(e: FileNotFoundException): Throwable
- Definition Classes
- DeltaErrorsBase
- def logInfo(msg: => String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logInfo(entry: LogEntry, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logInfo(entry: LogEntry): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logInfo(msg: => String): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logName: String
- Attributes
- protected
- Definition Classes
- Logging
- def logStoreConfConflicts(classConf: Seq[(String, String)], schemeConf: Seq[(String, String)]): Throwable
- Definition Classes
- DeltaErrorsBase
- def logTrace(msg: => String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logTrace(entry: LogEntry, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logTrace(entry: LogEntry): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logTrace(msg: => String): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logWarning(msg: => String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logWarning(entry: LogEntry, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logWarning(entry: LogEntry): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def logWarning(msg: => String): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def materializedRowCommitVersionMetadataMissing(tableName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def materializedRowIdMetadataMissing(tableName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def maxArraySizeExceeded(): Throwable
- Definition Classes
- DeltaErrorsBase
- def maxColumnIdNotSet: Throwable
- Definition Classes
- DeltaErrorsBase
- def maxColumnIdNotSetCorrectly(tableMax: Long, fieldMax: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def maxCommitRetriesExceededException(attemptNumber: Int, attemptVersion: Long, initAttemptVersion: Long, numActions: Int, totalCommitAttemptTime: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def mergeAddVoidColumn(columnName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def metadataAbsentException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def metadataAbsentForExistingCatalogTable(tableName: String, tablePath: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def metadataChangedException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.MetadataChangedException
- Definition Classes
- DeltaErrorsBase
- def missingColumn(attr: Attribute, targetAttrs: Seq[Attribute]): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingColumnId(mode: DeltaColumnMappingMode, field: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingColumnsInInsertInto(column: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingCommitInfo(featureName: String, commitVersion: String): DeltaIllegalStateException
- Definition Classes
- DeltaErrorsBase
- def missingCommitTimestamp(commitVersion: String): DeltaIllegalStateException
- Definition Classes
- DeltaErrorsBase
- def missingDeltaStorageJar(e: NoClassDefFoundError): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingPartFilesException(version: Long, ae: Exception): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingPartitionColumn(col: String, schemaCatalog: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingPhysicalName(mode: DeltaColumnMappingMode, field: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingProviderForConvertException(path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def missingTableIdentifierException(operationName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def modifyAppendOnlyTableException(tableName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def multiColumnInPredicateNotSupportedException(operation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- 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"
- Definition Classes
- DeltaErrorsBase
- def multipleLoadPathsException(paths: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def multipleSourceRowMatchingTargetRowInMergeException(spark: SparkSession): Throwable
- Definition Classes
- DeltaErrorsBase
- def multipleTimeTravelSyntaxUsed: Throwable
- Definition Classes
- DeltaErrorsBase
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def nestedFieldNotSupported(operation: String, field: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def nestedNotNullConstraint(parent: String, nested: DataType, nestType: String): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def newCheckConstraintViolated(num: Long, tableName: String, expr: String): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def newNotNullViolated(num: Long, tableName: String, col: UnresolvedAttribute): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def noHistoryFound(logPath: Path): Throwable
- Definition Classes
- DeltaErrorsBase
- def noNewAttributeId(oldAttr: AttributeReference): Throwable
- Definition Classes
- DeltaErrorsBase
- def noRecreatableHistoryFound(logPath: Path): Throwable
- Definition Classes
- DeltaErrorsBase
- def noRedirectRulesViolated(op: Operation, noRedirectRules: Set[NoRedirectRule]): Throwable
- Definition Classes
- DeltaErrorsBase
- def noRelationTable(tableIdent: Identifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def noStartVersionForCDC(): Throwable
Throwable used when CDC options contain no 'start'.
Throwable used when CDC options contain no 'start'.
- Definition Classes
- DeltaErrorsBase
- def nonDeterministicNotSupportedException(op: String, cond: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- def nonExistentColumnInSchema(column: String, schema: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def nonExistentDeltaTable(tableId: DeltaTableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def nonGeneratedColumnMissingUpdateExpression(columnName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def nonPartitionColumnAbsentException(colsDropped: Boolean): Throwable
- Definition Classes
- DeltaErrorsBase
- def nonPartitionColumnReference(colName: String, partitionColumns: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def nonSinglePartNamespaceForCatalog(ident: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def nonexistentConstraint(constraintName: String, tableName: String): AnalysisException
- Definition Classes
- DeltaErrorsBase
- def notADeltaSourceException(command: String, plan: Option[LogicalPlan] = None): Throwable
- Definition Classes
- DeltaErrorsBase
- def notADeltaTable(table: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def notADeltaTableException(operation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def notADeltaTableException(operation: String, tableName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def notADeltaTableException(operation: String, deltaTableIdentifier: DeltaTableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def notADeltaTableException(deltaTableIdentifier: DeltaTableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def notEnoughColumnsInInsert(table: String, query: Int, target: Int, nestedField: Option[String] = None): Throwable
- Definition Classes
- DeltaErrorsBase
- def notFoundFileToBeRewritten(absolutePath: String, candidates: Iterable[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def notNullColumnMissingException(constraint: NotNull): Throwable
- Definition Classes
- DeltaErrorsBase
- def notNullColumnNotFoundInStruct(struct: String): Throwable
- Definition Classes
- DeltaErrorsBase
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def nullRangeBoundaryInCDCRead(): Throwable
Throwable used when a null 'start' or 'end' is provided in CDC reads.
Throwable used when a null 'start' or 'end' is provided in CDC reads.
- Definition Classes
- DeltaErrorsBase
- def nullableParentWithNotNullNestedField: Throwable
- Definition Classes
- DeltaErrorsBase
- def numRecordsMismatch(operation: String, numAddedRecords: Long, numRemovedRecords: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def operationNotSupportedException(operation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def operationNotSupportedException(operation: String, tableIdentifier: TableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def operationOnTempViewWithGenerateColsNotSupported(op: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def optimizeFullNotSupportedException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def ordinalNumber(i: Int): String
- Definition Classes
- QueryErrorsBase
- def outputModeNotSupportedException(dataSource: String, outputMode: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def overwriteSchemaUsedWithDynamicPartitionOverwrite(): Throwable
- Definition Classes
- DeltaErrorsBase
- def partitionColumnCastFailed(columnValue: String, dataType: String, columnName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def partitionColumnNotFoundException(colName: String, schema: Seq[Attribute]): Throwable
- Definition Classes
- DeltaErrorsBase
- def partitionPathInvolvesNonPartitionColumnException(badColumns: Seq[String], fragment: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def partitionPathParseException(fragment: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def partitionSchemaInIcebergTables: Throwable
- Definition Classes
- DeltaErrorsBase
- def pathAlreadyExistsException(path: Path): Throwable
- Definition Classes
- DeltaErrorsBase
- def pathNotExistsException(path: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def pathNotSpecifiedException: Throwable
- Definition Classes
- DeltaErrorsBase
- def postCommitHookFailedException(failedHook: PostCommitHook, failedOnCommitVersion: Long, extraErrorMessage: String, error: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def protocolChangedException(conflictingCommit: Option[CommitInfo]): io.delta.exceptions.ProtocolChangedException
- Definition Classes
- DeltaErrorsBase
- def protocolPropNotIntException(key: String, value: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def provideOneOfInTimeTravel: Throwable
- Definition Classes
- DeltaErrorsBase
- def quoteByDefault(elem: String): String
- Attributes
- protected
- Definition Classes
- DataTypeErrorsBase
- def readTableWithoutSchemaException(identifier: String): Throwable
- Definition Classes
- DeltaErrorsBase
- 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
deltaLogis null.
- Attributes
- protected
- Definition Classes
- DeltaLogging
- 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
- 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
- def recordEvent(metric: MetricDefinition, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, trimBlob: Boolean = true): Unit
- Definition Classes
- DatabricksLogging
- def recordFrameProfile[T](group: String, name: String)(thunk: => T): T
- Attributes
- protected
- Definition Classes
- DeltaLogging
- 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
- def recordProductEvent(metric: MetricDefinition with CentralizableMetric, additionalTags: Map[TagDefinition, String] = Map.empty, blob: String = null, trimBlob: Boolean = true): Unit
- Definition Classes
- DatabricksLogging
- 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
- 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
- def removeFileCDCMissingExtendedMetadata(fileName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def replaceWhereMismatchException(replaceWhere: String, badPartitions: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def replaceWhereMismatchException(replaceWhere: String, invariantViolation: InvariantViolationException): Throwable
- Definition Classes
- DeltaErrorsBase
- def replaceWhereUsedInOverwrite(): Throwable
- Definition Classes
- DeltaErrorsBase
- def replaceWhereUsedWithDynamicPartitionOverwrite(): Throwable
- Definition Classes
- DeltaErrorsBase
- def replaceWhereWithFilterDataChangeUnset(dataFilters: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def replacingClusteredTableWithPartitionedTableNotAllowed(): Throwable
- Definition Classes
- DeltaErrorsBase
- def restoreMissedDataFilesError(missedFiles: Array[String], version: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def restoreTimestampBeforeEarliestException(userTimestamp: String, earliestTimestamp: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def restoreTimestampGreaterThanLatestException(userTimestamp: String, latestTimestamp: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def restoreVersionNotExistException(userVersion: Long, earliest: Long, latest: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def rowIdAssignmentWithoutStats: Throwable
- Definition Classes
- DeltaErrorsBase
- def schemaChangeDuringMappingModeChangeNotSupported(oldSchema: StructType, newSchema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def schemaChangedException(readSchema: StructType, dataSchema: StructType, retryable: Boolean, version: Option[Long], includeStartingVersionOrTimestampMessage: Boolean): Throwable
- Definition Classes
- DeltaErrorsBase
- def schemaChangedSinceAnalysis(atAnalysis: StructType, latestSchema: StructType, mentionLegacyFlag: Boolean = false): Throwable
- Definition Classes
- DeltaErrorsBase
- def schemaNotConsistentWithTarget(tableSchema: String, targetAttr: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def schemaNotProvidedException: Throwable
- Definition Classes
- DeltaErrorsBase
- def schemaNotSetException: Throwable
- Definition Classes
- DeltaErrorsBase
- def schemaTrackingLocationNotUnderCheckpointLocation(schemaTrackingLocation: String, checkpointLocation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def setLocationNotSupportedOnPathIdentifiers(): Throwable
- Definition Classes
- DeltaErrorsBase
- def setTransactionVersionConflict(appId: String, version1: Long, version2: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def showPartitionInNotPartitionedColumn(badColumns: Set[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def showPartitionInNotPartitionedTable(tableName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def sourceMaterializationFailedRepeatedlyInMerge: Throwable
- Definition Classes
- DeltaErrorsBase
- def sourceNotDeterministicInMergeException(spark: SparkSession): Throwable
- Definition Classes
- DeltaErrorsBase
- def sourcesWithConflictingSchemaTrackingLocation(schemaTrackingLocatiob: String, tableOrPath: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def sparkSessionNotSetException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def sparkTaskThreadNotFound: Throwable
- Definition Classes
- DeltaErrorsBase
- def specifySchemaAtReadTimeException: Throwable
- Definition Classes
- DeltaErrorsBase
- def startVersionAfterLatestVersion(start: Long, latest: Long): Throwable
Throwable used for invalid CDC 'start' and 'latest' options, where latest < start
Throwable used for invalid CDC 'start' and 'latest' options, where latest < start
- Definition Classes
- DeltaErrorsBase
- def startingVersionAndTimestampBothSetException(versionOptKey: String, timestampOptKey: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def staticPartitionsNotSupportedException: Throwable
- Definition Classes
- DeltaErrorsBase
- def statsRecomputeNotSupportedOnDvTables(): Throwable
- Definition Classes
- DeltaErrorsBase
- def streamWriteNullTypeException: Throwable
- Definition Classes
- DeltaErrorsBase
- def streamingMetadataEvolutionException(newSchema: StructType, newConfigs: Map[String, String], newProtocol: Protocol): Throwable
- Definition Classes
- DeltaErrorsBase
- def streamingMetadataLogInitFailedIncompatibleMetadataException(startVersion: Long, endVersion: Long): Throwable
- Definition Classes
- DeltaErrorsBase
- def subqueryNotSupportedException(op: String, cond: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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.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.- Definition Classes
- DeltaErrorsBase
- def tableAlreadyExists(table: CatalogTable): Throwable
- Definition Classes
- DeltaErrorsBase
- def tableFeatureDropHistoryTruncationNotAllowed(): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def tableFeatureMismatchException(features: Iterable[String]): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def tableFeatureReadRequiresWriteException(requiredWriterVersion: Int): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def tableFeatureRequiresHigherReaderProtocolVersion(feature: String, currentVersion: Int, requiredVersion: Int): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def tableFeatureRequiresHigherWriterProtocolVersion(feature: String, currentVersion: Int, requiredVersion: Int): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def tableFeaturesRequireManualEnablementException(unsupportedFeatures: Iterable[TableFeature], supportedFeatures: Iterable[TableFeature]): Throwable
- Definition Classes
- DeltaErrorsBase
- def tableLocationMismatch(table: CatalogTable, existingTable: CatalogTable): Throwable
- Definition Classes
- DeltaErrorsBase
- def tableNotSupportedException(operation: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def targetTableFinalSchemaEmptyException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def throwDeltaIllegalArgumentException(): Throwable
This is a method only used for testing Py4J exception handling.
This is a method only used for testing Py4J exception handling.
- Definition Classes
- DeltaErrorsBase
- def timeTravelInvalidBeginValue(timeTravelKey: String, cause: Throwable): Throwable
- Definition Classes
- DeltaErrorsBase
- def timeTravelNotSupportedException: Throwable
- Definition Classes
- DeltaErrorsBase
- def timestampGreaterThanLatestCommit(userTs: Timestamp, lastCommitTs: Timestamp, maximumTsStr: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def timestampInvalid(expr: Expression): Throwable
- Definition Classes
- DeltaErrorsBase
- def toDSOption(option: String): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLConf(conf: String): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLConfVal(conf: String): String
- Definition Classes
- QueryErrorsBase
- def toSQLExpr(e: Expression): String
- Definition Classes
- QueryErrorsBase
- def toSQLId(parts: Seq[String]): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLId(parts: String): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLStmt(text: String): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLType(t: AbstractDataType): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLType(text: String): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLValue(v: Any, t: DataType): String
- Definition Classes
- QueryErrorsBase
- def toSQLValue(value: Double): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLValue(value: Float): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLValue(value: Long): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLValue(value: Int): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLValue(value: Short): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLValue(value: UTF8String): String
- Definition Classes
- DataTypeErrorsBase
- def toSQLValue(value: String): String
- Definition Classes
- DataTypeErrorsBase
- def toString(): String
- Definition Classes
- AnyRef → Any
- def truncateTablePartitionNotSupportedException: Throwable
- Definition Classes
- DeltaErrorsBase
- def unSupportedInvariantNonStructType: Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedAlias(alias: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedAttributeReference(ref: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedChangeFilesFound(changeFiles: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedDataChangeException(op: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedNumPartitionColumnsFromFileNameException(path: String, parsedCols: Seq[String], expectedCols: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedPartialScan(path: Path): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedPartitionColumnFromFileNameException(path: String, parsedCol: String, expectedCol: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedPartitionSchemaFromUserException(catalogPartitionSchema: StructType, userPartitionSchema: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def unexpectedProject(project: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def uniFormHudiDeleteVectorCompat(): Throwable
- Definition Classes
- DeltaErrorsBase
- def uniFormHudiSchemaCompat(unsupportedType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def uniFormIcebergRequiresIcebergCompat(): Throwable
- Definition Classes
- DeltaErrorsBase
- def universalFormatConversionFailedException(failedOnCommitVersion: Long, format: String, errorMessage: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unknownConfigurationKeyException(confKey: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unknownPrivilege(privilege: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unknownReadLimit(limit: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unrecognizedColumnChange(otherClass: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unrecognizedFileAction(otherAction: String, otherClass: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unrecognizedInvariant(): Throwable
- Definition Classes
- DeltaErrorsBase
- def unrecognizedLogFile(path: Path): Throwable
- Definition Classes
- DeltaErrorsBase
- def unrecognizedRedirectSpec(spec: RedirectSpec): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsetNonExistentProperty(key: String, table: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportSubqueryInPartitionPredicates(): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedAbsPathAddFile(str: String): Throwable
- Definition Classes
- DeltaErrorsBase
- 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.
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.
- Definition Classes
- DeltaErrorsBase
- def unsupportedColumnMappingModeException(modeName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedDataTypes(unsupportedDataType: UnsupportedDataTypeInfo, moreUnsupportedDataTypes: UnsupportedDataTypeInfo*): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedDeepCloneException(): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedDeltaTableForPathHadoopConf(unsupportedOptions: Map[String, String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedExpression(causedBy: String, expType: DataType, supportedTypes: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedGenerateModeException(modeName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedReaderTableFeaturesInTableException(tableNameOrPath: String, unsupported: Iterable[String]): DeltaUnsupportedTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def unsupportedTableFeatureConfigsException(configs: Iterable[String]): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def unsupportedTableFeatureStatusException(feature: String, status: String): DeltaTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def unsupportedTruncateSampleTables: Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedTypeChangeInPreview(fieldPath: Seq[String], fromType: DataType, toType: DataType, feature: TypeWideningTableFeatureBase): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedTypeChangeInSchema(fieldPath: Seq[String], fromType: DataType, toType: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedWriteStagedTable(tableName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def unsupportedWriterTableFeaturesInTableException(tableNameOrPath: String, unsupported: Iterable[String]): DeltaUnsupportedTableFeatureException
- Definition Classes
- DeltaErrorsBase
- def unsupportedWritesWithMissingCoordinators(coordinatorName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def updateNonStructTypeFieldNotSupportedException(col: String, s: DataType): Throwable
- Definition Classes
- DeltaErrorsBase
- def updateSchemaMismatchExpression(from: StructType, to: StructType): Throwable
- Definition Classes
- DeltaErrorsBase
- def updateSetColumnNotFoundException(col: String, colList: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def updateSetConflictException(cols: Seq[String]): Throwable
- Definition Classes
- DeltaErrorsBase
- def useAddConstraints: Throwable
- Definition Classes
- DeltaErrorsBase
- def useSetLocation(): Throwable
- Definition Classes
- DeltaErrorsBase
- def vacuumBasePathMissingException(baseDeltaPath: Path): Throwable
- Definition Classes
- DeltaErrorsBase
- def variantShreddingUnsupported(): Throwable
- Definition Classes
- DeltaErrorsBase
- def versionInvalid(version: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def viewInDescribeDetailException(view: TableIdentifier): Throwable
- Definition Classes
- DeltaErrorsBase
- def viewNotSupported(operationName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withLogContext(context: Map[String, String])(body: => Unit): Unit
- Attributes
- protected
- Definition Classes
- Logging
- 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
- def zOrderingColumnDoesNotExistException(colName: String): Throwable
- Definition Classes
- DeltaErrorsBase
- def zOrderingOnColumnWithNoStatsException(colNames: Seq[String], spark: SparkSession): Throwable
- Definition Classes
- DeltaErrorsBase
- def zOrderingOnPartitionColumnException(colName: String): Throwable
- Definition Classes
- DeltaErrorsBase
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)