https://github.com/vmzakharov/dataframe-ec: A tabular data structure based on the Eclipse Collections framework
  • Vladimir Zakharov 
public class io.github.vmzakharov.ecdataframe.dataset.AvroDataSet extends io.github.vmzakharov.ecdataframe.dataset.DataSetAbstract
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.github.vmzakharov.ecdataframe.dataset.AvroDataSet
  super_class: io.github.vmzakharov.ecdataframe.dataset.DataSetAbstract
{
  private final org.apache.avro.Schema schema;
    descriptor: Lorg/apache/avro/Schema;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.lang.String dataFileName;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private org.apache.avro.generic.GenericRecord currentRecord;
    descriptor: Lorg/apache/avro/generic/GenericRecord;
    flags: (0x0002) ACC_PRIVATE

  private org.apache.avro.file.DataFileReader<org.apache.avro.generic.GenericRecord> dataFileReader;
    descriptor: Lorg/apache/avro/file/DataFileReader;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lorg/apache/avro/file/DataFileReader<Lorg/apache/avro/generic/GenericRecord;>;

  private static volatile int[] $SWITCH_TABLE$org$apache$avro$Schema$Type;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  public void <init>(java.lang.String, java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
        start local 1 // java.lang.String schemaDefinitionFileName
        start local 2 // java.lang.String newName
        start local 3 // java.lang.String newDataFileName
         0: .line 29
            aload 0 /* this */
            aload 2 /* newName */
            invokespecial io.github.vmzakharov.ecdataframe.dataset.DataSetAbstract.<init>:(Ljava/lang/String;)V
         1: .line 30
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* schemaDefinitionFileName */
            invokevirtual io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.loadSchema:(Ljava/lang/String;)Lorg/apache/avro/Schema;
            putfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.schema:Lorg/apache/avro/Schema;
         2: .line 31
            aload 0 /* this */
            aload 3 /* newDataFileName */
            putfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileName:Ljava/lang/String;
         3: .line 32
            return
        end local 3 // java.lang.String newDataFileName
        end local 2 // java.lang.String newName
        end local 1 // java.lang.String schemaDefinitionFileName
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0    4     0                      this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            0    4     1  schemaDefinitionFileName  Ljava/lang/String;
            0    4     2                   newName  Ljava/lang/String;
            0    4     3           newDataFileName  Ljava/lang/String;
    MethodParameters:
                          Name  Flags
      schemaDefinitionFileName  
      newName                   
      newDataFileName           

  private org.apache.avro.Schema loadSchema(java.lang.String);
    descriptor: (Ljava/lang/String;)Lorg/apache/avro/Schema;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
        start local 1 // java.lang.String schemaDefinitionFileName
         0: .line 38
            new org.apache.avro.Schema$Parser
            dup
            invokespecial org.apache.avro.Schema$Parser.<init>:()V
            new java.io.File
            dup
            aload 1 /* schemaDefinitionFileName */
            invokespecial java.io.File.<init>:(Ljava/lang/String;)V
            invokevirtual org.apache.avro.Schema$Parser.parse:(Ljava/io/File;)Lorg/apache/avro/Schema;
         1: areturn
         2: .line 40
      StackMap locals:
      StackMap stack: java.io.IOException
            astore 2 /* e */
        start local 2 // java.io.IOException e
         3: .line 42
            new java.lang.RuntimeException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Failed to load a schema definition from "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* schemaDefinitionFileName */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 2 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 2 // java.io.IOException e
        end local 1 // java.lang.String schemaDefinitionFileName
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0    4     0                      this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            0    4     1  schemaDefinitionFileName  Ljava/lang/String;
            3    4     2                         e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.io.IOException
    MethodParameters:
                          Name  Flags
      schemaDefinitionFileName  

  public org.apache.avro.generic.GenericRecord createRecord();
    descriptor: ()Lorg/apache/avro/generic/GenericRecord;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
         0: .line 48
            new org.apache.avro.generic.GenericData$Record
            dup
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.schema:Lorg/apache/avro/Schema;
            invokespecial org.apache.avro.generic.GenericData$Record.<init>:(Lorg/apache/avro/Schema;)V
            areturn
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;

  public org.apache.avro.generic.GenericRecord createRecordForField(java.lang.String);
    descriptor: (Ljava/lang/String;)Lorg/apache/avro/generic/GenericRecord;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
        start local 1 // java.lang.String fieldName
         0: .line 53
            new org.apache.avro.generic.GenericData$Record
            dup
            aload 0 /* this */
            aload 1 /* fieldName */
            invokevirtual io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.findFieldSchema:(Ljava/lang/String;)Lorg/apache/avro/Schema;
            invokespecial org.apache.avro.generic.GenericData$Record.<init>:(Lorg/apache/avro/Schema;)V
            areturn
        end local 1 // java.lang.String fieldName
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            0    1     1  fieldName  Ljava/lang/String;
    MethodParameters:
           Name  Flags
      fieldName  

  private org.apache.avro.Schema findFieldSchema(java.lang.String);
    descriptor: (Ljava/lang/String;)Lorg/apache/avro/Schema;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
        start local 1 // java.lang.String fieldName
         0: .line 58
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.schema:Lorg/apache/avro/Schema;
            aload 1 /* fieldName */
            invokevirtual org.apache.avro.Schema.getField:(Ljava/lang/String;)Lorg/apache/avro/Schema$Field;
            invokevirtual org.apache.avro.Schema$Field.schema:()Lorg/apache/avro/Schema;
            astore 2 /* fieldSchema */
        start local 2 // org.apache.avro.Schema fieldSchema
         1: .line 60
            aload 2 /* fieldSchema */
            invokevirtual org.apache.avro.Schema.isUnion:()Z
            ifeq 3
         2: .line 62
            aload 2 /* fieldSchema */
            invokevirtual org.apache.avro.Schema.getTypes:()Ljava/util/List;
            invokedynamic accept()Lorg/eclipse/collections/api/block/predicate/Predicate;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Z
                  io/github/vmzakharov/ecdataframe/dataset/AvroDataSet.lambda$0(Lorg/apache/avro/Schema;)Z (6)
                  (Lorg/apache/avro/Schema;)Z
                  1
            invokestatic org.eclipse.collections.impl.utility.ListIterate.detect:(Ljava/util/List;Lorg/eclipse/collections/api/block/predicate/Predicate;)Ljava/lang/Object;
            checkcast org.apache.avro.Schema
            astore 2 /* fieldSchema */
         3: .line 65
      StackMap locals: org.apache.avro.Schema
      StackMap stack:
            aload 2 /* fieldSchema */
            areturn
        end local 2 // org.apache.avro.Schema fieldSchema
        end local 1 // java.lang.String fieldName
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            0    4     1    fieldName  Ljava/lang/String;
            1    4     2  fieldSchema  Lorg/apache/avro/Schema;
    MethodParameters:
           Name  Flags
      fieldName  

  public void write(org.apache.avro.generic.GenericRecord[]);
    descriptor: ([Lorg/apache/avro/generic/GenericRecord;)V
    flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
    Code:
      stack=5, locals=8, args_size=2
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
        start local 1 // org.apache.avro.generic.GenericRecord[] records
         0: .line 71
            new java.io.File
            dup
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileName:Ljava/lang/String;
            invokespecial java.io.File.<init>:(Ljava/lang/String;)V
            astore 2 /* file */
        start local 2 // java.io.File file
         1: .line 72
            new org.apache.avro.generic.GenericDatumWriter
            dup
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.schema:Lorg/apache/avro/Schema;
            invokespecial org.apache.avro.generic.GenericDatumWriter.<init>:(Lorg/apache/avro/Schema;)V
            astore 3 /* datumWriter */
        start local 3 // org.apache.avro.io.DatumWriter datumWriter
         2: .line 74
            aconst_null
            astore 4
            aconst_null
            astore 5
         3: new org.apache.avro.file.DataFileWriter
            dup
            aload 3 /* datumWriter */
            invokespecial org.apache.avro.file.DataFileWriter.<init>:(Lorg/apache/avro/io/DatumWriter;)V
            astore 6 /* dataFileWriter */
        start local 6 // org.apache.avro.file.DataFileWriter dataFileWriter
         4: .line 76
            aload 6 /* dataFileWriter */
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.schema:Lorg/apache/avro/Schema;
            aload 2 /* file */
            invokevirtual org.apache.avro.file.DataFileWriter.create:(Lorg/apache/avro/Schema;Ljava/io/File;)Lorg/apache/avro/file/DataFileWriter;
            pop
         5: .line 77
            iconst_0
            istore 7 /* i */
        start local 7 // int i
         6: goto 9
         7: .line 79
      StackMap locals: io.github.vmzakharov.ecdataframe.dataset.AvroDataSet org.apache.avro.generic.GenericRecord[] java.io.File org.apache.avro.io.DatumWriter java.lang.Throwable java.lang.Throwable org.apache.avro.file.DataFileWriter int
      StackMap stack:
            aload 6 /* dataFileWriter */
            aload 1 /* records */
            iload 7 /* i */
            aaload
            invokevirtual org.apache.avro.file.DataFileWriter.append:(Ljava/lang/Object;)V
         8: .line 77
            iinc 7 /* i */ 1
      StackMap locals:
      StackMap stack:
         9: iload 7 /* i */
            aload 1 /* records */
            arraylength
            if_icmplt 7
        end local 7 // int i
        10: .line 81
            aload 6 /* dataFileWriter */
            ifnull 18
            aload 6 /* dataFileWriter */
            invokevirtual org.apache.avro.file.DataFileWriter.close:()V
            goto 18
      StackMap locals: io.github.vmzakharov.ecdataframe.dataset.AvroDataSet org.apache.avro.generic.GenericRecord[] java.io.File org.apache.avro.io.DatumWriter java.lang.Throwable java.lang.Throwable org.apache.avro.file.DataFileWriter
      StackMap stack: java.lang.Throwable
        11: astore 4
            aload 6 /* dataFileWriter */
            ifnull 12
            aload 6 /* dataFileWriter */
            invokevirtual org.apache.avro.file.DataFileWriter.close:()V
        end local 6 // org.apache.avro.file.DataFileWriter dataFileWriter
      StackMap locals:
      StackMap stack:
        12: aload 4
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        13: astore 5
            aload 4
            ifnonnull 14
            aload 5
            astore 4
            goto 15
      StackMap locals:
      StackMap stack:
        14: aload 4
            aload 5
            if_acmpeq 15
            aload 4
            aload 5
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        15: aload 4
            athrow
        16: .line 82
      StackMap locals: io.github.vmzakharov.ecdataframe.dataset.AvroDataSet org.apache.avro.generic.GenericRecord[] java.io.File org.apache.avro.io.DatumWriter
      StackMap stack: java.io.IOException
            astore 4 /* e */
        start local 4 // java.io.IOException e
        17: .line 84
            new java.lang.RuntimeException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Failed to persist data into '"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileName:Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 4 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 4 // java.io.IOException e
        18: .line 86
      StackMap locals:
      StackMap stack:
            return
        end local 3 // org.apache.avro.io.DatumWriter datumWriter
        end local 2 // java.io.File file
        end local 1 // org.apache.avro.generic.GenericRecord[] records
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   19     0            this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            0   19     1         records  [Lorg/apache/avro/generic/GenericRecord;
            1   19     2            file  Ljava/io/File;
            2   19     3     datumWriter  Lorg/apache/avro/io/DatumWriter<Lorg/apache/avro/generic/GenericRecord;>;
            4   12     6  dataFileWriter  Lorg/apache/avro/file/DataFileWriter<Lorg/apache/avro/generic/GenericRecord;>;
            6   10     7               i  I
           17   18     4               e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           4    10      11  any
           3    13      13  any
           2    16      16  Class java.io.IOException
    MethodParameters:
         Name  Flags
      records  

  public void openFileForReading();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=1
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
         0: .line 91
            new java.io.File
            dup
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileName:Ljava/lang/String;
            invokespecial java.io.File.<init>:(Ljava/lang/String;)V
            astore 1 /* file */
        start local 1 // java.io.File file
         1: .line 92
            new org.apache.avro.generic.GenericDatumReader
            dup
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.schema:Lorg/apache/avro/Schema;
            invokespecial org.apache.avro.generic.GenericDatumReader.<init>:(Lorg/apache/avro/Schema;)V
            astore 2 /* datumReader */
        start local 2 // org.apache.avro.io.DatumReader datumReader
         2: .line 95
            aload 0 /* this */
            new org.apache.avro.file.DataFileReader
            dup
            aload 1 /* file */
            aload 2 /* datumReader */
            invokespecial org.apache.avro.file.DataFileReader.<init>:(Ljava/io/File;Lorg/apache/avro/io/DatumReader;)V
            putfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileReader:Lorg/apache/avro/file/DataFileReader;
         3: .line 96
            goto 6
         4: .line 97
      StackMap locals: io.github.vmzakharov.ecdataframe.dataset.AvroDataSet java.io.File org.apache.avro.io.DatumReader
      StackMap stack: java.io.IOException
            astore 3 /* e */
        start local 3 // java.io.IOException e
         5: .line 99
            new java.lang.RuntimeException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Unable to create a reader for file '"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileName:Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 3 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 3 // java.io.IOException e
         6: .line 101
      StackMap locals:
      StackMap stack:
            return
        end local 2 // org.apache.avro.io.DatumReader datumReader
        end local 1 // java.io.File file
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    7     0         this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            1    7     1         file  Ljava/io/File;
            2    7     2  datumReader  Lorg/apache/avro/io/DatumReader<Lorg/apache/avro/generic/GenericRecord;>;
            5    6     3            e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           2     3       4  Class java.io.IOException

  public java.lang.Object getValue(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
        start local 1 // java.lang.String propertyChainString
         0: .line 105
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.currentRecord:Lorg/apache/avro/generic/GenericRecord;
            aload 1 /* propertyChainString */
            invokeinterface org.apache.avro.generic.GenericRecord.get:(Ljava/lang/String;)Ljava/lang/Object;
            areturn
        end local 1 // java.lang.String propertyChainString
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    1     0                 this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            0    1     1  propertyChainString  Ljava/lang/String;
    MethodParameters:
                     Name  Flags
      propertyChainString  

  public java.lang.Object next();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
         0: .line 111
            aload 0 /* this */
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileReader:Lorg/apache/avro/file/DataFileReader;
            invokevirtual org.apache.avro.file.DataFileReader.next:()Ljava/lang/Object;
            checkcast org.apache.avro.generic.GenericRecord
            putfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.currentRecord:Lorg/apache/avro/generic/GenericRecord;
         1: .line 112
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.currentRecord:Lorg/apache/avro/generic/GenericRecord;
            areturn
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;

  public boolean hasNext();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
         0: .line 118
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileReader:Lorg/apache/avro/file/DataFileReader;
            invokevirtual org.apache.avro.file.DataFileReader.hasNext:()Z
            ireturn
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
         0: .line 126
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileReader:Lorg/apache/avro/file/DataFileReader;
            invokevirtual org.apache.avro.file.DataFileReader.close:()V
         1: .line 127
            goto 4
         2: .line 128
      StackMap locals:
      StackMap stack: java.io.IOException
            pop
         3: .line 130
            new java.lang.RuntimeException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Unable to close data file reader for '"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.dataFileName:Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 132
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
      Exception table:
        from    to  target  type
           0     1       2  Class java.io.IOException

  public io.github.vmzakharov.ecdataframe.dsl.value.ValueType getFieldType(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/github/vmzakharov/ecdataframe/dsl/value/ValueType;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
        start local 1 // java.lang.String fieldName
         0: .line 136
            aload 0 /* this */
            aload 1 /* fieldName */
            invokevirtual io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.findFieldSchema:(Ljava/lang/String;)Lorg/apache/avro/Schema;
            astore 2 /* fieldSchema */
        start local 2 // org.apache.avro.Schema fieldSchema
         1: .line 137
            invokestatic io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.$SWITCH_TABLE$org$apache$avro$Schema$Type:()[I
            aload 2 /* fieldSchema */
            invokevirtual org.apache.avro.Schema.getType:()Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            iaload
            tableswitch { // 6 - 13
                    6: 3
                    7: 4
                    8: 6
                    9: 2
                   10: 6
                   11: 3
                   12: 3
                   13: 5
              default: 6
          }
         2: .line 140
      StackMap locals: org.apache.avro.Schema
      StackMap stack:
            getstatic io.github.vmzakharov.ecdataframe.dsl.value.ValueType.LONG:Lio/github/vmzakharov/ecdataframe/dsl/value/ValueType;
            areturn
         3: .line 144
      StackMap locals:
      StackMap stack:
            getstatic io.github.vmzakharov.ecdataframe.dsl.value.ValueType.DOUBLE:Lio/github/vmzakharov/ecdataframe/dsl/value/ValueType;
            areturn
         4: .line 146
      StackMap locals:
      StackMap stack:
            getstatic io.github.vmzakharov.ecdataframe.dsl.value.ValueType.STRING:Lio/github/vmzakharov/ecdataframe/dsl/value/ValueType;
            areturn
         5: .line 148
      StackMap locals:
      StackMap stack:
            getstatic io.github.vmzakharov.ecdataframe.dsl.value.ValueType.BOOLEAN:Lio/github/vmzakharov/ecdataframe/dsl/value/ValueType;
            areturn
         6: .line 150
      StackMap locals:
      StackMap stack:
            getstatic io.github.vmzakharov.ecdataframe.dsl.value.ValueType.VOID:Lio/github/vmzakharov/ecdataframe/dsl/value/ValueType;
            areturn
        end local 2 // org.apache.avro.Schema fieldSchema
        end local 1 // java.lang.String fieldName
        end local 0 // io.github.vmzakharov.ecdataframe.dataset.AvroDataSet this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    7     0         this  Lio/github/vmzakharov/ecdataframe/dataset/AvroDataSet;
            0    7     1    fieldName  Ljava/lang/String;
            1    7     2  fieldSchema  Lorg/apache/avro/Schema;
    MethodParameters:
           Name  Flags
      fieldName  

  static int[] $SWITCH_TABLE$org$apache$avro$Schema$Type();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 18
            getstatic io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.$SWITCH_TABLE$org$apache$avro$Schema$Type:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic org.apache.avro.Schema$Type.values:()[Lorg/apache/avro/Schema$Type;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic org.apache.avro.Schema$Type.ARRAY:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            iconst_3
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic org.apache.avro.Schema$Type.BOOLEAN:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 13
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic org.apache.avro.Schema$Type.BYTES:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 8
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            getstatic org.apache.avro.Schema$Type.DOUBLE:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 12
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            getstatic org.apache.avro.Schema$Type.ENUM:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            iconst_2
            iastore
        15: goto 17
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        16: pop
      StackMap locals:
      StackMap stack:
        17: aload 0
            getstatic org.apache.avro.Schema$Type.FIXED:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 6
            iastore
        18: goto 20
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        19: pop
      StackMap locals:
      StackMap stack:
        20: aload 0
            getstatic org.apache.avro.Schema$Type.FLOAT:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 11
            iastore
        21: goto 23
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        22: pop
      StackMap locals:
      StackMap stack:
        23: aload 0
            getstatic org.apache.avro.Schema$Type.INT:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 9
            iastore
        24: goto 26
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        25: pop
      StackMap locals:
      StackMap stack:
        26: aload 0
            getstatic org.apache.avro.Schema$Type.LONG:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 10
            iastore
        27: goto 29
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        28: pop
      StackMap locals:
      StackMap stack:
        29: aload 0
            getstatic org.apache.avro.Schema$Type.MAP:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            iconst_4
            iastore
        30: goto 32
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        31: pop
      StackMap locals:
      StackMap stack:
        32: aload 0
            getstatic org.apache.avro.Schema$Type.NULL:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 14
            iastore
        33: goto 35
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        34: pop
      StackMap locals:
      StackMap stack:
        35: aload 0
            getstatic org.apache.avro.Schema$Type.RECORD:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            iconst_1
            iastore
        36: goto 38
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        37: pop
      StackMap locals:
      StackMap stack:
        38: aload 0
            getstatic org.apache.avro.Schema$Type.STRING:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            bipush 7
            iastore
        39: goto 41
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        40: pop
      StackMap locals:
      StackMap stack:
        41: aload 0
            getstatic org.apache.avro.Schema$Type.UNION:Lorg/apache/avro/Schema$Type;
            invokevirtual org.apache.avro.Schema$Type.ordinal:()I
            iconst_5
            iastore
        42: goto 44
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        43: pop
      StackMap locals:
      StackMap stack:
        44: aload 0
            dup
            putstatic io.github.vmzakharov.ecdataframe.dataset.AvroDataSet.$SWITCH_TABLE$org$apache$avro$Schema$Type:[I
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.NoSuchFieldError
           5     6       7  Class java.lang.NoSuchFieldError
           8     9      10  Class java.lang.NoSuchFieldError
          11    12      13  Class java.lang.NoSuchFieldError
          14    15      16  Class java.lang.NoSuchFieldError
          17    18      19  Class java.lang.NoSuchFieldError
          20    21      22  Class java.lang.NoSuchFieldError
          23    24      25  Class java.lang.NoSuchFieldError
          26    27      28  Class java.lang.NoSuchFieldError
          29    30      31  Class java.lang.NoSuchFieldError
          32    33      34  Class java.lang.NoSuchFieldError
          35    36      37  Class java.lang.NoSuchFieldError
          38    39      40  Class java.lang.NoSuchFieldError
          41    42      43  Class java.lang.NoSuchFieldError

  private static boolean lambda$0(org.apache.avro.Schema);
    descriptor: (Lorg/apache/avro/Schema;)Z
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.avro.Schema schema
         0: .line 62
            aload 0 /* schema */
            invokevirtual org.apache.avro.Schema.getType:()Lorg/apache/avro/Schema$Type;
            getstatic org.apache.avro.Schema$Type.NULL:Lorg/apache/avro/Schema$Type;
            if_acmpeq 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: ireturn
        end local 0 // org.apache.avro.Schema schema
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0  schema  Lorg/apache/avro/Schema;

  private static java.lang.Object $deserializeLambda$(java.lang.invoke.SerializedLambda);
    descriptor: (Ljava/lang/invoke/SerializedLambda;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=1
         0: .line 1
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodName:()Ljava/lang/String;
            astore 1
            iconst_m1
            istore 2
            aload 1
            invokevirtual java.lang.String.hashCode:()I
            lookupswitch { // 1
          -1647345005: 1
              default: 2
          }
      StackMap locals: java.lang.String int
      StackMap stack:
         1: aload 1
            ldc "lambda$0"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 2
            iconst_0
            istore 2
      StackMap locals:
      StackMap stack:
         2: iload 2
            lookupswitch { // 1
                    0: 3
              default: 4
          }
      StackMap locals:
      StackMap stack:
         3: aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
            bipush 6
            if_icmpne 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
            ldc "org/eclipse/collections/api/block/predicate/Predicate"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
            ldc "accept"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
            ldc "(Ljava/lang/Object;)Z"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
            ldc "io/github/vmzakharov/ecdataframe/dataset/AvroDataSet"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
            ldc "(Lorg/apache/avro/Schema;)Z"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            invokedynamic accept()Lorg/eclipse/collections/api/block/predicate/Predicate;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Z
                  io/github/vmzakharov/ecdataframe/dataset/AvroDataSet.lambda$0(Lorg/apache/avro/Schema;)Z (6)
                  (Lorg/apache/avro/Schema;)Z
                  1
            areturn
      StackMap locals:
      StackMap stack:
         4: new java.lang.IllegalArgumentException
            dup
            ldc "Invalid lambda deserialization"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
SourceFile: "AvroDataSet.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public Field = org.apache.avro.Schema$Field of org.apache.avro.Schema
  public Parser = org.apache.avro.Schema$Parser of org.apache.avro.Schema
  public final Type = org.apache.avro.Schema$Type of org.apache.avro.Schema
  public Record = org.apache.avro.generic.GenericData$Record of org.apache.avro.generic.GenericData