public class org.apache.parquet.hadoop.ParquetFileWriter extends java.lang.Object { private static final org.slf4j.Logger LOG; private final org.apache.parquet.format.converter.ParquetMetadataConverter metadataConverter; public static final java.lang.String PARQUET_METADATA_FILE; public static final java.lang.String MAGIC_STR; public static final byte[] MAGIC; public static final java.lang.String EF_MAGIC_STR; public static final byte[] EFMAGIC; public static final java.lang.String PARQUET_COMMON_METADATA_FILE; public static final int CURRENT_VERSION; protected final org.apache.parquet.io.PositionOutputStream out; private final org.apache.parquet.schema.MessageType schema; private final org.apache.parquet.hadoop.ParquetFileWriter$AlignmentStrategy alignment; private final int columnIndexTruncateLength; private java.util.List blocks; private final java.util.List columnIndexes; private final java.util.List offsetIndexes; private final java.util.List bloomFilters; private final org.apache.parquet.crypto.InternalFileEncryptor fileEncryptor; private org.apache.parquet.hadoop.metadata.BlockMetaData currentBlock; private java.util.List currentColumnIndexes; private java.util.List currentOffsetIndexes; private java.util.Map currentBloomFilters; private long currentRecordCount; private org.apache.parquet.column.EncodingStats$Builder encodingStatsBuilder; private java.util.Set currentEncodings; private long uncompressedLength; private long compressedLength; private org.apache.parquet.column.statistics.Statistics currentStatistics; private org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder columnIndexBuilder; private org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder offsetIndexBuilder; private org.apache.parquet.hadoop.metadata.CompressionCodecName currentChunkCodec; private org.apache.parquet.hadoop.metadata.ColumnPath currentChunkPath; private org.apache.parquet.schema.PrimitiveType currentChunkType; private long currentChunkValueCount; private long currentChunkFirstDataPage; private long currentChunkDictionaryPageOffset; private org.apache.parquet.hadoop.metadata.ParquetMetadata footer; private final java.util.zip.CRC32 crc; private boolean pageWriteChecksumEnabled; private org.apache.parquet.hadoop.ParquetFileWriter$STATE state; private static final java.lang.ThreadLocal COPY_BUFFER; public void (oadd.org.apache.hadoop.conf.Configuration, org.apache.parquet.schema.MessageType, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException { org.apache.parquet.schema.MessageType v; org.apache.parquet.hadoop.ParquetFileWriter$Mode v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.hadoop.util.HadoopOutputFile v; oadd.org.apache.hadoop.conf.Configuration v; oadd.org.apache.hadoop.fs.Path v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v := @parameter: org.apache.parquet.schema.MessageType; v := @parameter: oadd.org.apache.hadoop.fs.Path; v = staticinvoke (v, v); v = ; specialinvoke v.(org.apache.parquet.io.OutputFile,org.apache.parquet.schema.MessageType,org.apache.parquet.hadoop.ParquetFileWriter$Mode,long,int)>(v, v, v, 134217728L, 8388608); return; } public void (oadd.org.apache.hadoop.conf.Configuration, org.apache.parquet.schema.MessageType, oadd.org.apache.hadoop.fs.Path, org.apache.parquet.hadoop.ParquetFileWriter$Mode) throws java.io.IOException { org.apache.parquet.schema.MessageType v; org.apache.parquet.hadoop.ParquetFileWriter$Mode v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.hadoop.util.HadoopOutputFile v; oadd.org.apache.hadoop.conf.Configuration v; oadd.org.apache.hadoop.fs.Path v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v := @parameter: org.apache.parquet.schema.MessageType; v := @parameter: oadd.org.apache.hadoop.fs.Path; v := @parameter: org.apache.parquet.hadoop.ParquetFileWriter$Mode; v = staticinvoke (v, v); specialinvoke v.(org.apache.parquet.io.OutputFile,org.apache.parquet.schema.MessageType,org.apache.parquet.hadoop.ParquetFileWriter$Mode,long,int)>(v, v, v, 134217728L, 8388608); return; } public void (oadd.org.apache.hadoop.conf.Configuration, org.apache.parquet.schema.MessageType, oadd.org.apache.hadoop.fs.Path, org.apache.parquet.hadoop.ParquetFileWriter$Mode, long, int) throws java.io.IOException { org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.hadoop.util.HadoopOutputFile v; long v; org.apache.parquet.schema.MessageType v; org.apache.parquet.hadoop.ParquetFileWriter$Mode v; int v; oadd.org.apache.hadoop.conf.Configuration v; oadd.org.apache.hadoop.fs.Path v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v := @parameter: org.apache.parquet.schema.MessageType; v := @parameter: oadd.org.apache.hadoop.fs.Path; v := @parameter: org.apache.parquet.hadoop.ParquetFileWriter$Mode; v := @parameter: long; v := @parameter: int; v = staticinvoke (v, v); specialinvoke v.(org.apache.parquet.io.OutputFile,org.apache.parquet.schema.MessageType,org.apache.parquet.hadoop.ParquetFileWriter$Mode,long,int)>(v, v, v, v, v); return; } public void (org.apache.parquet.io.OutputFile, org.apache.parquet.schema.MessageType, org.apache.parquet.hadoop.ParquetFileWriter$Mode, long, int) throws java.io.IOException { org.apache.parquet.schema.MessageType v; org.apache.parquet.io.OutputFile v; org.apache.parquet.hadoop.ParquetFileWriter$Mode v; org.apache.parquet.hadoop.ParquetFileWriter v; int v; long v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.io.OutputFile; v := @parameter: org.apache.parquet.schema.MessageType; v := @parameter: org.apache.parquet.hadoop.ParquetFileWriter$Mode; v := @parameter: long; v := @parameter: int; specialinvoke v.(org.apache.parquet.io.OutputFile,org.apache.parquet.schema.MessageType,org.apache.parquet.hadoop.ParquetFileWriter$Mode,long,int,int,int,boolean)>(v, v, v, v, v, 64, 2147483647, 1); return; } public void (org.apache.parquet.io.OutputFile, org.apache.parquet.schema.MessageType, org.apache.parquet.hadoop.ParquetFileWriter$Mode, long, int, int, int, boolean) throws java.io.IOException { org.apache.parquet.hadoop.ParquetFileWriter v; long v; org.apache.parquet.schema.MessageType v; org.apache.parquet.io.OutputFile v; org.apache.parquet.hadoop.ParquetFileWriter$Mode v; int v, v, v; boolean v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.io.OutputFile; v := @parameter: org.apache.parquet.schema.MessageType; v := @parameter: org.apache.parquet.hadoop.ParquetFileWriter$Mode; v := @parameter: long; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: boolean; specialinvoke v.(org.apache.parquet.io.OutputFile,org.apache.parquet.schema.MessageType,org.apache.parquet.hadoop.ParquetFileWriter$Mode,long,int,int,int,boolean,org.apache.parquet.crypto.FileEncryptionProperties)>(v, v, v, v, v, v, v, v, null); return; } public void (org.apache.parquet.io.OutputFile, org.apache.parquet.schema.MessageType, org.apache.parquet.hadoop.ParquetFileWriter$Mode, long, int, int, int, boolean, org.apache.parquet.crypto.FileEncryptionProperties) throws java.io.IOException { org.apache.parquet.format.converter.ParquetMetadataConverter v; java.util.Map v; boolean v, v, v, v; org.apache.parquet.crypto.FileEncryptionProperties v; java.util.Set v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v; org.apache.parquet.schema.MessageType v; org.apache.parquet.io.OutputFile v; org.apache.parquet.hadoop.ParquetFileWriter$Mode v, v; org.apache.parquet.hadoop.ParquetFileWriter$PaddingAlignment v; org.apache.parquet.crypto.ParquetCryptoRuntimeException v; java.lang.String[] v; long v, v, v; java.util.ArrayList v, v, v, v; org.apache.parquet.crypto.InternalFileEncryptor v; int v, v, v; java.lang.String v, v; org.apache.parquet.column.EncodingStats$Builder v; org.apache.parquet.hadoop.ParquetFileWriter$NoAlignment v; java.util.Iterator v; org.apache.parquet.hadoop.ParquetFileWriter v; java.util.zip.CRC32 v, v; java.lang.Object v, v; org.apache.parquet.io.PositionOutputStream v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.io.OutputFile; v := @parameter: org.apache.parquet.schema.MessageType; v := @parameter: org.apache.parquet.hadoop.ParquetFileWriter$Mode; v := @parameter: long; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: boolean; v := @parameter: org.apache.parquet.crypto.FileEncryptionProperties; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = null; v = ; v. = v; staticinvoke (v); v. = v; v = v; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); v = staticinvoke (v, v, v); v. = v; goto label; label: v = staticinvoke (v); v. = v; label: v = ; if v != v goto label; v = interfaceinvoke v.(v); v. = v; goto label; label: v = interfaceinvoke v.(v); v. = v; label: v = new org.apache.parquet.column.EncodingStats$Builder; specialinvoke v.()>(); v. = v; v. = v; v. = v; if v == 0 goto label; v = new java.util.zip.CRC32; v = v; specialinvoke v.()>(); goto label; label: v = null; label: v. = v; v = new org.apache.parquet.format.converter.ParquetMetadataConverter; specialinvoke v.(int)>(v); v. = v; if null != v goto label; v. = null; goto label; label: v = virtualinvoke v.(); if null == v goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = new org.apache.parquet.crypto.ParquetCryptoRuntimeException; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Encrypted column \u not in file schema"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.parquet.crypto.InternalFileEncryptor; specialinvoke v.(org.apache.parquet.crypto.FileEncryptionProperties)>(v); v. = v; label: return; } void (oadd.org.apache.hadoop.conf.Configuration, org.apache.parquet.schema.MessageType, oadd.org.apache.hadoop.fs.Path, long, int) throws java.io.IOException { long v; org.apache.parquet.format.converter.ParquetMetadataConverter v; java.util.ArrayList v, v, v, v; short v; int v; oadd.org.apache.hadoop.conf.Configuration v; org.apache.parquet.column.EncodingStats$Builder v; boolean v, v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v; org.apache.parquet.schema.MessageType v; oadd.org.apache.hadoop.fs.FSDataOutputStream v; org.apache.parquet.hadoop.ParquetFileWriter$PaddingAlignment v; java.util.zip.CRC32 v; oadd.org.apache.hadoop.fs.Path v; oadd.org.apache.hadoop.fs.FileSystem v; org.apache.parquet.io.PositionOutputStream v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v := @parameter: org.apache.parquet.schema.MessageType; v := @parameter: oadd.org.apache.hadoop.fs.Path; v := @parameter: long; v := @parameter: int; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = null; v = ; v. = v; v = virtualinvoke v.(v); v. = v; v = staticinvoke (v, v, v); v. = v; v = virtualinvoke v.(v); v = virtualinvoke v.(v, 1, 8192, v, v); v = staticinvoke (v); v. = v; v = new org.apache.parquet.column.EncodingStats$Builder; specialinvoke v.()>(); v. = v; v. = 2147483647; v = staticinvoke (v); v. = v; v = v.; if v == 0 goto label; v = new java.util.zip.CRC32; specialinvoke v.()>(); goto label; label: v = null; label: v. = v; v = new org.apache.parquet.format.converter.ParquetMetadataConverter; specialinvoke v.(int)>(2147483647); v. = v; v. = null; return; } public void start() throws java.io.IOException { byte[] v; org.slf4j.Logger v; org.apache.parquet.hadoop.ParquetFileWriter v; long v; org.apache.parquet.crypto.InternalFileEncryptor v, v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; java.lang.Long v; org.apache.parquet.io.PositionOutputStream v, v; boolean v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v = v.; v = virtualinvoke v.(); v. = v; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{}: start", v); v = ; v = v.; if null == v goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = ; label: v = v.; virtualinvoke v.(v); return; } org.apache.parquet.crypto.InternalFileEncryptor getEncryptor() { org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.crypto.InternalFileEncryptor v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v = v.; return v; } public void startBlock(long) throws java.io.IOException { org.slf4j.Logger v; org.apache.parquet.hadoop.ParquetFileWriter v; java.util.HashMap v; long v, v; org.apache.parquet.hadoop.ParquetFileWriter$AlignmentStrategy v; java.util.ArrayList v, v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; java.lang.Long v; org.apache.parquet.hadoop.metadata.BlockMetaData v; org.apache.parquet.io.PositionOutputStream v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: long; v = v.; v = virtualinvoke v.(); v. = v; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{}: start block", v); v = v.; v = v.; interfaceinvoke v.(v); v = new org.apache.parquet.hadoop.metadata.BlockMetaData; specialinvoke v.()>(); v. = v; v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; return; } public void startColumn(org.apache.parquet.column.ColumnDescriptor, long, org.apache.parquet.hadoop.metadata.CompressionCodecName) throws java.io.IOException { org.apache.parquet.schema.PrimitiveType v, v; org.apache.parquet.hadoop.metadata.ColumnPath v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder v; java.lang.String[] v; long v; org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; java.util.HashSet v; org.apache.parquet.column.ColumnDescriptor v; int v; org.apache.parquet.hadoop.metadata.CompressionCodecName v; org.apache.parquet.column.EncodingStats$Builder v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.column.ColumnDescriptor; v := @parameter: long; v := @parameter: org.apache.parquet.hadoop.metadata.CompressionCodecName; v = v.; v = virtualinvoke v.(); v. = v; v = v.; virtualinvoke v.(); v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = virtualinvoke v.(); v. = v; v. = v; v. = v; v. = -1L; v. = 0L; v. = 0L; v. = null; v = v.; v = v.; v = staticinvoke (v, v); v. = v; v = staticinvoke (); v. = v; return; } public void writeDictionaryPage(org.apache.parquet.column.page.DictionaryPage) throws java.io.IOException { org.apache.parquet.column.page.DictionaryPage v; org.apache.parquet.hadoop.ParquetFileWriter v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.column.page.DictionaryPage; virtualinvoke v.(v, null, null); return; } public void writeDictionaryPage(org.apache.parquet.column.page.DictionaryPage, org.apache.parquet.format.BlockCipher$Encryptor, byte[]) throws java.io.IOException { byte[] v, v; org.apache.parquet.column.Encoding v, v, v, v; org.apache.parquet.format.converter.ParquetMetadataConverter v, v; java.lang.Integer v, v; java.lang.Long v, v; org.apache.parquet.bytes.BytesInput v, v, v; org.apache.parquet.format.BlockCipher$Encryptor v; boolean v; java.util.Set v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.parquet.column.page.DictionaryPage v; int v, v, v, v, v; org.apache.parquet.column.EncodingStats$Builder v; org.slf4j.Logger v, v; org.apache.parquet.hadoop.ParquetFileWriter v; java.util.zip.CRC32 v, v, v; org.apache.parquet.io.PositionOutputStream v, v, v, v, v, v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.column.page.DictionaryPage; v := @parameter: org.apache.parquet.format.BlockCipher$Encryptor; v := @parameter: byte[]; v = v.; v = virtualinvoke v.(); v. = v; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{}: write dictionary page: {} values", v, v); v = v.; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; if v == 0 goto label; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, v, v, v, v, v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, v, v, v, v, v); label: v = v.; v = virtualinvoke v.(); v = v.; v = v - v; v = v.; v = v + v; v = v + v; v. = v; v = v.; v = v + v; v = v + v; v. = v; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("{}: write dictionary page content {}", v, v); v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); return; } public void writeDataPage(int, int, org.apache.parquet.bytes.BytesInput, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding) throws java.io.IOException { org.apache.parquet.column.Encoding v, v, v; org.apache.parquet.format.converter.ParquetMetadataConverter v; java.lang.Integer v, v; byte v; java.lang.Long v, v; org.apache.parquet.bytes.BytesInput v; org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder v; java.util.Set v, v, v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; long v, v, v, v, v, v, v, v, v, v, v, v; org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder v; int v, v, v; org.apache.parquet.column.EncodingStats$Builder v; org.slf4j.Logger v, v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.io.PositionOutputStream v, v, v, v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v = v.; v = virtualinvoke v.(); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = v.; v = virtualinvoke v.(); v = ; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("{}: write data page: {} values", v, v); v = virtualinvoke v.(); v = v.; v = v.; virtualinvoke v.(v, v, v, v, v, v, v); v = v.; v = virtualinvoke v.(); v = v - v; v = v.; v = v + v; v = v + v; v. = v; v = v.; v = v + v; v = v + v; v. = v; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("{}: write data page content {}", v, v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; v = v cmp 0L; if v >= 0 goto label; v. = v; label: return; } public void writeDataPage(int, int, org.apache.parquet.bytes.BytesInput, org.apache.parquet.column.statistics.Statistics, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding) throws java.io.IOException { org.apache.parquet.column.Encoding v, v, v; org.apache.parquet.column.statistics.Statistics v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder v; org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder v; org.apache.parquet.bytes.BytesInput v; int v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: org.apache.parquet.column.statistics.Statistics; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; specialinvoke v.(v, v, v, v, v, v, v); return; } public void writeDataPage(int, int, org.apache.parquet.bytes.BytesInput, org.apache.parquet.column.statistics.Statistics, long, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding) throws java.io.IOException { org.apache.parquet.column.Encoding v, v, v; org.apache.parquet.column.statistics.Statistics v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder v; long v, v, v, v; org.apache.parquet.bytes.BytesInput v; int v, v; org.apache.parquet.io.PositionOutputStream v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: org.apache.parquet.column.statistics.Statistics; v := @parameter: long; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v = v.; v = virtualinvoke v.(); specialinvoke v.(v, v, v, v, v, v, v); v = v.; v = v.; v = virtualinvoke v.(); v = v - v; virtualinvoke v.(v, v); return; } private void innerWriteDataPage(int, int, org.apache.parquet.bytes.BytesInput, org.apache.parquet.column.statistics.Statistics, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding, org.apache.parquet.column.Encoding) throws java.io.IOException { byte[] v; org.apache.parquet.column.Encoding v, v, v; org.apache.parquet.format.converter.ParquetMetadataConverter v, v; java.lang.Integer v, v; byte v; java.lang.Long v, v; org.apache.parquet.bytes.BytesInput v; boolean v; java.util.Set v, v, v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; long v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder v; int v, v, v; org.apache.parquet.column.EncodingStats$Builder v; org.apache.parquet.column.statistics.Statistics v, v, v, v; org.slf4j.Logger v, v; org.apache.parquet.hadoop.ParquetFileWriter v; java.util.zip.CRC32 v, v, v; org.apache.parquet.io.PositionOutputStream v, v, v, v, v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: org.apache.parquet.column.statistics.Statistics; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.column.Encoding; v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); v = v.; v = v cmp 0L; if v >= 0 goto label; v. = v; label: v = ; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("{}: write data page: {} values", v, v); v = virtualinvoke v.(); v = v.; if v == 0 goto label; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, v, v, v, v, v, v); goto label; label: v = v.; v = v.; virtualinvoke v.(v, v, v, v, v, v, v); label: v = v.; v = virtualinvoke v.(); v = v - v; v = v.; v = v + v; v = v + v; v. = v; v = v.; v = v + v; v = v + v; v. = v; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("{}: write data page content {}", v, v); v = v.; virtualinvoke v.(v); v = v.; if v != null goto label; v = virtualinvoke v.(); v. = v; goto label; label: v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); return; } void addBloomFilter(java.lang.String, org.apache.parquet.column.values.bloomfilter.BloomFilter) { org.apache.parquet.column.values.bloomfilter.BloomFilter v; org.apache.parquet.hadoop.ParquetFileWriter v; java.util.Map v; java.lang.String v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: java.lang.String; v := @parameter: org.apache.parquet.column.values.bloomfilter.BloomFilter; v = v.; interfaceinvoke v.(v, v); return; } public void writeDataPageV2(int, int, int, org.apache.parquet.bytes.BytesInput, org.apache.parquet.bytes.BytesInput, org.apache.parquet.column.Encoding, org.apache.parquet.bytes.BytesInput, int, org.apache.parquet.column.statistics.Statistics) throws java.io.IOException { org.apache.parquet.column.Encoding v; org.apache.parquet.format.converter.ParquetMetadataConverter v; byte v; org.apache.parquet.bytes.BytesInput v, v, v, v; org.apache.parquet.bytes.BytesInput[] v; org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder v; java.util.Set v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder v; int v, v, v, v, v, v, v, v; org.apache.parquet.column.EncodingStats$Builder v; org.apache.parquet.column.statistics.Statistics v, v, v, v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.io.PositionOutputStream v, v, v, v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: org.apache.parquet.column.Encoding; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: int; v := @parameter: org.apache.parquet.column.statistics.Statistics; v = v.; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + v; v = virtualinvoke v.(); v = v + v; v = specialinvoke v.(v); v = virtualinvoke v.(); v = v + v; v = virtualinvoke v.(); v = v + v; v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; v = v cmp 0L; if v >= 0 goto label; v. = v; label: v = v.; v = v.; virtualinvoke v.(v, v, v, v, v, v, v, v, v); v = v.; v = virtualinvoke v.(); v = v - v; v = v.; v = v + v; v = v + v; v. = v; v = v.; v = v + v; v = v + v; v. = v; v = v.; if v != null goto label; v = virtualinvoke v.(); v. = v; goto label; label: v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; virtualinvoke v.(v); v = newarray (org.apache.parquet.bytes.BytesInput)[3]; v[0] = v; v[1] = v; v[2] = v; v = staticinvoke (v); v = v.; virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); v = v - v; virtualinvoke v.(v, v); return; } void writeColumnChunk(org.apache.parquet.column.ColumnDescriptor, long, org.apache.parquet.hadoop.metadata.CompressionCodecName, org.apache.parquet.column.page.DictionaryPage, org.apache.parquet.bytes.BytesInput, long, long, org.apache.parquet.column.statistics.Statistics, org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder, org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder, org.apache.parquet.column.values.bloomfilter.BloomFilter, java.util.Set, java.util.Set, java.util.List) throws java.io.IOException { org.apache.parquet.column.statistics.Statistics v; org.apache.parquet.hadoop.ParquetFileWriter v; org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder v; java.util.Set v, v; long v, v, v; org.apache.parquet.column.page.DictionaryPage v; org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder v; java.util.List v; org.apache.parquet.column.values.bloomfilter.BloomFilter v; org.apache.parquet.column.ColumnDescriptor v; org.apache.parquet.bytes.BytesInput v; org.apache.parquet.hadoop.metadata.CompressionCodecName v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.column.ColumnDescriptor; v := @parameter: long; v := @parameter: org.apache.parquet.hadoop.metadata.CompressionCodecName; v := @parameter: org.apache.parquet.column.page.DictionaryPage; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: long; v := @parameter: long; v := @parameter: org.apache.parquet.column.statistics.Statistics; v := @parameter: org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder; v := @parameter: org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder; v := @parameter: org.apache.parquet.column.values.bloomfilter.BloomFilter; v := @parameter: java.util.Set; v := @parameter: java.util.Set; v := @parameter: java.util.List; virtualinvoke v.(v, v, v, v, v, v, v, v, v, v, v, v, v, v, null, 0, 0, null); return; } void writeColumnChunk(org.apache.parquet.column.ColumnDescriptor, long, org.apache.parquet.hadoop.metadata.CompressionCodecName, org.apache.parquet.column.page.DictionaryPage, org.apache.parquet.bytes.BytesInput, long, long, org.apache.parquet.column.statistics.Statistics, org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder, org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder, org.apache.parquet.column.values.bloomfilter.BloomFilter, java.util.Set, java.util.Set, java.util.List, org.apache.parquet.format.BlockCipher$Encryptor, int, int, byte[]) throws java.io.IOException { byte[] v, v; org.apache.parquet.column.Encoding v; java.lang.Long v, v; java.util.Map v; org.apache.parquet.bytes.BytesInput v; org.apache.parquet.format.BlockCipher$Encryptor v; boolean v, v, v; org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder v; java.util.Set v, v, v, v, v; org.apache.parquet.hadoop.ParquetFileWriter$STATE v, v; java.util.List v; org.apache.parquet.crypto.ModuleCipherFactory$ModuleType v; org.apache.parquet.column.ColumnDescriptor v; org.apache.parquet.hadoop.metadata.CompressionCodecName v; java.lang.String[] v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.parquet.column.page.DictionaryPage v; org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder v; org.apache.parquet.column.values.bloomfilter.BloomFilter v; int v, v, v; java.lang.String v; org.apache.parquet.column.EncodingStats$Builder v, v; org.apache.parquet.column.statistics.Statistics v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.parquet.hadoop.ParquetFileWriter v; java.lang.Object v; org.apache.parquet.io.PositionOutputStream v, v, v, v; v := @this: org.apache.parquet.hadoop.ParquetFileWriter; v := @parameter: org.apache.parquet.column.ColumnDescriptor; v := @parameter: long; v := @parameter: org.apache.parquet.hadoop.metadata.CompressionCodecName; v := @parameter: org.apache.parquet.column.page.DictionaryPage; v := @parameter: org.apache.parquet.bytes.BytesInput; v := @parameter: long; v := @parameter: long; v := @parameter: org.apache.parquet.column.statistics.Statistics; v := @parameter: org.apache.parquet.internal.column.columnindex.ColumnIndexBuilder; v := @parameter: org.apache.parquet.internal.column.columnindex.OffsetIndexBuilder; v := @parameter: org.apache.parquet.column.values.bloomfilter.BloomFilter; v := @parameter: java.util.Set; v := @parameter: java.util.Set; v := @parameter: java.util.List; v := @parameter: org.apache.parquet.format.BlockCipher$Encryptor; v := @parameter: int; v := @parameter: int; v := @parameter: byte[]; virtualinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); v. = v; if v == null goto label; v = null; if null == v goto label; v = ; v = (int) -1; v = staticinvoke (v, v, v, v, v); label: virtualinvoke v.(v, v, v); label: if v == null goto label; v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; if v == v goto label; v = 1; label: if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (".", v); interfaceinvoke v.(v, v); label: v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{}: write data pages", v); v = virtualinvoke v.(); v = v - v; v = v.; v = v + v; v = v + v; v. = v; v = v.; v = v + v; v = v + v; v. = v; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{}: write data pages content", v); v = v.