Package io.delta.kernel.internal

Class DeltaErrors

Object

io.delta.kernel.internal.DeltaErrors

public final class DeltaErrors
extends Object

Contains methods to create user-facing Delta exceptions.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DeltaErrors.SupplierWithIOException<T>

Method Summary

Modifier and Type	Method	Description
static KernelException	cannotModifyAppendOnlyTable(String tablePath)
static KernelException	cannotModifyTableProperty(String key)
static KernelException	cannotToggleRowTrackingOnExistingTable()
static KernelException	cdfMixedAddRemoveNotSupported(String tablePath)
static KernelException	checkpointOnUnpublishedCommits(String tablePath, long version, long maxPublishedVersion)
static KernelException	columnInvariantsNotSupported()
static KernelException	columnNotFoundInSchema(Column column, StructType tableSchema)
static ConcurrentWriteException	concurrentDomainMetadataAction(DomainMetadata domainMetadataAttempt, DomainMetadata winningDomainMetadata)
static KernelException	concurrentTransaction(String appId, long txnVersion, long lastUpdated)
static KernelException	conflictWithReservedInternalColumnName(String columnName)
static KernelException	dataSchemaMismatch(String tablePath, StructType tableSchema, StructType dataSchema)
static KernelException	defaultValueRequireIcebergV3()
static KernelException	defaultValueRequiresTableFeature()
static KernelException	disablingIcebergCompatFeatureOnExistingTable(String key)
static KernelException	domainMetadataUnsupported()
static KernelException	duplicateColumnsInSchema(StructType schema, List<String> duplicateColumns)
static KernelException	enablingClusteringOnPartitionedTableNotAllowed(String tablePath, Set<String> partitionColNames, List<Column> clusteringCols)
static KernelException	enablingIcebergCompatFeatureOnExistingTable(String key)
static KernelException	endVersionNotFound(String tablePath, long endVersionRequested, long latestAvailableVersion)
static KernelException	icebergCompatIncompatibleTableFeatures(String compatVersion, Set<TableFeature> incompatibleFeatures)
static KernelException	icebergCompatIncompatibleVersionEnabled(String compatVersion, String incompatibleIcebergCompatVersion)
static KernelException	icebergCompatMissingNumRecordsStats(String compatVersion, DataFileStatus dataFileStatus)
static KernelException	icebergCompatRequiredFeatureMissing(String compatVersion, String feature)
static KernelException	icebergCompatRequiresLiteralDefaultValue(String compatVersion, DataType dataType, String value)
static KernelException	icebergCompatUnsupportedTypeColumns(String compatVersion, List<DataType> dataTypes)
static KernelException	icebergCompatUnsupportedTypePartitionColumn(String compatVersion, DataType dataType)
static KernelException	icebergCompatUnsupportedTypeWidening(String compatVersion, TypeChange typeChange)
static KernelException	icebergWriterCompatInvalidPhysicalName(List<String> invalidFields)
static KernelException	invalidColumnName(String columnName, String unsupportedChars)
static KernelException	invalidConfigurationValueException(String key, String value, String helpMessage)
static KernelException	invalidFieldMove(int columnId, Optional<SchemaIterable.ParentStructFieldInfo> currentParent, Optional<SchemaIterable.ParentStructFieldInfo> newParent)
static KernelException	invalidResolvedVersionRange(String tablePath, long startVersion, long endVersion)
static KernelException	invalidVersionRange(long startVersion, long endVersion)
static KernelException	metadataChangedException()
static KernelException	metadataMissingRequiredCatalogTableProperty(String committerClassName, Map<String,String> missingOrViolatingProperties, Map<String,String> requiredCatalogTableProperties)
static KernelException	missingCheckpoint(String tablePath, long checkpointVersion)
static KernelException	missingNumRecordsStatsForRowTracking()
static KernelException	missingRowTrackingColumnRequested(String columnName)
static CommitRangeNotFoundException	noCommitFilesFoundForVersionRange(String tablePath, long startVersion, Optional<Long> endVersionOpt)
static KernelException	nonLiteralDefaultValue(String value)
static RuntimeException	nonRetryableCommitException(int attempt, long commitAsVersion, CommitFailedException cause)
static KernelException	overlappingTablePropertiesSetAndUnset(Set<String> violatingKeys)
static KernelException	partitionColumnMissingInData(String tablePath, String partitionColumn)
static KernelException	protocolChangedException(long attemptVersion)
static KernelException	requireSchemaForReplaceTable()
static KernelException	requiresSchemaForNewTable(String tablePath)
static KernelException	resolvedEndVersionAfterMaxCatalogVersion(String tablePath, long resolvedEndVersion, long maxCatalogVersion)
static KernelException	rowTrackingMetadataMissingInFile(String entry, String filePath)
static KernelException	rowTrackingRequiredForRowIdHighWatermark(String tablePath, String rowIdHighWatermark)
static KernelException	rowTrackingSupportedWithDomainMetadataUnsupported()
static StartVersionNotFoundException	startVersionNotFound(String tablePath, long startVersionRequested, Optional<Long> earliestAvailableVersion)
static KernelException	statsTypeMismatch(String fieldName, DataType expected, DataType actual)
static KernelException	tableAlreadyExists(String tablePath, String message)
static InvalidTableException	tableWithIctMissingCommitInfo(String dataPath, long version)
static InvalidTableException	tableWithIctMissingIct(String dataPath, long version)
static KernelException	timestampAfterLatestCommit(String tablePath, long providedTimestamp, long latestCommitTimestamp, long latestCommitVersion)
static KernelException	timestampBeforeFirstAvailableCommit(String tablePath, long providedTimestamp, long earliestCommitTimestamp, long earliestCommitVersion)
static KernelException	unknownConfigurationException(String confKey)
static KernelException	unsupportedDataType(DataType dataType)
static KernelException	unsupportedDataTypeForDefaultValue(String fieldName, String fieldType)
static KernelException	unsupportedPartitionDataType(String colName, DataType dataType)
static UnsupportedTableFeatureException	unsupportedReaderFeatures(String tablePath, Set<String> readerFeatures)
static UnsupportedProtocolVersionException	unsupportedReaderProtocol(String tablePath, int tableReaderVersion)
static KernelException	unsupportedStatsDataType(DataType dataType)
static UnsupportedTableFeatureException	unsupportedTableFeature(String feature)
static UnsupportedTableFeatureException	unsupportedWriterFeatures(String tablePath, Set<String> writerFeatures)
static UnsupportedProtocolVersionException	unsupportedWriterProtocol(String tablePath, int tableWriterVersion)
static KernelException	versionBeforeFirstAvailableCommit(String tablePath, long versionToLoad, long earliestVersion)
static KernelException	versionToLoadAfterLatestCommit(String tablePath, long versionToLoad, long latestVersion)
static KernelException	voidTypeEncountered()
static <T> T	wrapEngineException(Supplier<T> f, String msgString, Object... args)
static <T> T	wrapEngineExceptionThrowsIO(DeltaErrors.SupplierWithIOException<T> f, String msgString, Object... args)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

missingCheckpoint

public static KernelException missingCheckpoint(String tablePath,
 long checkpointVersion)

versionBeforeFirstAvailableCommit

public static KernelException versionBeforeFirstAvailableCommit(String tablePath,
 long versionToLoad,
 long earliestVersion)

versionToLoadAfterLatestCommit

public static KernelException versionToLoadAfterLatestCommit(String tablePath,
 long versionToLoad,
 long latestVersion)

timestampBeforeFirstAvailableCommit

public static KernelException timestampBeforeFirstAvailableCommit(String tablePath,
 long providedTimestamp,
 long earliestCommitTimestamp,
 long earliestCommitVersion)

timestampAfterLatestCommit

public static KernelException timestampAfterLatestCommit(String tablePath,
 long providedTimestamp,
 long latestCommitTimestamp,
 long latestCommitVersion)

noCommitFilesFoundForVersionRange

public static CommitRangeNotFoundException noCommitFilesFoundForVersionRange(String tablePath,
 long startVersion,
 Optional<Long> endVersionOpt)

startVersionNotFound

public static StartVersionNotFoundException startVersionNotFound(String tablePath,
 long startVersionRequested,
 Optional<Long> earliestAvailableVersion)

endVersionNotFound

public static KernelException endVersionNotFound(String tablePath,
 long endVersionRequested,
 long latestAvailableVersion)

invalidVersionRange

public static KernelException invalidVersionRange(long startVersion,
 long endVersion)

invalidResolvedVersionRange

public static KernelException invalidResolvedVersionRange(String tablePath,
 long startVersion,
 long endVersion)

resolvedEndVersionAfterMaxCatalogVersion

public static KernelException resolvedEndVersionAfterMaxCatalogVersion(String tablePath,
 long resolvedEndVersion,
 long maxCatalogVersion)

unsupportedReaderProtocol

public static UnsupportedProtocolVersionException unsupportedReaderProtocol(String tablePath,
 int tableReaderVersion)

unsupportedWriterProtocol

public static UnsupportedProtocolVersionException unsupportedWriterProtocol(String tablePath,
 int tableWriterVersion)

unsupportedTableFeature

public static UnsupportedTableFeatureException unsupportedTableFeature(String feature)

unsupportedReaderFeatures

public static UnsupportedTableFeatureException unsupportedReaderFeatures(String tablePath,
 Set<String> readerFeatures)

unsupportedWriterFeatures

public static UnsupportedTableFeatureException unsupportedWriterFeatures(String tablePath,
 Set<String> writerFeatures)

columnInvariantsNotSupported

public static KernelException columnInvariantsNotSupported()

checkpointOnUnpublishedCommits

public static KernelException checkpointOnUnpublishedCommits(String tablePath,
 long version,
 long maxPublishedVersion)

unsupportedDataType

public static KernelException unsupportedDataType(DataType dataType)

unsupportedStatsDataType

public static KernelException unsupportedStatsDataType(DataType dataType)

unsupportedPartitionDataType

public static KernelException unsupportedPartitionDataType(String colName,
 DataType dataType)

duplicateColumnsInSchema

public static KernelException duplicateColumnsInSchema(StructType schema,
 List<String> duplicateColumns)

conflictWithReservedInternalColumnName

public static KernelException conflictWithReservedInternalColumnName(String columnName)

invalidColumnName

public static KernelException invalidColumnName(String columnName,
 String unsupportedChars)

requiresSchemaForNewTable

public static KernelException requiresSchemaForNewTable(String tablePath)

requireSchemaForReplaceTable

public static KernelException requireSchemaForReplaceTable()

tableAlreadyExists

public static KernelException tableAlreadyExists(String tablePath,
 String message)

dataSchemaMismatch

public static KernelException dataSchemaMismatch(String tablePath,
 StructType tableSchema,
 StructType dataSchema)

statsTypeMismatch

public static KernelException statsTypeMismatch(String fieldName,
 DataType expected,
 DataType actual)

columnNotFoundInSchema

public static KernelException columnNotFoundInSchema(Column column,
 StructType tableSchema)

overlappingTablePropertiesSetAndUnset

public static KernelException overlappingTablePropertiesSetAndUnset(Set<String> violatingKeys)

icebergCompatMissingNumRecordsStats

public static KernelException icebergCompatMissingNumRecordsStats(String compatVersion,
 DataFileStatus dataFileStatus)

icebergCompatIncompatibleVersionEnabled

public static KernelException icebergCompatIncompatibleVersionEnabled(String compatVersion,
 String incompatibleIcebergCompatVersion)

icebergCompatUnsupportedTypeColumns

public static KernelException icebergCompatUnsupportedTypeColumns(String compatVersion,
 List<DataType> dataTypes)

icebergCompatUnsupportedTypeWidening

public static KernelException icebergCompatUnsupportedTypeWidening(String compatVersion,
 TypeChange typeChange)

icebergCompatUnsupportedTypePartitionColumn

public static KernelException icebergCompatUnsupportedTypePartitionColumn(String compatVersion,
 DataType dataType)

icebergCompatRequiresLiteralDefaultValue

public static KernelException icebergCompatRequiresLiteralDefaultValue(String compatVersion,
 DataType dataType,
 String value)

icebergCompatIncompatibleTableFeatures

public static KernelException icebergCompatIncompatibleTableFeatures(String compatVersion,
 Set<TableFeature> incompatibleFeatures)

icebergCompatRequiredFeatureMissing

public static KernelException icebergCompatRequiredFeatureMissing(String compatVersion,
 String feature)

enablingIcebergCompatFeatureOnExistingTable

public static KernelException enablingIcebergCompatFeatureOnExistingTable(String key)

icebergWriterCompatInvalidPhysicalName

public static KernelException icebergWriterCompatInvalidPhysicalName(List<String> invalidFields)

disablingIcebergCompatFeatureOnExistingTable

public static KernelException disablingIcebergCompatFeatureOnExistingTable(String key)

defaultValueRequiresTableFeature

public static KernelException defaultValueRequiresTableFeature()

defaultValueRequireIcebergV3

public static KernelException defaultValueRequireIcebergV3()

unsupportedDataTypeForDefaultValue

public static KernelException unsupportedDataTypeForDefaultValue(String fieldName,
 String fieldType)

nonLiteralDefaultValue

public static KernelException nonLiteralDefaultValue(String value)

partitionColumnMissingInData

public static KernelException partitionColumnMissingInData(String tablePath,
 String partitionColumn)

enablingClusteringOnPartitionedTableNotAllowed

public static KernelException enablingClusteringOnPartitionedTableNotAllowed(String tablePath,
 Set<String> partitionColNames,
 List<Column> clusteringCols)

nonRetryableCommitException

public static RuntimeException nonRetryableCommitException(int attempt,
 long commitAsVersion,
 CommitFailedException cause)

concurrentTransaction

public static KernelException concurrentTransaction(String appId,
 long txnVersion,
 long lastUpdated)

metadataChangedException

public static KernelException metadataChangedException()

protocolChangedException

public static KernelException protocolChangedException(long attemptVersion)

voidTypeEncountered

public static KernelException voidTypeEncountered()

cannotModifyTableProperty

public static KernelException cannotModifyTableProperty(String key)

unknownConfigurationException

public static KernelException unknownConfigurationException(String confKey)

invalidConfigurationValueException

public static KernelException invalidConfigurationValueException(String key,
 String value,
 String helpMessage)

domainMetadataUnsupported

public static KernelException domainMetadataUnsupported()

concurrentDomainMetadataAction

public static ConcurrentWriteException concurrentDomainMetadataAction(DomainMetadata domainMetadataAttempt,
 DomainMetadata winningDomainMetadata)

missingNumRecordsStatsForRowTracking

public static KernelException missingNumRecordsStatsForRowTracking()

rowTrackingSupportedWithDomainMetadataUnsupported

public static KernelException rowTrackingSupportedWithDomainMetadataUnsupported()

rowTrackingRequiredForRowIdHighWatermark

public static KernelException rowTrackingRequiredForRowIdHighWatermark(String tablePath,
 String rowIdHighWatermark)

cannotToggleRowTrackingOnExistingTable

public static KernelException cannotToggleRowTrackingOnExistingTable()

missingRowTrackingColumnRequested

public static KernelException missingRowTrackingColumnRequested(String columnName)

cannotModifyAppendOnlyTable

public static KernelException cannotModifyAppendOnlyTable(String tablePath)

cdfMixedAddRemoveNotSupported

public static KernelException cdfMixedAddRemoveNotSupported(String tablePath)

rowTrackingMetadataMissingInFile

public static KernelException rowTrackingMetadataMissingInFile(String entry,
 String filePath)

tableWithIctMissingCommitInfo

public static InvalidTableException tableWithIctMissingCommitInfo(String dataPath,
 long version)

tableWithIctMissingIct

public static InvalidTableException tableWithIctMissingIct(String dataPath,
 long version)

metadataMissingRequiredCatalogTableProperty

public static KernelException metadataMissingRequiredCatalogTableProperty(String committerClassName,
 Map<String,String> missingOrViolatingProperties,
 Map<String,String> requiredCatalogTableProperties)

invalidFieldMove

public static KernelException invalidFieldMove(int columnId,
 Optional<SchemaIterable.ParentStructFieldInfo> currentParent,
 Optional<SchemaIterable.ParentStructFieldInfo> newParent)

wrapEngineException

public static <T> T wrapEngineException(Supplier<T> f,
 String msgString,
 Object... args)

wrapEngineExceptionThrowsIO

public static <T> T wrapEngineExceptionThrowsIO(DeltaErrors.SupplierWithIOException<T> f,
 String msgString,
 Object... args)
                                         throws IOException

Throws:

IOException