Examples of Varint

Examples of at.jku.sii.sqlitereader.io.AdvancedDataInput.Varint

17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
    this.columns = columns;
  }

  public static Record read(AdvancedAnnotatedDataInput in, DataBaseEncoding encoding) {
    int count = 0;
    Varint headerSize = in.readVarint("headerSize");
    count += headerSize.bytesUsed;

    ArrayList<RecordColumn> columns = new ArrayList<RecordColumn>();
    while (count < headerSize.value) {
      Varint next = in.readVarint();
      count += next.bytesUsed;
      final RecordColumn c = RecordColumns.create(next.value);
      columns.add(c);
      in.annotateLast(next.bytesUsed, "ColumnType", c.getSerialType(), c.getDescription());
    }
View Full Code Here

Examples of org.apache.mina.codec.delimited.ints.VarInt

36
37
38
39
40
41
42
    public static <L extends GeneratedMessage> ProtobufEncoder<L> newInstance(Class<L> clazz) {
        return new ProtobufEncoder<L>(clazz);
    }

    public ProtobufEncoder(Class<INPUT> clazz) {
        super(new VarInt().getEncoder(), ProtobufMessageEncoder.newInstance(clazz));
    }
View Full Code Here

Examples of org.apache.mina.codec.delimited.ints.VarInt

43
44
45
46
47
48
49
50
    return newInstance(clazz, ExtensionRegistryLite.getEmptyRegistry());
  }

  public ProtobufDecoder(Class<OUTPUT> clazz, ExtensionRegistryLite registry)
      throws NoSuchMethodException {
    super(new VarInt().getDecoder(), ProtobufMessageDecoder.newInstance(
        clazz, registry));
  }
View Full Code Here

Examples of org.apache.mina.codec.delimited.ints.VarInt

32
33
34
35
36
37
38
    public static <L extends GeneratedMessage> ProtobufDynamicDecoder newInstance() throws NoSuchMethodException {
        return new ProtobufDynamicDecoder();
    }

    public ProtobufDynamicDecoder() throws NoSuchMethodException {
        super(new VarInt().getDecoder(), ProtobufDynamicMessageDecoder.newInstance());
    }
View Full Code Here

Examples of org.apache.mina.codec.delimited.ints.VarInt

33
34
35
36
37
38
39
      throws NoSuchMethodException {
    return new ThriftDynamicDecoder();
  }

  public ThriftDynamicDecoder() throws NoSuchMethodException {
    super(new VarInt().getDecoder(), new ThriftDynamicMessageDecoder());
  }
View Full Code Here

Examples of org.apache.mina.codec.delimited.ints.VarInt

46
47
48
49
50
51
52
     * Construct an Avro Decoder
     *
     * @param schema            Avro Schema to be used
     */
    public AvroDecoder(Schema schema) {
        super(new VarInt().getDecoder(), new AvroMessageDecoder<T>(schema));
    }
View Full Code Here

Examples of org.apache.mina.codec.delimited.ints.VarInt

48
49
50
51
52
53
54
    /**
     * Intializes the Avro Encoder
     * Default Encoder are VarInt encoder for Size and {@link AvroEncoder} for Avro encoding
     */
    public AvroEncoder() {
        super(new VarInt().getEncoder(), new AvroMessageEncoder<T>());
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.