public class org.apache.drill.metastore.iceberg.operate.IcebergModify extends org.apache.drill.metastore.operate.AbstractModify
{
private final org.apache.drill.metastore.iceberg.transform.OperationTransformer transformer;
private final org.apache.drill.metastore.iceberg.IcebergMetastoreContext context;
private final java.util.List operations;
public void <init>(org.apache.drill.metastore.operate.MetadataTypeValidator, org.apache.drill.metastore.iceberg.IcebergMetastoreContext)
{
org.apache.drill.metastore.iceberg.transform.Transformer v;
org.apache.drill.metastore.operate.MetadataTypeValidator v;
org.apache.drill.metastore.iceberg.transform.OperationTransformer v;
org.apache.drill.metastore.iceberg.operate.IcebergModify v;
org.apache.drill.metastore.iceberg.IcebergMetastoreContext v;
java.util.ArrayList v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergModify;
v := @parameter: org.apache.drill.metastore.operate.MetadataTypeValidator;
v := @parameter: org.apache.drill.metastore.iceberg.IcebergMetastoreContext;
specialinvoke v.<org.apache.drill.metastore.operate.AbstractModify: void <init>(org.apache.drill.metastore.operate.MetadataTypeValidator)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: java.util.List operations> = v;
v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: org.apache.drill.metastore.iceberg.IcebergMetastoreContext context> = v;
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.IcebergMetastoreContext: org.apache.drill.metastore.iceberg.transform.Transformer transformer()>();
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.transform.Transformer: org.apache.drill.metastore.iceberg.transform.OperationTransformer operation()>();
v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: org.apache.drill.metastore.iceberg.transform.OperationTransformer transformer> = v;
return;
}
public void execute()
{
java.util.List v, v;
org.apache.drill.metastore.iceberg.operate.IcebergModify v;
boolean v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergModify;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: java.util.List operations>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
return;
label:
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: java.util.List operations>;
specialinvoke v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: void executeOperations(java.util.List)>(v);
return;
}
public void purge()
{
java.util.List v;
org.apache.drill.metastore.iceberg.transform.OperationTransformer v;
org.apache.drill.metastore.iceberg.operate.Delete v;
org.apache.drill.metastore.expressions.FilterExpression v;
org.apache.drill.metastore.iceberg.operate.IcebergModify v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergModify;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: org.apache.drill.metastore.iceberg.transform.OperationTransformer transformer>;
v = null;
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.OperationTransformer: org.apache.drill.metastore.iceberg.operate.Delete toDelete(org.apache.drill.metastore.expressions.FilterExpression)>(v);
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
specialinvoke v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: void executeOperations(java.util.List)>(v);
return;
}
protected void addOverwrite(java.util.List)
{
java.util.List v, v, v;
org.apache.drill.metastore.iceberg.transform.OperationTransformer v;
org.apache.drill.metastore.iceberg.operate.IcebergModify v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergModify;
v := @parameter: java.util.List;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: java.util.List operations>;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: org.apache.drill.metastore.iceberg.transform.OperationTransformer transformer>;
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.OperationTransformer: java.util.List toOverwrite(java.util.List)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
return;
}
protected void addDelete(org.apache.drill.metastore.operate.Delete)
{
java.util.List v;
org.apache.drill.metastore.operate.Delete v;
org.apache.drill.metastore.iceberg.transform.OperationTransformer v;
org.apache.drill.metastore.iceberg.operate.Delete v;
org.apache.drill.metastore.iceberg.operate.IcebergModify v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergModify;
v := @parameter: org.apache.drill.metastore.operate.Delete;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: java.util.List operations>;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: org.apache.drill.metastore.iceberg.transform.OperationTransformer transformer>;
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.OperationTransformer: org.apache.drill.metastore.iceberg.operate.Delete toDelete(org.apache.drill.metastore.operate.Delete)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
private void executeOperations(java.util.List)
{
org.apache.iceberg.Table v;
org.apache.drill.metastore.iceberg.IcebergMetastoreContext v, v;
org.apache.drill.metastore.iceberg.operate.ExpirationHandler v;
java.util.function.Consumer v;
java.util.List v;
org.apache.iceberg.Transaction v;
org.apache.drill.metastore.iceberg.operate.IcebergModify v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergModify;
v := @parameter: java.util.List;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: org.apache.drill.metastore.iceberg.IcebergMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.IcebergMetastoreContext: org.apache.iceberg.Table table()>();
v = interfaceinvoke v.<org.apache.iceberg.Table: org.apache.iceberg.Transaction newTransaction()>();
v = staticinvoke <org.apache.drill.metastore.iceberg.operate.IcebergModify$lambda_executeOperations_0__15: java.util.function.Consumer bootstrap$(org.apache.iceberg.Transaction)>(v);
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
interfaceinvoke v.<org.apache.iceberg.Transaction: void commitTransaction()>();
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergModify: org.apache.drill.metastore.iceberg.IcebergMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.IcebergMetastoreContext: org.apache.drill.metastore.iceberg.operate.ExpirationHandler expirationHandler()>();
virtualinvoke v.<org.apache.drill.metastore.iceberg.operate.ExpirationHandler: void expireQuietly()>();
return;
}
}