本文整理汇总了Java中org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg类的典型用法代码示例。如果您正苦于以下问题:Java BigDecimalMsg类的具体用法?Java BigDecimalMsg怎么用?Java BigDecimalMsg使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
BigDecimalMsg类属于org.apache.hadoop.hbase.protobuf.generated.HBaseProtos包,在下文中一共展示了BigDecimalMsg类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testMaxWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMaxWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Scan scan = new Scan();
scan.setStartRow(ROWS[4]);
scan.setStopRow(ROWS[2]);
scan.addColumn(TEST_FAMILY, TEST_QUALIFIER);
BigDecimal max = new BigDecimal(Long.MIN_VALUE);
;
try {
max = aClient.max(TEST_TABLE, ci, scan);
} catch (Throwable e) {
max = BigDecimal.ZERO;
}
assertEquals(BigDecimal.ZERO, max);// control should go to the catch block
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:19,代码来源:TestBigDecimalColumnInterpreter.java
示例2: testMaxWithInvalidRange2
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMaxWithInvalidRange2() throws Throwable {
BigDecimal max = new BigDecimal(Long.MIN_VALUE);
Scan scan = new Scan();
scan.addColumn(TEST_FAMILY, TEST_QUALIFIER);
scan.setStartRow(ROWS[4]);
scan.setStopRow(ROWS[4]);
try {
AggregationClient aClient = new AggregationClient(conf);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
max = aClient.max(TEST_TABLE, ci, scan);
} catch (Exception e) {
max = BigDecimal.ZERO;
}
assertEquals(BigDecimal.ZERO, max);// control should go to the catch block
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:18,代码来源:TestBigDecimalColumnInterpreter.java
示例3: testMinWithValidRangeWithNullCF
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMinWithValidRangeWithNullCF() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.setStartRow(ROWS[5]);
scan.setStopRow(ROWS[15]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal min = null;
try {
min = aClient.min(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, min);// CP will throw an IOException about the
// null column family, and max will be set to 0
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例4: testMinWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMinWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
BigDecimal min = null;
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[4]);
scan.setStopRow(ROWS[2]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
try {
min = aClient.min(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, min);// control should go to the catch block
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例5: testMinWithInvalidRange2
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMinWithInvalidRange2() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[6]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal min = null;
try {
min = aClient.min(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, min);// control should go to the catch block
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例6: testSumWithValidRangeWithNullCF
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testSumWithValidRangeWithNullCF() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[7]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal sum = null;
try {
sum = aClient.sum(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, sum);// CP will throw an IOException about the
// null column family, and max will be set to 0
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例7: testSumWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testSumWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[2]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal sum = null;
try {
sum = aClient.sum(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, sum);// control should go to the catch block
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例8: testAvgWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testAvgWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addColumn(TEST_FAMILY, TEST_QUALIFIER);
scan.setStartRow(ROWS[5]);
scan.setStopRow(ROWS[1]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Double avg = null;
try {
avg = aClient.avg(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, avg);// control should go to the catch block
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例9: testStdWithValidRangeWithNullCF
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testStdWithValidRangeWithNullCF() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[17]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Double std = null;
try {
std = aClient.std(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, std);// CP will throw an IOException about the
// null column family, and max will be set to 0
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例10: testStdWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test
public void testStdWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[1]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Double std = null;
try {
std = aClient.std(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, std);// control should go to the catch block
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例11: testMaxWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMaxWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Scan scan = new Scan();
scan.setStartRow(ROWS[4]);
scan.setStopRow(ROWS[2]);
scan.addColumn(TEST_FAMILY, TEST_QUALIFIER);
BigDecimal max = new BigDecimal(Long.MIN_VALUE);
;
try {
max = aClient.max(TEST_TABLE, ci, scan);
} catch (Throwable e) {
max = BigDecimal.ZERO;
}
assertEquals(BigDecimal.ZERO, max);// control should go to the catch block
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:19,代码来源:TestBigDecimalColumnInterpreter.java
示例12: testMaxWithInvalidRange2
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMaxWithInvalidRange2() throws Throwable {
BigDecimal max = new BigDecimal(Long.MIN_VALUE);
Scan scan = new Scan();
scan.addColumn(TEST_FAMILY, TEST_QUALIFIER);
scan.setStartRow(ROWS[4]);
scan.setStopRow(ROWS[4]);
try {
AggregationClient aClient = new AggregationClient(conf);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
max = aClient.max(TEST_TABLE, ci, scan);
} catch (Exception e) {
max = BigDecimal.ZERO;
}
assertEquals(BigDecimal.ZERO, max);// control should go to the catch block
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:18,代码来源:TestBigDecimalColumnInterpreter.java
示例13: testMinWithValidRangeWithNullCF
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMinWithValidRangeWithNullCF() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.setStartRow(ROWS[5]);
scan.setStopRow(ROWS[15]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal min = null;
try {
min = aClient.min(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, min);// CP will throw an IOException about the
// null column family, and max will be set to 0
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例14: testMinWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMinWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
BigDecimal min = null;
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[4]);
scan.setStopRow(ROWS[2]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
try {
min = aClient.min(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, min);// control should go to the catch block
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例15: testMinWithInvalidRange2
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testMinWithInvalidRange2() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[6]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal min = null;
try {
min = aClient.min(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, min);// control should go to the catch block
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例16: testSumWithValidRangeWithNullCF
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testSumWithValidRangeWithNullCF() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[7]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal sum = null;
try {
sum = aClient.sum(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, sum);// CP will throw an IOException about the
// null column family, and max will be set to 0
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例17: testSumWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testSumWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[2]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
BigDecimal sum = null;
try {
sum = aClient.sum(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, sum);// control should go to the catch block
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例18: testAvgWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testAvgWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addColumn(TEST_FAMILY, TEST_QUALIFIER);
scan.setStartRow(ROWS[5]);
scan.setStopRow(ROWS[1]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Double avg = null;
try {
avg = aClient.avg(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, avg);// control should go to the catch block
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例19: testStdWithValidRangeWithNullCF
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test (timeout=300000)
public void testStdWithValidRangeWithNullCF() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[17]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Double std = null;
try {
std = aClient.std(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, std);// CP will throw an IOException about the
// null column family, and max will be set to 0
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
示例20: testStdWithInvalidRange
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg; //导入依赖的package包/类
@Test
public void testStdWithInvalidRange() {
AggregationClient aClient = new AggregationClient(conf);
Scan scan = new Scan();
scan.addFamily(TEST_FAMILY);
scan.setStartRow(ROWS[6]);
scan.setStopRow(ROWS[1]);
final ColumnInterpreter<BigDecimal, BigDecimal, EmptyMsg, BigDecimalMsg, BigDecimalMsg> ci =
new BigDecimalColumnInterpreter();
Double std = null;
try {
std = aClient.std(TEST_TABLE, ci, scan);
} catch (Throwable e) {
}
assertEquals(null, std);// control should go to the catch block
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:17,代码来源:TestBigDecimalColumnInterpreter.java
注:本文中的org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.BigDecimalMsg类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论