object TypeWidening
- Alphabetic
- By Inheritance
- TypeWidening
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def assertTableReadable(conf: SQLConf, protocol: Protocol, metadata: Metadata): Unit
Asserts that the given table doesn't contain any unsupported type changes.
Asserts that the given table doesn't contain any unsupported type changes. This should never happen unless a non-compliant writer applied a type change that is not part of the feature specification.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def containsWideningTypeChanges(from: DataType, to: DataType): Boolean
Compares
fromandtoand returns whether the type was widened, or, for nested types, whether one of the nested fields was widened. - def ensureFeatureConsistentlyEnabled(protocol: Protocol, metadata: Metadata, otherProtocol: Protocol, otherMetadata: Metadata): Unit
Checks that the type widening table property wasn't disabled or enabled between the two given states, throws an errors if it was.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def isEnabled(protocol: Protocol, metadata: Metadata): Boolean
Returns whether Type Widening is enabled on this table version.
Returns whether Type Widening is enabled on this table version. Checks that Type Widening is supported, which is a pre-requisite for enabling Type Widening, throws an error if not. When Type Widening is enabled, the type of existing columns or fields can be widened using ALTER TABLE CHANGE COLUMN.
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isSupported(protocol: Protocol): Boolean
Returns whether the protocol version supports the Type Widening table feature.
- def isTypeChangeSupported(fromType: AtomicType, toType: AtomicType): Boolean
Returns whether the given type change is eligible for widening.
Returns whether the given type change is eligible for widening. This only checks atomic types. It is the responsibility of the caller to recurse into structs, maps and arrays.
- def isTypeChangeSupportedByIceberg(fromType: AtomicType, toType: AtomicType): Boolean
Returns whether the given type change is supported by Iceberg, and by extension can be read using Uniform.
Returns whether the given type change is supported by Iceberg, and by extension can be read using Uniform. See https://iceberg.apache.org/spec/#schema-evolution. Note that these are type promotions supported by Iceberg V1 & V2 (both support the same type promotions). Iceberg V3 will add support for date -> timestamp_ntz and void -> any but Uniform doesn't currently support Iceberg V3.
- def isTypeChangeSupportedForSchemaEvolution(fromType: AtomicType, toType: AtomicType, uniformIcebergCompatibleOnly: Boolean): Boolean
Returns whether the given type change can be applied during schema evolution.
Returns whether the given type change can be applied during schema evolution. Only a subset of supported type changes are considered for schema evolution.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)