public class org.apache.drill.metastore.iceberg.write.ParquetFileWriter extends java.lang.Object implements org.apache.drill.metastore.iceberg.write.FileWriter
{
private final org.apache.iceberg.Table table;
private final java.util.List records;
private java.lang.String location;
private java.lang.String name;
public void <init>(org.apache.iceberg.Table)
{
org.apache.drill.metastore.iceberg.write.ParquetFileWriter v;
org.apache.iceberg.Table v;
java.util.ArrayList v;
v := @this: org.apache.drill.metastore.iceberg.write.ParquetFileWriter;
v := @parameter: org.apache.iceberg.Table;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.util.List records> = v;
v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: org.apache.iceberg.Table table> = v;
return;
}
public org.apache.drill.metastore.iceberg.write.FileWriter records(java.util.List)
{
org.apache.drill.metastore.iceberg.write.ParquetFileWriter v;
java.util.List v, v;
v := @this: org.apache.drill.metastore.iceberg.write.ParquetFileWriter;
v := @parameter: java.util.List;
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.util.List records>;
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
return v;
}
public org.apache.drill.metastore.iceberg.write.FileWriter location(java.lang.String)
{
org.apache.drill.metastore.iceberg.write.ParquetFileWriter v;
java.lang.String v;
v := @this: org.apache.drill.metastore.iceberg.write.ParquetFileWriter;
v := @parameter: java.lang.String;
v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.lang.String location> = v;
return v;
}
public org.apache.drill.metastore.iceberg.write.FileWriter name(java.lang.String)
{
org.apache.drill.metastore.iceberg.write.ParquetFileWriter v;
java.lang.String v;
v := @this: org.apache.drill.metastore.iceberg.write.ParquetFileWriter;
v := @parameter: java.lang.String;
v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.lang.String name> = v;
return v;
}
public org.apache.drill.metastore.iceberg.write.File write()
{
java.lang.Throwable v;
java.lang.Object[] v;
org.apache.iceberg.parquet.Parquet$WriteBuilder v, v, v;
org.apache.iceberg.Metrics v;
org.apache.iceberg.io.OutputFile v;
java.util.function.Function v;
org.apache.drill.metastore.iceberg.exceptions.IcebergMetastoreException v;
org.apache.hadoop.fs.Path v;
java.lang.String v, v, v, v, v, v, v, v;
java.net.URI v;
org.apache.iceberg.io.FileAppender v;
org.apache.iceberg.Table v, v;
org.apache.drill.metastore.iceberg.write.ParquetFileWriter v;
org.apache.iceberg.FileFormat v;
org.apache.drill.metastore.iceberg.write.File v;
java.util.List v;
org.apache.iceberg.io.FileIO v;
v := @this: org.apache.drill.metastore.iceberg.write.ParquetFileWriter;
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.lang.String location>;
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "File create location must be specified");
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.lang.String name>;
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "File name must be specified");
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: org.apache.iceberg.Table table>;
v = interfaceinvoke v.<org.apache.iceberg.Table: org.apache.iceberg.io.FileIO io()>();
v = new org.apache.hadoop.fs.Path;
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.lang.String location>;
v = <org.apache.iceberg.FileFormat: org.apache.iceberg.FileFormat PARQUET>;
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.lang.String name>;
v = virtualinvoke v.<org.apache.iceberg.FileFormat: java.lang.String addExtension(java.lang.String)>(v);
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = interfaceinvoke v.<org.apache.iceberg.io.FileIO: org.apache.iceberg.io.OutputFile newOutputFile(java.lang.String)>(v);
label:
v = staticinvoke <org.apache.iceberg.parquet.Parquet: org.apache.iceberg.parquet.Parquet$WriteBuilder write(org.apache.iceberg.io.OutputFile)>(v);
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: org.apache.iceberg.Table table>;
v = virtualinvoke v.<org.apache.iceberg.parquet.Parquet$WriteBuilder: org.apache.iceberg.parquet.Parquet$WriteBuilder forTable(org.apache.iceberg.Table)>(v);
v = staticinvoke <org.apache.drill.metastore.iceberg.write.ParquetFileWriter$buildWriter__30: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<org.apache.iceberg.parquet.Parquet$WriteBuilder: org.apache.iceberg.parquet.Parquet$WriteBuilder createWriterFunc(java.util.function.Function)>(v);
v = virtualinvoke v.<org.apache.iceberg.parquet.Parquet$WriteBuilder: org.apache.iceberg.io.FileAppender build()>();
v = v.<org.apache.drill.metastore.iceberg.write.ParquetFileWriter: java.util.List records>;
interfaceinvoke v.<org.apache.iceberg.io.FileAppender: void addAll(java.lang.Iterable)>(v);
interfaceinvoke v.<org.apache.iceberg.io.FileAppender: void close()>();
v = new org.apache.drill.metastore.iceberg.write.File;
v = interfaceinvoke v.<org.apache.iceberg.io.FileAppender: org.apache.iceberg.Metrics metrics()>();
specialinvoke v.<org.apache.drill.metastore.iceberg.write.File: void <init>(org.apache.iceberg.io.OutputFile,org.apache.iceberg.Metrics)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.drill.metastore.iceberg.exceptions.IcebergMetastoreException;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.iceberg.io.OutputFile: java.lang.String location()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to write data into parquet file [%s]", v);
specialinvoke v.<org.apache.drill.metastore.iceberg.exceptions.IcebergMetastoreException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.io.IOException from label to label with label;
catch java.lang.ClassCastException from label to label with label;
catch org.apache.iceberg.exceptions.RuntimeIOException from label to label with label;
}
}