@Test(expected = IllegalArgumentException.class) public void testError() throws Exception { CubeDesc cubeDesc = CubeManager.getInstance(getTestConfig()).getCube("test_kylin_cube_with_slr_ready").getDescriptor(); HBaseColumnDesc hbaseCol = cubeDesc.getHbaseMapping().getColumnFamily()[0].getColumns()[0]; BufferedMeasureCodec codec = new BufferedMeasureCodec(hbaseCol.getMeasures()); BigDecimal sum = new BigDecimal("11111111111111111111333.1234567"); BigDecimal min = new BigDecimal("333.1111111"); BigDecimal max = new BigDecimal("333.1999999"); LongWritable count = new LongWritable(2); Long item_count = new Long(100); codec.encode(new Object[] { sum, min, max, count, item_count }); }
public MeasureDesc[] getMeasures() { return measures; }
RowValueDecoder implements Cloneable { public MeasureDesc[] getMeasures() { return measures; } }
RowValueDecoder implements Cloneable { public MeasureDesc[] getMeasures() { return measures; } RowValueDecoder(HBaseColumnDesc hbaseColumn); }
RowValueDecoder implements Cloneable { public MeasureDesc[] getMeasures() { return measures; } RowValueDecoder(HBaseColumnDesc hbaseColumn); void decodeAndConvertJavaObj(Result hbaseRow); void decode(Result hbaseRow); void decodeAndConvertJavaObj(byte[] bytes); void decode(byte[] bytes); void setProjectIndex(int bitIndex); BitSet getProjectionIndex(); HBaseColumnDesc getHBaseColumn(); Object[] getValues(); MeasureDesc[] getMeasures(); void loadCubeMeasureArray(Object[] result); boolean hasMemHungryMeasures(); static boolean hasMemHungryMeasures(Collection<RowValueDecoder> rowValueDecoders); }
RowValueDecoder implements Cloneable { public MeasureDesc[] getMeasures() { return measures; } RowValueDecoder(HBaseColumnDesc hbaseColumn); void decodeAndConvertJavaObj(Result hbaseRow); void decode(Result hbaseRow); void decodeAndConvertJavaObj(byte[] bytes); void decode(byte[] bytes); void setProjectIndex(int bitIndex); BitSet getProjectionIndex(); HBaseColumnDesc getHBaseColumn(); Object[] getValues(); MeasureDesc[] getMeasures(); void loadCubeMeasureArray(Object[] result); boolean hasMemHungryMeasures(); static boolean hasMemHungryMeasures(Collection<RowValueDecoder> rowValueDecoders);  }