Package org.apache.iceberg.flink.sink.dynamic

Class PartitionSpecEvolution

java.lang.Object

org.apache.iceberg.flink.sink.dynamic.PartitionSpecEvolution

public class PartitionSpecEvolution
extends Object

Checks compatibility of PartitionSpecs and evolves one into the other.

Method Summary

Modifier and Type	Method	Description
static boolean	checkCompatibility(PartitionSpec spec1, PartitionSpec spec2)	Checks whether two PartitionSpecs are compatible with each other.

Methods inherited from class java.lang.Object

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

Method Details

checkCompatibility

public static boolean checkCompatibility(PartitionSpec spec1,
 PartitionSpec spec2)

Checks whether two PartitionSpecs are compatible with each other. Less strict than PartitionSpec#compatible in the sense that it tolerates differently named partition fields, as long as their transforms and field names corresponding to their source ids match.