org.apache.drill.metastore.iceberg.transform

Class OperationTransformer<T>

java.lang.Object

org.apache.drill.metastore.iceberg.transform.OperationTransformer<T>

Type Parameters:

T - Metastore component unit type

Direct Known Subclasses:

TablesOperationTransformer

public abstract class OperationTransformer<T>
extends Object

Base class to transforms given input into IcebergOperation implementations.

Field Summary

Fields

Modifier and Type	Field and Description
protected IcebergMetastoreContext<T>	context

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OperationTransformer(IcebergMetastoreContext<T> context)

Method Summary

Modifier and Type	Method and Description
Delete	toDelete(Delete delete)
Delete	toDelete(FilterExpression filter)
abstract List<Overwrite>	toOverwrite(List<T> units) Converts given list of Metastore components units into list of overwrite operations.
Overwrite	toOverwrite(String location, org.apache.iceberg.expressions.Expression expression, List<T> units)

Methods inherited from class java.lang.Object

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

Field Detail

context

protected final IcebergMetastoreContext<T> context

Constructor Detail

OperationTransformer

protected OperationTransformer(IcebergMetastoreContext<T> context)

Method Detail

toOverwrite

public Overwrite toOverwrite(String location,
                             org.apache.iceberg.expressions.Expression expression,
                             List<T> units)

toDelete

public Delete toDelete(FilterExpression filter)

toDelete

public Delete toDelete(Delete delete)

toOverwrite

public abstract List<Overwrite> toOverwrite(List<T> units)

Converts given list of Metastore components units into list of overwrite operations. Specific for each Metastore component.

Parameters:

units - Metastore component units

Returns:

list of overwrite operations