Package com.expediagroup.beekeeper.cleanup.validation

Class IcebergValidator

java.lang.Object

com.expediagroup.beekeeper.cleanup.validation.IcebergValidator

public class IcebergValidator
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
IcebergValidator(CleanerClientFactory cleanerClientFactory)

Method Summary

Modifier and Type	Method	Description
void	throwExceptionIfIceberg(java.lang.String databaseName, java.lang.String tableName)	Beekeeper currently does not support the Iceberg format.

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergValidator

public IcebergValidator(CleanerClientFactory cleanerClientFactory)

Method Detail

throwExceptionIfIceberg

public void throwExceptionIfIceberg(java.lang.String databaseName,
                                    java.lang.String tableName)

Beekeeper currently does not support the Iceberg format. Iceberg tables in the Hive Metastore do not store partition information, causing Beekeeper to attempt to clean up the entire table due to the missing information. This method checks if the table is an Iceberg table and throws a BeekeeperIcebergException to stop the process.

Parameters:

databaseName -

tableName -