Package 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	Description
protected final IcebergMetastoreContext<T>	context

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

context

protected final IcebergMetastoreContext<T> context

Constructor Details

OperationTransformer

protected OperationTransformer(IcebergMetastoreContext<T> context)

Method Details

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