integration/presto/src/main/prestodb/org/apache/carbondata/presto/readers/BooleanStreamReader.java [28:92]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class BooleanStreamReader extends CarbonColumnVectorImpl
    implements PrestoVectorBlockBuilder {

  protected int batchSize;

  protected Type type = BooleanType.BOOLEAN;

  protected BlockBuilder builder;

  public BooleanStreamReader(int batchSize, DataType dataType) {
    super(batchSize, dataType);
    this.batchSize = batchSize;
    this.builder = type.createBlockBuilder(null, batchSize);
  }

  @Override
  public Block buildBlock() {
    return builder.build();
  }

  @Override
  public void setBatchSize(int batchSize) {
    this.batchSize = batchSize;
  }

  @Override
  public void putByte(int rowId, byte value) {
    type.writeBoolean(builder, value == 1);
  }

  @Override
  public void putBytes(int rowId, int count, byte[] src, int srcIndex) {
    for (int i = 0; i < count; i++) {
      type.writeBoolean(builder, src[srcIndex++] == 1);
    }
  }

  @Override
  public void putBoolean(int rowId, boolean value) {
    type.writeBoolean(builder, value);
  }

  @Override
  public void putNull(int rowId) {
    builder.appendNull();
  }

  @Override
  public void putNulls(int rowId, int count) {
    for (int i = 0; i < count; i++) {
      builder.appendNull();
    }
  }

  @Override
  public void reset() {
    builder = type.createBlockBuilder(null, batchSize);
  }

  @Override
  public void putObject(int rowId, Object value) {
    if (value == null) {
      putNull(rowId);
    } else {
      putBoolean(rowId, (boolean) value);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



integration/presto/src/main/prestosql/org/apache/carbondata/presto/readers/BooleanStreamReader.java [28:92]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class BooleanStreamReader extends CarbonColumnVectorImpl
    implements PrestoVectorBlockBuilder {

  protected int batchSize;

  protected Type type = BooleanType.BOOLEAN;

  protected BlockBuilder builder;

  public BooleanStreamReader(int batchSize, DataType dataType) {
    super(batchSize, dataType);
    this.batchSize = batchSize;
    this.builder = type.createBlockBuilder(null, batchSize);
  }

  @Override
  public Block buildBlock() {
    return builder.build();
  }

  @Override
  public void setBatchSize(int batchSize) {
    this.batchSize = batchSize;
  }

  @Override
  public void putByte(int rowId, byte value) {
    type.writeBoolean(builder, value == 1);
  }

  @Override
  public void putBytes(int rowId, int count, byte[] src, int srcIndex) {
    for (int i = 0; i < count; i++) {
      type.writeBoolean(builder, src[srcIndex++] == 1);
    }
  }

  @Override
  public void putBoolean(int rowId, boolean value) {
    type.writeBoolean(builder, value);
  }

  @Override
  public void putNull(int rowId) {
    builder.appendNull();
  }

  @Override
  public void putNulls(int rowId, int count) {
    for (int i = 0; i < count; i++) {
      builder.appendNull();
    }
  }

  @Override
  public void reset() {
    builder = type.createBlockBuilder(null, batchSize);
  }

  @Override
  public void putObject(int rowId, Object value) {
    if (value == null) {
      putNull(rowId);
    } else {
      putBoolean(rowId, (boolean) value);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



