public class oadd.org.apache.hadoop.io.SequenceFile$Reader extends java.lang.Object implements java.io.Closeable { private java.lang.String filename; private oadd.org.apache.hadoop.fs.FSDataInputStream in; private oadd.org.apache.hadoop.io.DataOutputBuffer outBuf; private byte version; private java.lang.String keyClassName; private java.lang.String valClassName; private java.lang.Class keyClass; private java.lang.Class valClass; private oadd.org.apache.hadoop.io.compress.CompressionCodec codec; private oadd.org.apache.hadoop.io.SequenceFile$Metadata metadata; private byte[] sync; private byte[] syncCheck; private boolean syncSeen; private long headerEnd; private long end; private int keyLength; private int recordLength; private boolean decompress; private boolean blockCompressed; private oadd.org.apache.hadoop.conf.Configuration conf; private int noBufferedRecords; private boolean lazyDecompress; private boolean valuesDecompressed; private int noBufferedKeys; private int noBufferedValues; private oadd.org.apache.hadoop.io.DataInputBuffer keyLenBuffer; private oadd.org.apache.hadoop.io.compress.CompressionInputStream keyLenInFilter; private java.io.DataInputStream keyLenIn; private oadd.org.apache.hadoop.io.compress.Decompressor keyLenDecompressor; private oadd.org.apache.hadoop.io.DataInputBuffer keyBuffer; private oadd.org.apache.hadoop.io.compress.CompressionInputStream keyInFilter; private java.io.DataInputStream keyIn; private oadd.org.apache.hadoop.io.compress.Decompressor keyDecompressor; private oadd.org.apache.hadoop.io.DataInputBuffer valLenBuffer; private oadd.org.apache.hadoop.io.compress.CompressionInputStream valLenInFilter; private java.io.DataInputStream valLenIn; private oadd.org.apache.hadoop.io.compress.Decompressor valLenDecompressor; private oadd.org.apache.hadoop.io.DataInputBuffer valBuffer; private oadd.org.apache.hadoop.io.compress.CompressionInputStream valInFilter; private java.io.DataInputStream valIn; private oadd.org.apache.hadoop.io.compress.Decompressor valDecompressor; private oadd.org.apache.hadoop.io.serializer.Deserializer keyDeserializer; private oadd.org.apache.hadoop.io.serializer.Deserializer valDeserializer; public static oadd.org.apache.hadoop.io.SequenceFile$Reader$Option file(oadd.org.apache.hadoop.fs.Path) { oadd.org.apache.hadoop.io.SequenceFile$Reader$FileOption v; oadd.org.apache.hadoop.fs.Path v; v := @parameter: oadd.org.apache.hadoop.fs.Path; v = new oadd.org.apache.hadoop.io.SequenceFile$Reader$FileOption; specialinvoke v.(oadd.org.apache.hadoop.fs.Path)>(v); return v; } public static oadd.org.apache.hadoop.io.SequenceFile$Reader$Option stream(oadd.org.apache.hadoop.fs.FSDataInputStream) { oadd.org.apache.hadoop.fs.FSDataInputStream v; oadd.org.apache.hadoop.io.SequenceFile$Reader$InputStreamOption v; v := @parameter: oadd.org.apache.hadoop.fs.FSDataInputStream; v = new oadd.org.apache.hadoop.io.SequenceFile$Reader$InputStreamOption; specialinvoke v.(oadd.org.apache.hadoop.fs.FSDataInputStream)>(v); return v; } public static oadd.org.apache.hadoop.io.SequenceFile$Reader$Option start(long) { oadd.org.apache.hadoop.io.SequenceFile$Reader$StartOption v; long v; v := @parameter: long; v = new oadd.org.apache.hadoop.io.SequenceFile$Reader$StartOption; specialinvoke v.(long)>(v); return v; } public static oadd.org.apache.hadoop.io.SequenceFile$Reader$Option length(long) { long v; oadd.org.apache.hadoop.io.SequenceFile$Reader$LengthOption v; v := @parameter: long; v = new oadd.org.apache.hadoop.io.SequenceFile$Reader$LengthOption; specialinvoke v.(long)>(v); return v; } public static oadd.org.apache.hadoop.io.SequenceFile$Reader$Option bufferSize(int) { int v; oadd.org.apache.hadoop.io.SequenceFile$Reader$BufferSizeOption v; v := @parameter: int; v = new oadd.org.apache.hadoop.io.SequenceFile$Reader$BufferSizeOption; specialinvoke v.(int)>(v); return v; } public transient void (oadd.org.apache.hadoop.conf.Configuration, oadd.org.apache.hadoop.io.SequenceFile$Reader$Option[]) throws java.io.IOException { byte[] v, v; long v, v, v, v, v, v; oadd.org.apache.hadoop.io.SequenceFile$Reader$Option[] v; oadd.org.apache.hadoop.io.DataOutputBuffer v; int v, v; oadd.org.apache.hadoop.conf.Configuration v; boolean v, v, v; oadd.org.apache.hadoop.fs.FSDataInputStream v, v; java.lang.IllegalArgumentException v, v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; oadd.org.apache.hadoop.fs.FileStatus v; java.lang.Object v, v, v, v, v, v; oadd.org.apache.hadoop.fs.Path v, v; oadd.org.apache.hadoop.fs.FileSystem v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v := @parameter: oadd.org.apache.hadoop.io.SequenceFile$Reader$Option[]; specialinvoke v.()>(); v = new oadd.org.apache.hadoop.io.DataOutputBuffer; specialinvoke v.()>(); v. = v; v. = null; v. = null; v = newarray (byte)[16]; v. = v; v = newarray (byte)[16]; v. = v; v. = 0; v. = 1; v. = 1; v. = 0; v. = 0; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v. = null; v = staticinvoke (class "Loadd/org/apache/hadoop/io/SequenceFile$Reader$FileOption;", v); v = staticinvoke (class "Loadd/org/apache/hadoop/io/SequenceFile$Reader$InputStreamOption;", v); v = staticinvoke (class "Loadd/org/apache/hadoop/io/SequenceFile$Reader$StartOption;", v); v = staticinvoke (class "Loadd/org/apache/hadoop/io/SequenceFile$Reader$LengthOption;", v); v = staticinvoke (class "Loadd/org/apache/hadoop/io/SequenceFile$Reader$BufferSizeOption;", v); v = staticinvoke (class "Loadd/org/apache/hadoop/io/SequenceFile$Reader$OnlyHeaderOption;", v); if v != null goto label; v = 1; goto label; label: v = 0; label: if v != null goto label; v = 1; goto label; label: v = 0; label: if v != v goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("File or stream option must be specified"); throw v; label: if v != null goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("buffer size can only be set when a file is specified."); throw v; label: v = null; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; v = staticinvoke (v); goto label; label: v = virtualinvoke v.(); label: v = v; if null != v goto label; v = virtualinvoke v.(v); v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); label: v = v; v = virtualinvoke v.(v, v, v, v); goto label; label: if null != v goto label; v = 9223372036854775807L; goto label; label: v = virtualinvoke v.(); label: v = v; v = virtualinvoke v.(); label: if v != null goto label; v = 0L; goto label; label: v = virtualinvoke v.(); label: v = v; v = v; v = v; v = v; if v == null goto label; v = 1; goto label; label: v = 0; label: specialinvoke v.(v, v, v, v, v, v); return; } public void (oadd.org.apache.hadoop.fs.FileSystem, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException { oadd.org.apache.hadoop.io.SequenceFile$Reader$Option[] v; oadd.org.apache.hadoop.io.SequenceFile$Reader$Option v; oadd.org.apache.hadoop.conf.Configuration v; oadd.org.apache.hadoop.fs.Path v, v; oadd.org.apache.hadoop.fs.FileSystem v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.fs.FileSystem; v := @parameter: oadd.org.apache.hadoop.fs.Path; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v = newarray (oadd.org.apache.hadoop.io.SequenceFile$Reader$Option)[1]; v = virtualinvoke v.(v); v = staticinvoke (v); v[0] = v; specialinvoke v.(oadd.org.apache.hadoop.conf.Configuration,oadd.org.apache.hadoop.io.SequenceFile$Reader$Option[])>(v, v); return; } public void (oadd.org.apache.hadoop.fs.FSDataInputStream, int, long, long, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException { oadd.org.apache.hadoop.fs.FSDataInputStream v; oadd.org.apache.hadoop.io.SequenceFile$Reader$Option v, v, v; long v, v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; oadd.org.apache.hadoop.io.SequenceFile$Reader$Option[] v; int v; oadd.org.apache.hadoop.conf.Configuration v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.fs.FSDataInputStream; v := @parameter: int; v := @parameter: long; v := @parameter: long; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v = newarray (oadd.org.apache.hadoop.io.SequenceFile$Reader$Option)[3]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; specialinvoke v.(oadd.org.apache.hadoop.conf.Configuration,oadd.org.apache.hadoop.io.SequenceFile$Reader$Option[])>(v, v); return; } private void initialize(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.FSDataInputStream, long, long, oadd.org.apache.hadoop.conf.Configuration, boolean) throws java.io.IOException { java.lang.Throwable v; long v, v, v, v, v; byte v; java.io.Closeable[] v; oadd.org.apache.hadoop.conf.Configuration v; java.lang.String v; boolean v; oadd.org.apache.hadoop.fs.FSDataInputStream v, v, v; org.slf4j.Logger v; java.lang.IllegalArgumentException v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; oadd.org.apache.hadoop.fs.Path v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.fs.Path; v := @parameter: oadd.org.apache.hadoop.fs.FSDataInputStream; v := @parameter: long; v := @parameter: long; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v := @parameter: boolean; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("in == null"); throw v; label: if v != null goto label; v = ""; goto label; label: v = virtualinvoke v.(); label: v. = v; v. = v; v. = v; label: virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v + v; v. = v; v = v.; v = v cmp v; if v >= 0 goto label; v. = 9223372036854775807L; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.io.Closeable)[1]; v = v.; v[0] = v; staticinvoke (v, v); throw v; label: return; catch java.lang.Throwable from label to label with label; } protected oadd.org.apache.hadoop.fs.FSDataInputStream openFile(oadd.org.apache.hadoop.fs.FileSystem, oadd.org.apache.hadoop.fs.Path, int, long) throws java.io.IOException { oadd.org.apache.hadoop.fs.FSDataInputStream v; int v; long v; oadd.org.apache.hadoop.fs.Path v; oadd.org.apache.hadoop.fs.FileSystem v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.fs.FileSystem; v := @parameter: oadd.org.apache.hadoop.fs.Path; v := @parameter: int; v := @parameter: long; v = virtualinvoke v.(v, v); return v; } private void init(boolean) throws java.io.IOException { byte[] v, v, v, v, v, v, v, v; byte v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.conf.Configuration v, v, v, v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; oadd.org.apache.hadoop.io.compress.CompressionInputStream v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.DataInputBuffer v, v, v, v, v, v, v, v, v, v; long v; oadd.org.apache.hadoop.io.UTF8 v; java.io.IOException v, v, v; java.io.DataInputStream v, v, v, v, v, v; oadd.org.apache.hadoop.io.serializer.Deserializer v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.serializer.SerializationFactory v; oadd.org.apache.hadoop.io.VersionMismatchException v; int v; java.lang.Class v, v, v, v, v, v; java.lang.Object v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.fs.FSDataInputStream v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.DefaultCodec v; java.lang.ClassNotFoundException v; boolean v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.CompressionCodec v, v, v, v, v, v, v, v, v; java.io.EOFException v, v; oadd.org.apache.hadoop.io.compress.Decompressor v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.SequenceFile$Metadata v, v; java.lang.IllegalArgumentException v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: boolean; v = ; v = lengthof v; v = newarray (byte)[v]; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u not a SequenceFile"); label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new java.io.EOFException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v[0]; v = ; v = v[0]; if v != v goto label; v = v[1]; v = ; v = v[1]; if v != v goto label; v = v[2]; v = ; v = v[2]; if v == v goto label; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u not a SequenceFile"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v[3]; v. = v; v = v.; v = ; v = v[3]; if v <= v goto label; v = new oadd.org.apache.hadoop.io.VersionMismatchException; v = ; v = v[3]; v = v.; specialinvoke v.(byte,byte)>(v, v); throw v; label: v = v.; if v >= 4 goto label; v = new oadd.org.apache.hadoop.io.UTF8; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; goto label; label: v = v.; v = staticinvoke (v); v. = v; v = v.; v = staticinvoke (v); v. = v; label: v = v.; if v <= 2 goto label; v = v.; v = virtualinvoke v.(); v. = v; goto label; label: v. = 0; label: v = v.; if v < 4 goto label; v = v.; v = virtualinvoke v.(); v. = v; goto label; label: v. = 0; label: v = v.; if v == 0 goto label; v = v.; if v < 5 goto label; v = v.; v = staticinvoke (v); label: v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(class "Loadd/org/apache/hadoop/io/compress/CompressionCodec;"); v = v.; v = staticinvoke (v, v); v. = v; label: goto label; label: v := @caughtexception; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown codec: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = new oadd.org.apache.hadoop.io.compress.DefaultCodec; specialinvoke v.()>(); v. = v; v = v.; v = v.; interfaceinvoke v.(v); label: v = new oadd.org.apache.hadoop.io.SequenceFile$Metadata; specialinvoke v.()>(); v. = v; v = v.; if v < 6 goto label; v = v.; v = v.; virtualinvoke v.(v); label: v = v.; if v <= 1 goto label; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v. = v; label: if v != 0 goto label; v = new oadd.org.apache.hadoop.io.DataInputBuffer; specialinvoke v.()>(); v. = v; v = v.; if v == 0 goto label; v = v.; v = staticinvoke (v); v. = v; v = v.; v = v.; v = v.; v = interfaceinvoke v.(v, v); v. = v; v = new java.io.DataInputStream; v = v.; specialinvoke v.(java.io.InputStream)>(v); v. = v; goto label; label: v = v.; v. = v; label: v = v.; if v == 0 goto label; v = new oadd.org.apache.hadoop.io.DataInputBuffer; specialinvoke v.()>(); v. = v; v = new oadd.org.apache.hadoop.io.DataInputBuffer; specialinvoke v.()>(); v. = v; v = new oadd.org.apache.hadoop.io.DataInputBuffer; specialinvoke v.()>(); v. = v; v = v.; v = staticinvoke (v); v. = v; v = v.; v = v.; v = v.; v = interfaceinvoke v.(v, v); v. = v; v = new java.io.DataInputStream; v = v.; specialinvoke v.(java.io.InputStream)>(v); v. = v; v = v.; v = staticinvoke (v); v. = v; v = v.; v = v.; v = v.; v = interfaceinvoke v.(v, v); v. = v; v = new java.io.DataInputStream; v = v.; specialinvoke v.(java.io.InputStream)>(v); v. = v; v = v.; v = staticinvoke (v); v. = v; v = v.; v = v.; v = v.; v = interfaceinvoke v.(v, v); v. = v; v = new java.io.DataInputStream; v = v.; specialinvoke v.(java.io.InputStream)>(v); v. = v; label: v = new oadd.org.apache.hadoop.io.serializer.SerializationFactory; v = v.; specialinvoke v.(oadd.org.apache.hadoop.conf.Configuration)>(v); v = virtualinvoke v.(); v = specialinvoke v.(v, v); v. = v; v = v.; if v != null goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not find a deserializer for the Key class: \'\u0001\'. Please ensure that the configuration \'oadd.io.serializations\' is properly configured, if you\'re using custom serialization."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; if v != 0 goto label; v = v.; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; v = v.; interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = specialinvoke v.(v, v); v. = v; v = v.; if v != null goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not find a deserializer for the Value class: \'\u0001\'. Please ensure that the configuration \'oadd.io.serializations\' is properly configured, if you\'re using custom serialization."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = v.; interfaceinvoke v.(v); label: return; catch java.io.EOFException from label to label with label; catch java.lang.ClassNotFoundException from label to label with label; } private oadd.org.apache.hadoop.io.serializer.Deserializer getDeserializer(oadd.org.apache.hadoop.io.serializer.SerializationFactory, java.lang.Class) { java.lang.Class v; oadd.org.apache.hadoop.io.serializer.Deserializer v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; oadd.org.apache.hadoop.io.serializer.SerializationFactory v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.io.serializer.SerializationFactory; v := @parameter: java.lang.Class; v = virtualinvoke v.(v); return v; } public synchronized void close() throws java.io.IOException { oadd.org.apache.hadoop.io.compress.Decompressor v, v, v, v; oadd.org.apache.hadoop.fs.FSDataInputStream v; oadd.org.apache.hadoop.io.serializer.Deserializer v, v, v, v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; staticinvoke (v); v = v.; staticinvoke (v); v = v.; staticinvoke (v); v = v.; staticinvoke (v); v. = null; v. = null; v. = null; v. = null; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; virtualinvoke v.(); return; } public java.lang.String getKeyClassName() { java.lang.String v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } public synchronized java.lang.Class getKeyClass() { java.io.IOException v; java.lang.RuntimeException v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; java.lang.Class v, v, v; oadd.org.apache.hadoop.conf.Configuration v; java.lang.String v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; if null != v goto label; label: v = virtualinvoke v.(); v = v.; v = staticinvoke (v, v); v. = v; label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = v.; return v; catch java.io.IOException from label to label with label; } public java.lang.String getValueClassName() { java.lang.String v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } public synchronized java.lang.Class getValueClass() { java.io.IOException v; java.lang.RuntimeException v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; java.lang.Class v, v, v; oadd.org.apache.hadoop.conf.Configuration v; java.lang.String v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; if null != v goto label; label: v = virtualinvoke v.(); v = v.; v = staticinvoke (v, v); v. = v; label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = v.; return v; catch java.io.IOException from label to label with label; } public boolean isCompressed() { boolean v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } public boolean isBlockCompressed() { boolean v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } public oadd.org.apache.hadoop.io.compress.CompressionCodec getCompressionCodec() { oadd.org.apache.hadoop.io.compress.CompressionCodec v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } private byte[] getSync() { byte[] v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } private byte getVersion() { byte v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } public oadd.org.apache.hadoop.io.SequenceFile$CompressionType getCompressionType() { oadd.org.apache.hadoop.io.SequenceFile$CompressionType v, v; boolean v, v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; if v == 0 goto label; v = v.; if v == 0 goto label; v = ; goto label; label: v = ; label: return v; label: v = ; return v; } public oadd.org.apache.hadoop.io.SequenceFile$Metadata getMetadata() { oadd.org.apache.hadoop.io.SequenceFile$Metadata v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } oadd.org.apache.hadoop.conf.Configuration getConf() { oadd.org.apache.hadoop.conf.Configuration v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; return v; } private synchronized void readBuffer(oadd.org.apache.hadoop.io.DataInputBuffer, oadd.org.apache.hadoop.io.compress.CompressionInputStream) throws java.io.IOException { java.lang.Throwable v; byte[] v; oadd.org.apache.hadoop.fs.FSDataInputStream v, v; oadd.org.apache.hadoop.io.compress.CompressionInputStream v; oadd.org.apache.hadoop.io.DataInputBuffer v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; oadd.org.apache.hadoop.io.DataOutputBuffer v; int v, v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.io.DataInputBuffer; v := @parameter: oadd.org.apache.hadoop.io.compress.CompressionInputStream; v = new oadd.org.apache.hadoop.io.DataOutputBuffer; specialinvoke v.()>(); label: v = v.; v = staticinvoke (v); v = v.; virtualinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, 0, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: virtualinvoke v.(); return; catch java.lang.Throwable from label to label with label; } private synchronized void readBlock() throws java.io.IOException { byte[] v, v, v, v; boolean v, v, v, v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; oadd.org.apache.hadoop.io.compress.CompressionInputStream v, v, v, v; oadd.org.apache.hadoop.io.DataInputBuffer v, v, v, v; long v, v, v, v; int v, v, v, v, v; oadd.org.apache.hadoop.fs.FSDataInputStream v, v, v, v, v, v, v, v, v; java.io.IOException v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = v.; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); v = v + v; virtualinvoke v.(v); v = v.; v = v.; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); v = v + v; virtualinvoke v.(v); label: v. = 0; v. = 0; v. = 0; v. = 0; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; v = staticinvoke (v, v); if v != 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("File is corrupt!"); throw v; label: v. = 1; v = v.; v = staticinvoke (v); v. = v; v = v.; v = v.; specialinvoke v.(v, v); v = v.; v = v.; specialinvoke v.(v, v); v = v.; v. = v; v = v.; if v != 0 goto label; v = v.; v = v.; specialinvoke v.(v, v); v = v.; v = v.; specialinvoke v.(v, v); v = v.; v. = v; v. = 1; label: return; } private synchronized void seekToCurrentValue() throws java.io.IOException { java.io.DataInputStream v, v; oadd.org.apache.hadoop.io.compress.CompressionInputStream v, v, v; oadd.org.apache.hadoop.io.DataInputBuffer v, v, v; int v, v, v, v, v, v, v, v, v; java.lang.String v; boolean v, v, v, v; java.io.IOException v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v = v.; if v != 0 goto label; v = v.; if v == 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; virtualinvoke v.(); goto label; label: v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = v.; specialinvoke v.(v, v); v = v.; v = v.; specialinvoke v.(v, v); v = v.; v. = v; v. = 1; label: v = 0; v = v.; v = v + 1; v = v.; label: if v <= v goto label; v = v.; v = staticinvoke (v); v = v + v; v = v.; v = v - 1; v. = v; v = v - 1; goto label; label: if v <= 0 goto label; v = v.; v = virtualinvoke v.(v); if v == v goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to seek to \u0001(th) value!"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } public synchronized void getCurrentValue(oadd.org.apache.hadoop.io.Writable) throws java.io.IOException { java.io.DataInputStream v, v, v, v, v; oadd.org.apache.hadoop.io.DataInputBuffer v, v; oadd.org.apache.hadoop.io.Writable v; int v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.conf.Configuration v; java.lang.String v, v, v; boolean v, v, v; org.slf4j.Logger v, v, v; java.io.IOException v; oadd.org.apache.hadoop.io.SequenceFile$Reader v; v := @this: oadd.org.apache.hadoop.io.SequenceFile$Reader; v := @parameter: oadd.org.apache.hadoop.io.Writable; v = v instanceof oadd.org.apache.hadoop.conf.Configurable; if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: specialinvoke v.(); v = v.; if v != 0 goto label; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("available bytes: \u0001"); interfaceinvoke v.(v); v = new java.io.IOException; v = v.; v = virtualinvoke v.(); v = v.; v = v - v; v = v.; v = virtualinvoke v.(); v = v.; v = v - v; v = dynamicinvoke "makeConcatWithConstants" (v, v, v)