public class org.apache.drill.metastore.iceberg.operate.Overwrite extends java.lang.Object implements org.apache.drill.metastore.iceberg.operate.IcebergOperation
{
private final org.apache.iceberg.expressions.Expression filter;
private final org.apache.iceberg.DataFile dataFile;
public void <init>(org.apache.iceberg.DataFile, org.apache.iceberg.expressions.Expression)
{
org.apache.drill.metastore.iceberg.operate.Overwrite v;
org.apache.iceberg.expressions.Expression v;
org.apache.iceberg.DataFile v;
v := @this: org.apache.drill.metastore.iceberg.operate.Overwrite;
v := @parameter: org.apache.iceberg.DataFile;
v := @parameter: org.apache.iceberg.expressions.Expression;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.drill.metastore.iceberg.operate.Overwrite: org.apache.iceberg.DataFile dataFile> = v;
v.<org.apache.drill.metastore.iceberg.operate.Overwrite: org.apache.iceberg.expressions.Expression filter> = v;
return;
}
public org.apache.iceberg.expressions.Expression filter()
{
org.apache.drill.metastore.iceberg.operate.Overwrite v;
org.apache.iceberg.expressions.Expression v;
v := @this: org.apache.drill.metastore.iceberg.operate.Overwrite;
v = v.<org.apache.drill.metastore.iceberg.operate.Overwrite: org.apache.iceberg.expressions.Expression filter>;
return v;
}
public org.apache.iceberg.DataFile dataFile()
{
org.apache.drill.metastore.iceberg.operate.Overwrite v;
org.apache.iceberg.DataFile v;
v := @this: org.apache.drill.metastore.iceberg.operate.Overwrite;
v = v.<org.apache.drill.metastore.iceberg.operate.Overwrite: org.apache.iceberg.DataFile dataFile>;
return v;
}
public void add(org.apache.iceberg.Transaction)
{
org.apache.drill.metastore.iceberg.operate.Overwrite v;
org.apache.iceberg.expressions.Expression v;
org.apache.iceberg.Transaction v;
org.apache.iceberg.DataFile v;
org.apache.iceberg.OverwriteFiles v, v, v, v;
v := @this: org.apache.drill.metastore.iceberg.operate.Overwrite;
v := @parameter: org.apache.iceberg.Transaction;
v = interfaceinvoke v.<org.apache.iceberg.Transaction: org.apache.iceberg.OverwriteFiles newOverwrite()>();
v = v.<org.apache.drill.metastore.iceberg.operate.Overwrite: org.apache.iceberg.expressions.Expression filter>;
v = interfaceinvoke v.<org.apache.iceberg.OverwriteFiles: org.apache.iceberg.OverwriteFiles overwriteByRowFilter(org.apache.iceberg.expressions.Expression)>(v);
v = v.<org.apache.drill.metastore.iceberg.operate.Overwrite: org.apache.iceberg.DataFile dataFile>;
v = interfaceinvoke v.<org.apache.iceberg.OverwriteFiles: org.apache.iceberg.OverwriteFiles addFile(org.apache.iceberg.DataFile)>(v);
v = interfaceinvoke v.<org.apache.iceberg.OverwriteFiles: org.apache.iceberg.OverwriteFiles validateAddedFilesMatchOverwriteFilter()>();
interfaceinvoke v.<org.apache.iceberg.OverwriteFiles: void commit()>();
return;
}
}