Package org.apache.hadoop.hive.common.type

Examples of org.apache.hadoop.hive.common.type.Decimal128


            dv.noNulls = false;
            dv.isNull[0] = true;
            dv.isRepeating = true;
          } else {
            HiveDecimal hd = (HiveDecimal)(value);
            dv.vector[0] = new Decimal128(hd.toString(), (short)hd.scale());
            dv.isRepeating = true;
            dv.isNull[0] = false;     
          }
        }
        break;
View Full Code Here


    Decimal128[] vector = inputColVector.vector;
    Decimal128[] outputVector = outputColVector.vector;

    // Initialize local variable to use as 0 value on first use.
    if (zero == null) {
      this.zero = new Decimal128(0, inputColVector.scale);
    }

    // return immediately if batch is empty
    if (n == 0) {
      return;
View Full Code Here

    Decimal128[] vector = inputColVector.vector;
    Decimal128[] outputVector = outputColVector.vector;

    // Initialize local variable to use as 0 value on first use.
    if (zero == null) {
      this.zero = new Decimal128(0, inputColVector.scale);
    }

    // return immediately if batch is empty
    if (n == 0) {
      return;
View Full Code Here

          aggregationBufferSets,
          aggregateIndex,
          j);
        int i = selected[j];
        if (!isNull[i]) {
          Decimal128 value = vector[i];
          myagg.updateValueWithCheckAndInit(value, scale);
        }
      }
    }
View Full Code Here

      for (int i=0; i< batchSize; ++i) {
        Aggregation myagg = getCurrentAggregationBuffer(
          aggregationBufferSets,
          aggregateIndex,
          i);
        Decimal128 value = vector[selected[i]];
        myagg.updateValueWithCheckAndInit(value, scale);
      }
    }
View Full Code Here

        if (!isNull[i]) {
          Aggregation myagg = getCurrentAggregationBuffer(
            aggregationBufferSets,
            aggregateIndex,
          i);
          Decimal128 value = vector[i];
          myagg.updateValueWithCheckAndInit(value, scale);
        }
      }
    }
View Full Code Here

      for (int i=0; i<batchSize; ++i) {
        Aggregation myagg = getCurrentAggregationBuffer(
          aggregationBufferSets,
          aggregateIndex,
          i);
        Decimal128 value = vector[i];
        myagg.updateValueWithCheckAndInit(value, scale);
      }
    }
View Full Code Here

        int[] selected) {

      for (int j=0; j< batchSize; ++j) {
        int i = selected[j];
        if (!isNull[i]) {
          Decimal128 value = vector[i];
          myagg.updateValueWithCheckAndInit(value, scale);
        }
      }
    }
View Full Code Here

      if (myagg.isNull) {
        myagg.init ();
      }

      Decimal128 value = vector[selected[0]];
      myagg.updateValueWithCheckAndInit(value, scale);

      // i=0 was pulled out to remove the count > 1 check in the loop
      //
      for (int i=1; i< batchSize; ++i) {
View Full Code Here

        int batchSize,
        boolean[] isNull) {

      for(int i=0;i<batchSize;++i) {
        if (!isNull[i]) {
          Decimal128 value = vector[i];
          myagg.updateValueWithCheckAndInit(value, scale);
        }
      }
    }
View Full Code Here

TOP

Related Classes of org.apache.hadoop.hive.common.type.Decimal128

Copyright © 2018 www.massapicom. 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.