DeltaErrorsInternal

io.delta.kernel.internal.DeltaErrorsInternal

public class DeltaErrorsInternal extends Object

Contains methods to create developer-facing exceptions. See Exception Principles for more information on what these are and how to use them.

Method Summary

Modifier and Type

Method

Description

static InvalidTableException

catalogCommitsPrecedePublishedDeltas(String tablePath, long earliestCatalogCommitVersion, List<Long> foundPublishedVersions)

static UnsupportedOperationException

defaultCommitterDoesNotSupportCatalogManagedTables()

static IllegalArgumentException

invalidLatestSnapshotForMaxCatalogVersion(long latestSnapshotVersion, long maxCatalogVersion)

static IllegalStateException

invalidTimestampFormatForPartitionValue(String partitionValue)

static IllegalStateException

logicalPhysicalSchemaMismatch(int num_partition_cols, int physical_size, int logical_size)

static IllegalStateException

missingRemoveFileSizeDuringCommit()

static InvalidTableException

publishedDeltasAndCatalogCommitsNotContiguous(String tablePath, List<Long> publishedDeltaVersions, List<Long> catalogCommitVersions)

static InvalidTableException

publishedDeltasNotContiguous(String tablePath, List<Long> foundVersions)

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- missingRemoveFileSizeDuringCommit
  
  public static IllegalStateException missingRemoveFileSizeDuringCommit()
- invalidTimestampFormatForPartitionValue
  
  public static IllegalStateException invalidTimestampFormatForPartitionValue(String partitionValue)
- defaultCommitterDoesNotSupportCatalogManagedTables
  
  public static UnsupportedOperationException defaultCommitterDoesNotSupportCatalogManagedTables()
- logicalPhysicalSchemaMismatch
  
  public static IllegalStateException logicalPhysicalSchemaMismatch(int num_partition_cols, int physical_size, int logical_size)
- catalogCommitsPrecedePublishedDeltas
  
  public static InvalidTableException catalogCommitsPrecedePublishedDeltas(String tablePath, long earliestCatalogCommitVersion, List<Long> foundPublishedVersions)
- publishedDeltasAndCatalogCommitsNotContiguous
  
  public static InvalidTableException publishedDeltasAndCatalogCommitsNotContiguous(String tablePath, List<Long> publishedDeltaVersions, List<Long> catalogCommitVersions)
- publishedDeltasNotContiguous
  
  public static InvalidTableException publishedDeltasNotContiguous(String tablePath, List<Long> foundVersions)
- invalidLatestSnapshotForMaxCatalogVersion
  
  public static IllegalArgumentException invalidLatestSnapshotForMaxCatalogVersion(long latestSnapshotVersion, long maxCatalogVersion)