https://github.com/datastax/native-protocol: A set of Java types representing the frames and messages of the Apache Cassandra® native protocol, with the associated serialization and deserialization logic (this is a third-party implementation, not related to the Apache Cassandra project)
  • Various (DataStax) 
public class com.datastax.oss.protocol.internal.request.Batch$Codec extends com.datastax.oss.protocol.internal.Message$Codec
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: com.datastax.oss.protocol.internal.request.Batch$Codec
  super_class: com.datastax.oss.protocol.internal.Message$Codec
{
  public void <init>(int);
    descriptor: (I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
        start local 1 // int protocolVersion
         0: .line 118
            aload 0 /* this */
            bipush 13
            iload 1 /* protocolVersion */
            invokespecial com.datastax.oss.protocol.internal.Message$Codec.<init>:(II)V
         1: .line 119
            return
        end local 1 // int protocolVersion
        end local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    2     0             this  Lcom/datastax/oss/protocol/internal/request/Batch$Codec;
            0    2     1  protocolVersion  I
    MethodParameters:
                 Name  Flags
      protocolVersion  

  public <B> void encode(B, com.datastax.oss.protocol.internal.Message, com.datastax.oss.protocol.internal.PrimitiveCodec<B>);
    descriptor: (Ljava/lang/Object;Lcom/datastax/oss/protocol/internal/Message;Lcom/datastax/oss/protocol/internal/PrimitiveCodec;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=8, args_size=4
        start local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
        start local 1 // java.lang.Object dest
        start local 2 // com.datastax.oss.protocol.internal.Message message
        start local 3 // com.datastax.oss.protocol.internal.PrimitiveCodec encoder
         0: .line 123
            aload 2 /* message */
            checkcast com.datastax.oss.protocol.internal.request.Batch
            astore 4 /* batch */
        start local 4 // com.datastax.oss.protocol.internal.request.Batch batch
         1: .line 124
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.type:B
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeByte:(BLjava/lang/Object;)V
         2: .line 125
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.queriesOrIds:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            istore 5 /* queryCount */
        start local 5 // int queryCount
         3: .line 126
            aload 3 /* encoder */
            iload 5 /* queryCount */
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeUnsignedShort:(ILjava/lang/Object;)V
         4: .line 127
            iconst_0
            istore 6 /* i */
        start local 6 // int i
         5: goto 15
         6: .line 128
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch int int
      StackMap stack:
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.queriesOrIds:Ljava/util/List;
            iload 6 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            astore 7 /* q */
        start local 7 // java.lang.Object q
         7: .line 129
            aload 7 /* q */
            instanceof java.lang.String
            ifeq 11
         8: .line 130
            aload 3 /* encoder */
            iconst_0
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeByte:(BLjava/lang/Object;)V
         9: .line 131
            aload 3 /* encoder */
            aload 7 /* q */
            checkcast java.lang.String
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeLongString:(Ljava/lang/String;Ljava/lang/Object;)V
        10: .line 132
            goto 13
        11: .line 133
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 3 /* encoder */
            iconst_1
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeByte:(BLjava/lang/Object;)V
        12: .line 134
            aload 3 /* encoder */
            aload 7 /* q */
            checkcast byte[]
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeShortBytes:([BLjava/lang/Object;)V
        13: .line 136
      StackMap locals:
      StackMap stack:
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.values:Ljava/util/List;
            iload 6 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast java.util.List
            aload 1 /* dest */
            aload 3 /* encoder */
            invokestatic com.datastax.oss.protocol.internal.request.query.Values.writePositionalValues:(Ljava/util/List;Ljava/lang/Object;Lcom/datastax/oss/protocol/internal/PrimitiveCodec;)V
        end local 7 // java.lang.Object q
        14: .line 127
            iinc 6 /* i */ 1
      StackMap locals:
      StackMap stack:
        15: iload 6 /* i */
            iload 5 /* queryCount */
            if_icmplt 6
        end local 6 // int i
        16: .line 139
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.consistency:I
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeUnsignedShort:(ILjava/lang/Object;)V
        17: .line 141
            aload 0 /* this */
            getfield com.datastax.oss.protocol.internal.request.Batch$Codec.protocolVersion:I
            iconst_5
            if_icmplt 20
        18: .line 142
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeInt:(ILjava/lang/Object;)V
        19: .line 143
            goto 21
        20: .line 144
      StackMap locals:
      StackMap stack:
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            i2b
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeByte:(BLjava/lang/Object;)V
        21: .line 146
      StackMap locals:
      StackMap stack:
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            bipush 16
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 23
        22: .line 147
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.serialConsistency:I
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeUnsignedShort:(ILjava/lang/Object;)V
        23: .line 149
      StackMap locals:
      StackMap stack:
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            bipush 32
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 25
        24: .line 150
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.defaultTimestamp:J
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeLong:(JLjava/lang/Object;)V
        25: .line 152
      StackMap locals:
      StackMap stack:
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            sipush 128
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 27
        26: .line 153
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.keyspace:Ljava/lang/String;
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeString:(Ljava/lang/String;Ljava/lang/Object;)V
        27: .line 155
      StackMap locals:
      StackMap stack:
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            sipush 256
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 29
        28: .line 156
            aload 3 /* encoder */
            aload 4 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.nowInSeconds:I
            aload 1 /* dest */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeInt:(ILjava/lang/Object;)V
        29: .line 158
      StackMap locals:
      StackMap stack:
            return
        end local 5 // int queryCount
        end local 4 // com.datastax.oss.protocol.internal.request.Batch batch
        end local 3 // com.datastax.oss.protocol.internal.PrimitiveCodec encoder
        end local 2 // com.datastax.oss.protocol.internal.Message message
        end local 1 // java.lang.Object dest
        end local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   30     0        this  Lcom/datastax/oss/protocol/internal/request/Batch$Codec;
            0   30     1        dest  TB;
            0   30     2     message  Lcom/datastax/oss/protocol/internal/Message;
            0   30     3     encoder  Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;
            1   30     4       batch  Lcom/datastax/oss/protocol/internal/request/Batch;
            3   30     5  queryCount  I
            5   16     6           i  I
            7   14     7           q  Ljava/lang/Object;
    Signature: <B:Ljava/lang/Object;>(TB;Lcom/datastax/oss/protocol/internal/Message;Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;)V
    MethodParameters:
         Name  Flags
      dest     
      message  
      encoder  

  public int encodedSize(com.datastax.oss.protocol.internal.Message);
    descriptor: (Lcom/datastax/oss/protocol/internal/Message;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=7, args_size=2
        start local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
        start local 1 // com.datastax.oss.protocol.internal.Message message
         0: .line 162
            aload 1 /* message */
            checkcast com.datastax.oss.protocol.internal.request.Batch
            astore 2 /* batch */
        start local 2 // com.datastax.oss.protocol.internal.request.Batch batch
         1: .line 163
            iconst_1
            istore 3 /* size */
        start local 3 // int size
         2: .line 164
            iinc 3 /* size */ 2
         3: .line 166
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.queriesOrIds:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            istore 4 /* queryCount */
        start local 4 // int queryCount
         4: .line 168
            iload 4 /* queryCount */
            ldc 65535
            if_icmpgt 5
            iconst_1
            goto 6
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch int int
      StackMap stack:
         5: iconst_0
      StackMap locals:
      StackMap stack: int
         6: ldc "Batch messages can contain at most %d queries"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            ldc 65535
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
         7: .line 167
            invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
         8: .line 170
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.values:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            iload 4 /* queryCount */
            if_icmpne 9
            iconst_1
            goto 10
      StackMap locals:
      StackMap stack:
         9: iconst_0
        10: .line 171
      StackMap locals:
      StackMap stack: int
            ldc "Batch contains %d queries but %d value lists"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
        11: .line 172
            iload 4 /* queryCount */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
        12: .line 173
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.values:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
        13: .line 169
            invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
        14: .line 175
            iconst_0
            istore 5 /* i */
        start local 5 // int i
        15: goto 25
        16: .line 176
      StackMap locals: int
      StackMap stack:
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.queriesOrIds:Ljava/util/List;
            iload 5 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            astore 6 /* q */
        start local 6 // java.lang.Object q
        17: .line 177
            iload 3 /* size */
        18: .line 178
            iconst_1
        19: .line 179
            aload 6 /* q */
            instanceof java.lang.String
            ifeq 21
        20: .line 180
            aload 6 /* q */
            checkcast java.lang.String
            invokestatic com.datastax.oss.protocol.internal.PrimitiveSizes.sizeOfLongString:(Ljava/lang/String;)I
            goto 22
        21: .line 181
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch$Codec com.datastax.oss.protocol.internal.Message com.datastax.oss.protocol.internal.request.Batch int int int java.lang.Object
      StackMap stack: int int
            aload 6 /* q */
            checkcast byte[]
            invokestatic com.datastax.oss.protocol.internal.PrimitiveSizes.sizeOfShortBytes:([B)I
        22: .line 178
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch$Codec com.datastax.oss.protocol.internal.Message com.datastax.oss.protocol.internal.request.Batch int int int java.lang.Object
      StackMap stack: int int int
            iadd
            iadd
            istore 3 /* size */
        23: .line 183
            iload 3 /* size */
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.values:Ljava/util/List;
            iload 5 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast java.util.List
            invokestatic com.datastax.oss.protocol.internal.request.query.Values.sizeOfPositionalValues:(Ljava/util/List;)I
            iadd
            istore 3 /* size */
        end local 6 // java.lang.Object q
        24: .line 175
            iinc 5 /* i */ 1
      StackMap locals:
      StackMap stack:
        25: iload 5 /* i */
            iload 4 /* queryCount */
            if_icmplt 16
        end local 5 // int i
        26: .line 185
            iinc 3 /* size */ 2
        27: .line 186
            iload 3 /* size */
            aload 0 /* this */
            getfield com.datastax.oss.protocol.internal.request.Batch$Codec.protocolVersion:I
            iconst_5
            if_icmplt 28
            iconst_4
            goto 29
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch$Codec com.datastax.oss.protocol.internal.Message com.datastax.oss.protocol.internal.request.Batch int int
      StackMap stack: int
        28: iconst_1
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch$Codec com.datastax.oss.protocol.internal.Message com.datastax.oss.protocol.internal.request.Batch int int
      StackMap stack: int int
        29: iadd
            istore 3 /* size */
        30: .line 187
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            bipush 16
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 32
        31: .line 188
            iinc 3 /* size */ 2
        32: .line 190
      StackMap locals:
      StackMap stack:
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            bipush 32
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 34
        33: .line 191
            iinc 3 /* size */ 8
        34: .line 193
      StackMap locals:
      StackMap stack:
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            sipush 128
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 36
        35: .line 194
            iload 3 /* size */
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.keyspace:Ljava/lang/String;
            invokestatic com.datastax.oss.protocol.internal.PrimitiveSizes.sizeOfString:(Ljava/lang/String;)I
            iadd
            istore 3 /* size */
        36: .line 196
      StackMap locals:
      StackMap stack:
            aload 2 /* batch */
            getfield com.datastax.oss.protocol.internal.request.Batch.flags:I
            sipush 256
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 38
        37: .line 197
            iinc 3 /* size */ 4
        38: .line 199
      StackMap locals:
      StackMap stack:
            iload 3 /* size */
            ireturn
        end local 4 // int queryCount
        end local 3 // int size
        end local 2 // com.datastax.oss.protocol.internal.request.Batch batch
        end local 1 // com.datastax.oss.protocol.internal.Message message
        end local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   39     0        this  Lcom/datastax/oss/protocol/internal/request/Batch$Codec;
            0   39     1     message  Lcom/datastax/oss/protocol/internal/Message;
            1   39     2       batch  Lcom/datastax/oss/protocol/internal/request/Batch;
            2   39     3        size  I
            4   39     4  queryCount  I
           15   26     5           i  I
           17   24     6           q  Ljava/lang/Object;
    MethodParameters:
         Name  Flags
      message  

  public <B> com.datastax.oss.protocol.internal.Message decode(B, com.datastax.oss.protocol.internal.PrimitiveCodec<B>);
    descriptor: (Ljava/lang/Object;Lcom/datastax/oss/protocol/internal/PrimitiveCodec;)Lcom/datastax/oss/protocol/internal/Message;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=12, locals=14, args_size=3
        start local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
        start local 1 // java.lang.Object source
        start local 2 // com.datastax.oss.protocol.internal.PrimitiveCodec decoder
         0: .line 204
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readByte:(Ljava/lang/Object;)B
            istore 3 /* type */
        start local 3 // byte type
         1: .line 205
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readUnsignedShort:(Ljava/lang/Object;)I
            istore 4 /* queryCount */
        start local 4 // int queryCount
         2: .line 207
            iload 4 /* queryCount */
            invokestatic com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList.builder:(I)Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList$Builder;
         3: .line 206
            astore 5 /* queriesOrIds */
        start local 5 // com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder queriesOrIds
         4: .line 209
            iload 4 /* queryCount */
            invokestatic com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList.builder:(I)Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList$Builder;
         5: .line 208
            astore 6 /* values */
        start local 6 // com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder values
         6: .line 210
            iconst_0
            istore 7 /* i */
        start local 7 // int i
         7: goto 17
         8: .line 211
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch$Codec java.lang.Object com.datastax.oss.protocol.internal.PrimitiveCodec int int com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder int
      StackMap stack:
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readByte:(Ljava/lang/Object;)B
            ifne 9
            iconst_1
            goto 10
      StackMap locals:
      StackMap stack:
         9: iconst_0
      StackMap locals:
      StackMap stack: int
        10: istore 8 /* isQueryString */
        start local 8 // boolean isQueryString
        11: .line 212
            aload 5 /* queriesOrIds */
        12: .line 213
            iload 8 /* isQueryString */
            ifeq 13
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readLongString:(Ljava/lang/Object;)Ljava/lang/String;
            goto 14
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch$Codec java.lang.Object com.datastax.oss.protocol.internal.PrimitiveCodec int int com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder int int
      StackMap stack: com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder
        13: aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readShortBytes:(Ljava/lang/Object;)[B
        14: .line 212
      StackMap locals: com.datastax.oss.protocol.internal.request.Batch$Codec java.lang.Object com.datastax.oss.protocol.internal.PrimitiveCodec int int com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder int int
      StackMap stack: com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder java.io.Serializable
            invokevirtual com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder.add:(Ljava/lang/Object;)Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList$Builder;
            pop
        15: .line 214
            aload 6 /* values */
            aload 1 /* source */
            aload 2 /* decoder */
            invokestatic com.datastax.oss.protocol.internal.request.query.Values.readPositionalValues:(Ljava/lang/Object;Lcom/datastax/oss/protocol/internal/PrimitiveCodec;)Ljava/util/List;
            invokevirtual com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder.add:(Ljava/lang/Object;)Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList$Builder;
            pop
        end local 8 // boolean isQueryString
        16: .line 210
            iinc 7 /* i */ 1
      StackMap locals:
      StackMap stack:
        17: iload 7 /* i */
            iload 4 /* queryCount */
            if_icmplt 8
        end local 7 // int i
        18: .line 216
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readUnsignedShort:(Ljava/lang/Object;)I
            istore 7 /* consistency */
        start local 7 // int consistency
        19: .line 218
            aload 0 /* this */
            getfield com.datastax.oss.protocol.internal.request.Batch$Codec.protocolVersion:I
            iconst_5
            if_icmplt 21
        20: .line 219
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readInt:(Ljava/lang/Object;)I
            goto 22
        21: .line 220
      StackMap locals:
      StackMap stack:
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readByte:(Ljava/lang/Object;)B
        22: .line 217
      StackMap locals:
      StackMap stack: int
            istore 8 /* flags */
        start local 8 // int flags
        23: .line 222
            iload 8 /* flags */
            bipush 16
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 25
        24: .line 223
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readUnsignedShort:(Ljava/lang/Object;)I
            goto 26
        25: .line 224
      StackMap locals: int
      StackMap stack:
            bipush 8
        26: .line 221
      StackMap locals:
      StackMap stack: int
            istore 9 /* serialConsistency */
        start local 9 // int serialConsistency
        27: .line 226
            iload 8 /* flags */
            bipush 32
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 29
        28: .line 227
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readLong:(Ljava/lang/Object;)J
            goto 30
        29: .line 228
      StackMap locals: int
      StackMap stack:
            ldc -9223372036854775808
        30: .line 225
      StackMap locals:
      StackMap stack: long
            lstore 10 /* defaultTimestamp */
        start local 10 // long defaultTimestamp
        31: .line 230
            iload 8 /* flags */
            sipush 128
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 33
        32: .line 231
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readString:(Ljava/lang/Object;)Ljava/lang/String;
            goto 34
        33: .line 232
      StackMap locals: long
      StackMap stack:
            aconst_null
        34: .line 229
      StackMap locals:
      StackMap stack: java.lang.String
            astore 12 /* keyspace */
        start local 12 // java.lang.String keyspace
        35: .line 234
            iload 8 /* flags */
            sipush 256
            invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
            ifeq 37
        36: .line 235
            aload 2 /* decoder */
            aload 1 /* source */
            invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readInt:(Ljava/lang/Object;)I
            goto 38
        37: .line 236
      StackMap locals: java.lang.String
      StackMap stack:
            ldc -2147483648
        38: .line 233
      StackMap locals:
      StackMap stack: int
            istore 13 /* nowInSeconds */
        start local 13 // int nowInSeconds
        39: .line 238
            new com.datastax.oss.protocol.internal.request.Batch
            dup
        40: .line 239
            iload 8 /* flags */
        41: .line 240
            iload 3 /* type */
        42: .line 241
            aload 5 /* queriesOrIds */
            invokevirtual com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder.build:()Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList;
        43: .line 242
            aload 6 /* values */
            invokevirtual com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder.build:()Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList;
        44: .line 243
            iload 7 /* consistency */
        45: .line 244
            iload 9 /* serialConsistency */
        46: .line 245
            lload 10 /* defaultTimestamp */
        47: .line 246
            aload 12 /* keyspace */
        48: .line 247
            iload 13 /* nowInSeconds */
        49: .line 238
            invokespecial com.datastax.oss.protocol.internal.request.Batch.<init>:(IBLjava/util/List;Ljava/util/List;IIJLjava/lang/String;I)V
            areturn
        end local 13 // int nowInSeconds
        end local 12 // java.lang.String keyspace
        end local 10 // long defaultTimestamp
        end local 9 // int serialConsistency
        end local 8 // int flags
        end local 7 // int consistency
        end local 6 // com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder values
        end local 5 // com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder queriesOrIds
        end local 4 // int queryCount
        end local 3 // byte type
        end local 2 // com.datastax.oss.protocol.internal.PrimitiveCodec decoder
        end local 1 // java.lang.Object source
        end local 0 // com.datastax.oss.protocol.internal.request.Batch$Codec this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   50     0               this  Lcom/datastax/oss/protocol/internal/request/Batch$Codec;
            0   50     1             source  TB;
            0   50     2            decoder  Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;
            1   50     3               type  B
            2   50     4         queryCount  I
            4   50     5       queriesOrIds  Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList$Builder<Ljava/lang/Object;>;
            6   50     6             values  Lcom/datastax/oss/protocol/internal/util/collection/NullAllowingImmutableList$Builder<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
            7   18     7                  i  I
           11   16     8      isQueryString  Z
           19   50     7        consistency  I
           23   50     8              flags  I
           27   50     9  serialConsistency  I
           31   50    10   defaultTimestamp  J
           35   50    12           keyspace  Ljava/lang/String;
           39   50    13       nowInSeconds  I
    Signature: <B:Ljava/lang/Object;>(TB;Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;)Lcom/datastax/oss/protocol/internal/Message;
    MethodParameters:
         Name  Flags
      source   
      decoder  
}
SourceFile: "Batch.java"
NestHost: com.datastax.oss.protocol.internal.request.Batch
InnerClasses:
  public abstract Codec = com.datastax.oss.protocol.internal.Message$Codec of com.datastax.oss.protocol.internal.Message
  public Codec = com.datastax.oss.protocol.internal.request.Batch$Codec of com.datastax.oss.protocol.internal.request.Batch
  public Builder = com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList$Builder of com.datastax.oss.protocol.internal.util.collection.NullAllowingImmutableList