public class org.apache.drill.exec.store.hdf.HDF5BatchReader extends java.lang.Object implements org.apache.drill.exec.physical.impl.scan.framework.ManagedReader { private static final org.slf4j.Logger logger; private static final java.lang.String PATH_COLUMN_NAME; private static final java.lang.String DATA_TYPE_COLUMN_NAME; private static final java.lang.String IS_LINK_COLUMN_NAME; private static final java.lang.String FILE_NAME_COLUMN_NAME; private static final java.lang.String INT_COLUMN_PREFIX; private static final java.lang.String LONG_COLUMN_PREFIX; private static final java.lang.String FLOAT_COLUMN_PREFIX; private static final java.lang.String DOUBLE_COLUMN_PREFIX; private static final java.lang.String INT_COLUMN_NAME; private static final java.lang.String FLOAT_COLUMN_NAME; private static final java.lang.String DOUBLE_COLUMN_NAME; private static final java.lang.String LONG_COLUMN_NAME; private static final java.lang.String DATA_SIZE_COLUMN_NAME; private static final java.lang.String ELEMENT_COUNT_NAME; private static final java.lang.String DATASET_DATA_TYPE_NAME; private static final java.lang.String DIMENSIONS_FIELD_NAME; private static final int PREVIEW_ROW_LIMIT; private static final int PREVIEW_COL_LIMIT; private static final int MAX_DATASET_SIZE; private final org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig readerConfig; private final java.util.List dataWriters; private final int maxRecords; private java.lang.String fileName; private org.apache.hadoop.mapred.FileSplit split; private io.jhdf.HdfFile hdfFile; private java.io.BufferedReader reader; private org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter; private org.apache.drill.exec.store.hdf.writers.WriterSpec writerSpec; private java.util.Iterator metadataIterator; private org.apache.drill.exec.vector.accessor.ScalarWriter pathWriter; private org.apache.drill.exec.vector.accessor.ScalarWriter dataTypeWriter; private org.apache.drill.exec.vector.accessor.ScalarWriter fileNameWriter; private org.apache.drill.exec.vector.accessor.ScalarWriter linkWriter; private org.apache.drill.exec.vector.accessor.ScalarWriter dataSizeWriter; private org.apache.drill.exec.vector.accessor.ScalarWriter elementCountWriter; private org.apache.drill.exec.vector.accessor.ScalarWriter datasetTypeWriter; private org.apache.drill.exec.vector.accessor.ScalarWriter dimensionsWriter; private org.apache.drill.common.exceptions.CustomErrorContext errorContext; private boolean showMetadataPreview; private int[] dimensions; static final boolean $assertionsDisabled; public void (org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig, int) { org.apache.drill.exec.store.hdf.HDF5BatchReader v; int v; org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig v; org.apache.drill.exec.store.hdf.HDF5FormatConfig v; boolean v; java.util.ArrayList v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig; v := @parameter: int; specialinvoke v.()>(); v. = v; v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = v.; v = virtualinvoke v.(); v. = v; return; } public boolean open(org.apache.drill.exec.physical.impl.scan.file.FileScanFramework$FileSchemaNegotiator) { org.apache.drill.common.exceptions.UserException v; org.apache.drill.exec.record.metadata.SchemaBuilder v, v, v, v, v, v, v, v, v; org.apache.hadoop.mapred.FileSplit v, v, v; io.jhdf.api.Dataset v; io.jhdf.HdfFile v, v; java.lang.Object[] v; org.apache.drill.common.exceptions.UserException$Builder v, v, v; java.util.ArrayList v; org.apache.drill.exec.vector.accessor.ScalarWriter v, v, v, v, v, v, v, v; java.lang.String v, v, v, v; java.io.IOException v; org.apache.drill.exec.store.hdf.writers.WriterSpec v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v; int[] v, v, v, v; org.apache.hadoop.fs.Path v, v; org.apache.drill.exec.record.metadata.TupleMetadata v, v; org.apache.drill.exec.physical.impl.scan.file.FileScanFramework$FileSchemaNegotiator v; java.util.List v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig v, v, v; org.apache.drill.common.exceptions.CustomErrorContext v, v, v; org.apache.drill.exec.physical.resultSet.RowSetLoader v, v, v, v, v, v, v, v, v, v, v; int v, v; org.slf4j.Logger v; java.util.Iterator v; org.apache.drill.exec.physical.resultSet.ResultSetLoader v, v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: org.apache.drill.exec.physical.impl.scan.file.FileScanFramework$FileSchemaNegotiator; v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v. = v; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = staticinvoke (v); v = newarray (java.lang.Object)[1]; v = v.; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.("Failed to close input file: %s", v); v = v.; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); throw v; label: v = v.; v = v.; if v != null goto label; v = v.; v = new java.util.ArrayList; specialinvoke v.()>(); v = specialinvoke v.(v, v); v = interfaceinvoke v.(); v. = v; v = new org.apache.drill.exec.record.metadata.SchemaBuilder; specialinvoke v.()>(); v = ; v = virtualinvoke v.("path", v); v = ; v = virtualinvoke v.("data_type", v); v = ; v = virtualinvoke v.("file_name", v); v = ; v = virtualinvoke v.("data_size", v); v = ; v = virtualinvoke v.("is_link", v); v = ; v = virtualinvoke v.("element_count", v); v = ; v = virtualinvoke v.("dataset_data_type", v); v = ; v = virtualinvoke v.("dimensions", v); v = virtualinvoke v.(); interfaceinvoke v.(v, 0); v = interfaceinvoke v.(); v = newarray (int)[0]; v. = v; v = interfaceinvoke v.(); v. = v; goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v. = v; v = new org.apache.drill.exec.store.hdf.writers.WriterSpec; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(org.apache.drill.exec.vector.accessor.TupleWriter,org.apache.drill.exec.record.metadata.TupleMetadata,org.apache.drill.common.exceptions.CustomErrorContext)>(v, v, v); v. = v; v = v.; v = lengthof v; if v > 1 goto label; specialinvoke v.(v); goto label; label: v = v.; v = lengthof v; if v != 2 goto label; specialinvoke v.(v); goto label; label: specialinvoke v.(v); label: v = v.; v = v.; if v != null goto label; v = v.; v = interfaceinvoke v.("path"); v. = v; v = v.; v = interfaceinvoke v.("data_type"); v. = v; v = v.; v = interfaceinvoke v.("file_name"); v. = v; v = v.; v = interfaceinvoke v.("data_size"); v. = v; v = v.; v = interfaceinvoke v.("is_link"); v. = v; v = v.; v = interfaceinvoke v.("element_count"); v. = v; v = v.; v = interfaceinvoke v.("dataset_data_type"); v. = v; v = v.; v = interfaceinvoke v.("dimensions"); v. = v; label: return 1; catch java.io.IOException from label to label with label; } private void buildSchemaFor1DimensionalDataset(io.jhdf.api.Dataset) { org.slf4j.Logger v; io.jhdf.object.datatype.DataType v; org.apache.drill.common.types.TypeProtos$MinorType v; java.util.List v; org.apache.drill.exec.store.hdf.writers.HDF5DataWriter v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; io.jhdf.api.Dataset v; java.lang.Class v; java.lang.String v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: io.jhdf.api.Dataset; v = interfaceinvoke v.(); v = staticinvoke (v); if v != null goto label; v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("Couldn\'t add {}", v); return; label: v = v.; v = specialinvoke v.(v); interfaceinvoke v.(v); return; } private org.apache.drill.exec.store.hdf.writers.HDF5DataWriter buildWriter(org.apache.drill.common.types.TypeProtos$MinorType) { org.apache.drill.exec.store.hdf.writers.HDF5MapDataWriter v; org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.store.hdf.writers.HDF5FloatDataWriter v; int[] v; org.apache.drill.exec.store.hdf.writers.HDF5LongDataWriter v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; io.jhdf.HdfFile v, v, v, v, v, v, v; org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig v, v, v, v, v, v, v; org.apache.drill.exec.store.hdf.writers.HDF5StringDataWriter v; org.apache.drill.exec.store.hdf.writers.HDF5IntDataWriter v; int v, v; java.lang.String v, v, v, v, v, v, v, v; java.lang.UnsupportedOperationException v; org.apache.drill.exec.store.hdf.writers.HDF5TimestampDataWriter v; org.apache.drill.exec.store.hdf.writers.WriterSpec v, v, v, v, v, v, v; org.apache.drill.exec.store.hdf.writers.HDF5DoubleDataWriter v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: org.apache.drill.common.types.TypeProtos$MinorType; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; default: goto label; }; label: v = new org.apache.drill.exec.store.hdf.writers.HDF5StringDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String)>(v, v, v); return v; label: v = new org.apache.drill.exec.store.hdf.writers.HDF5TimestampDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String)>(v, v, v); return v; label: v = new org.apache.drill.exec.store.hdf.writers.HDF5IntDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String)>(v, v, v); return v; label: v = new org.apache.drill.exec.store.hdf.writers.HDF5LongDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String)>(v, v, v); return v; label: v = new org.apache.drill.exec.store.hdf.writers.HDF5DoubleDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String)>(v, v, v); return v; label: v = new org.apache.drill.exec.store.hdf.writers.HDF5FloatDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String)>(v, v, v); return v; label: v = new org.apache.drill.exec.store.hdf.writers.HDF5MapDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String)>(v, v, v); return v; label: v = new java.lang.UnsupportedOperationException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw v; } private void buildSchemaFor2DimensionalDataset(io.jhdf.api.Dataset) { org.apache.drill.common.types.TypeProtos$MinorType v; org.apache.drill.exec.store.hdf.writers.HDF5FloatDataWriter v; byte v; int[] v, v; io.jhdf.api.Dataset v; java.util.List v, v, v, v; org.apache.drill.exec.store.hdf.writers.HDF5LongDataWriter v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; io.jhdf.HdfFile v, v, v, v; org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig v, v, v, v; org.apache.drill.exec.store.hdf.writers.HDF5IntDataWriter v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.lang.UnsupportedOperationException v; org.slf4j.Logger v; io.jhdf.object.datatype.DataType v; org.apache.drill.exec.store.hdf.writers.WriterSpec v, v, v, v; java.lang.Class v; org.apache.drill.exec.store.hdf.writers.HDF5DoubleDataWriter v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: io.jhdf.api.Dataset; v = interfaceinvoke v.(); v = staticinvoke (v); if v != null goto label; v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("Couldn\'t add {}", v); return; label: v = v.; v = v[1]; v = 0; label: v = v cmp v; if v >= 0 goto label; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; default: goto label; }; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("int_col_\u0001"); v = v.; v = new org.apache.drill.exec.store.hdf.writers.HDF5IntDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String,java.lang.String,int)>(v, v, v, v, v); interfaceinvoke v.(v); goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("long_col_\u0001"); v = v.; v = new org.apache.drill.exec.store.hdf.writers.HDF5LongDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String,java.lang.String,int)>(v, v, v, v, v); interfaceinvoke v.(v); goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("double_col_\u0001"); v = v.; v = new org.apache.drill.exec.store.hdf.writers.HDF5DoubleDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String,java.lang.String,int)>(v, v, v, v, v); interfaceinvoke v.(v); goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("float_col_\u0001"); v = v.; v = new org.apache.drill.exec.store.hdf.writers.HDF5FloatDataWriter; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(io.jhdf.HdfFile,org.apache.drill.exec.store.hdf.writers.WriterSpec,java.lang.String,java.lang.String,int)>(v, v, v, v, v); interfaceinvoke v.(v); goto label; label: v = new java.lang.UnsupportedOperationException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v + 1; goto label; label: return; } private void openFile(org.apache.drill.exec.physical.impl.scan.file.FileScanFramework$FileSchemaNegotiator) throws java.io.IOException { java.lang.Object[] v; org.apache.drill.common.exceptions.CustomErrorContext v; org.apache.drill.common.exceptions.UserException$Builder v, v, v; org.apache.drill.common.exceptions.UserException v; org.apache.drill.exec.store.dfs.DrillFileSystem v; org.apache.hadoop.mapred.FileSplit v, v; org.apache.hadoop.fs.Path v, v; org.slf4j.Logger v; java.io.InputStreamReader v; java.lang.Exception v; org.apache.drill.exec.physical.impl.scan.file.FileScanFramework$FileSchemaNegotiator v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; io.jhdf.HdfFile v; java.io.BufferedReader v; java.io.InputStream v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: org.apache.drill.exec.physical.impl.scan.file.FileScanFramework$FileSchemaNegotiator; v = null; label: v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (v); v. = v; label: goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: v = staticinvoke (v); v = newarray (java.lang.Object)[1]; v = v.; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.("Failed to open input file: %s", v); v = v.; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); throw v; label: v = new java.io.BufferedReader; v = new java.io.InputStreamReader; specialinvoke v.(java.io.InputStream)>(v); specialinvoke v.(java.io.Reader)>(v); v. = v; return; catch java.lang.Exception from label to label with label; } public boolean next() { int[] v, v, v, v; boolean v, v, v, v, v, v, v; java.util.List v, v, v, v, v, v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; org.apache.drill.exec.store.hdf.HDF5BatchReader$HDF5ReaderConfig v, v; org.apache.drill.exec.physical.resultSet.RowSetLoader v, v, v, v, v, v, v, v, v; int v, v, v, v, v, v, v; java.lang.String v, v; java.util.Iterator v; java.lang.Object v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v = v.; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; return 0; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; return 0; label: v = v.; specialinvoke v.(v); goto label; label: v = v.; v = lengthof v; if v > 1 goto label; v = v.; v = interfaceinvoke v.(0); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(0); v = virtualinvoke v.(); if v != 0 goto label; return 0; label: v = v.; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(0); virtualinvoke v.(); v = v.; interfaceinvoke v.(); goto label; label: v = v.; v = lengthof v; if v > 1 goto label; v = v.; v = interfaceinvoke v.(0); v = virtualinvoke v.(); if v != 0 goto label; return 0; label: v = v.; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(0); virtualinvoke v.(); v = v.; interfaceinvoke v.(); goto label; label: v = 0; v = v.; interfaceinvoke v.(); v = 0; label: v = v.; v = v[1]; if v >= v goto label; v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(); v = v + 1; goto label; label: v = v.; interfaceinvoke v.(); v = v.; v = v[0]; if v < v goto label; return 0; label: return 1; } private void projectMetadataRow(org.apache.drill.exec.physical.resultSet.RowSetLoader) { int[] v; java.util.Map v; io.jhdf.api.Dataset v; boolean v, v, v, v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; io.jhdf.HdfFile v; long v, v; org.apache.drill.exec.physical.resultSet.RowSetLoader v; org.apache.drill.exec.vector.accessor.ScalarWriter v, v, v, v, v, v, v, v; int v; java.lang.String v, v, v, v, v, v, v, v; java.util.Iterator v; java.lang.Class v; java.lang.Object v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: org.apache.drill.exec.physical.resultSet.RowSetLoader; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v <= 0 goto label; specialinvoke v.(v, v); label: v = virtualinvoke v.(); v = virtualinvoke v.("DATASET"); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v == 0 goto label; v = virtualinvoke v.(); specialinvoke v.(v, v); label: interfaceinvoke v.(); return; } private java.util.List getFileMetadata(io.jhdf.api.Group, java.util.List) { java.lang.Throwable v; io.jhdf.api.Node v; int[] v; java.util.Map v, v; int v, v; java.lang.String v, v, v, v, v, v; boolean v, v; org.apache.drill.exec.store.hdf.HDF5DrillMetadata v; org.slf4j.Logger v, v; java.util.Iterator v; java.util.List v; io.jhdf.api.NodeType v, v, v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; java.lang.Object v; io.jhdf.api.Group v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: io.jhdf.api.Group; v := @parameter: java.util.List; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v); return v; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.drill.exec.store.hdf.HDF5DrillMetadata; specialinvoke v.()>(); v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(1); goto label; label: v = interfaceinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(0); v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = interfaceinvoke v.(); v = specialinvoke v.(v); virtualinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); v = specialinvoke v.(v); virtualinvoke v.(v); interfaceinvoke v.(v); specialinvoke v.(v, v); goto label; label: v = ; v = interfaceinvoke v.(); interfaceinvoke v.("Unknown data type: {}", v); goto label; label: return v; catch io.jhdf.exceptions.HdfException from label to label with label; } private java.util.Map getAttributes(java.lang.String) { java.lang.Throwable v; java.util.HashMap v; java.lang.Integer v; io.jhdf.api.Node v; java.util.Map v; int v, v, v; java.lang.String v, v, v, v; boolean v, v, v; org.apache.drill.exec.store.hdf.HDF5Attribute v; org.slf4j.Logger v, v, v, v, v, v; java.util.Iterator v; java.util.Set v; java.lang.Exception v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; io.jhdf.HdfFile v, v; java.lang.Object v, v, v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: java.lang.String; v = virtualinvoke v.("/"); if v == 0 goto label; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(0, v); label: v = ; interfaceinvoke v.("Getting attributes for {}", v); v = new java.util.HashMap; specialinvoke v.()>(); label: v = v.; v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Couldn\'t get attributes for path: {}", v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("Error: {}", v); return v; label: v = interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unable to get attributes for {}: Only Huge objects BTrees with 1 record are currently supported.", v); return v; label: v = ; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Found {} attribtutes for {}", v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = staticinvoke (v, v, v); if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Adding {} to attribute list for {}", v, v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: return v; catch java.lang.Exception from label to label with label; catch io.jhdf.exceptions.HdfException from label to label with label; } private void projectDataset(org.apache.drill.exec.physical.resultSet.RowSetLoader, java.lang.String) { org.apache.drill.common.exceptions.UserException v; byte v; io.jhdf.api.Dataset v; java.lang.Exception v, v; io.jhdf.HdfFile v, v; double[][] v; java.lang.Object[] v; org.apache.drill.common.exceptions.UserException$Builder v, v, v; long v; java.lang.AssertionError v; java.lang.String v, v, v, v, v; long[][] v; io.jhdf.object.datatype.DataType v, v, v, v, v; int[][] v; org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v; int[] v, v, v, v; boolean v; org.apache.drill.exec.store.hdf.HDF5BatchReader v; org.apache.drill.common.exceptions.CustomErrorContext v; org.apache.drill.exec.physical.resultSet.RowSetLoader v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v; float[][] v; org.slf4j.Logger v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v; v := @this: org.apache.drill.exec.store.hdf.HDF5BatchReader; v := @parameter: org.apache.drill.exec.physical.resultSet.RowSetLoader; v := @parameter: java.lang.String; v = staticinvoke (v); v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = ; v = v cmp v; if v <= 0 goto label; v = ; interfaceinvoke v.("Dataset {} is greater than 16MB. Data will be truncated in Metadata view.", v); label: v = interfaceinvoke v.(); v = lengthof v; if v != 1 goto label; v = interfaceinvoke v.(); v = staticinvoke (v); label: v = interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error reading {}", v); return; label: v = ; if v != 0 goto label; if v != null goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: if v != null goto label; return; label: v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; case 10: goto label; default: goto label; }; label: v = ; interfaceinvoke v.("Couldn\'t read {}", v); goto label; label: specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v, v); goto label; label: v = v.; specialinvoke v.