本文整理了Java中org.apache.hadoop.hbase.util.Bytes.toByteArrays()
方法的一些代码示例,展示了Bytes.toByteArrays()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bytes.toByteArrays()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.util.Bytes
类名称:Bytes
方法名:toByteArrays
暂无
代码示例来源:origin: apache/hbase
/**
* @param column operand
* @return A byte array of a byte array where first and only entry is
* <code>column</code>
*/
public static byte [][] toByteArrays(final String column) {
return toByteArrays(toBytes(column));
}
代码示例来源:origin: apache/hbase
.secureBulkLoadManager.setFsCreatedListener(fsCreatedListener);
testUtil.createTable(TABLE,FAMILY,Bytes.toByteArrays(SPLIT_ROWKEY));
代码示例来源:origin: co.cask.hbase/hbase
/**
* @param column operand
* @return A byte array of a byte array where first and only entry is
* <code>column</code>
*/
public static byte [][] toByteArrays(final String column) {
return toByteArrays(toBytes(column));
}
代码示例来源:origin: org.apache.hbase/hbase-common
/**
* @param column operand
* @return A byte array of a byte array where first and only entry is
* <code>column</code>
*/
public static byte [][] toByteArrays(final String column) {
return toByteArrays(toBytes(column));
}
代码示例来源:origin: com.aliyun.hbase/alihbase-common
/**
* @param column operand
* @return A byte array of a byte array where first and only entry is
* <code>column</code>
*/
public static byte [][] toByteArrays(final String column) {
return toByteArrays(toBytes(column));
}
代码示例来源:origin: harbby/presto-connectors
/**
* @param column operand
* @return A byte array of a byte array where first and only entry is
* <code>column</code>
*/
public static byte [][] toByteArrays(final String column) {
return toByteArrays(toBytes(column));
}
代码示例来源:origin: twitter/hraven
@Test
public void testSplitWithLimit() {
// source with more splits than the limit
byte[][] expectedResult = Bytes.toByteArrays(new String[] {"random", "stuff::"});
byte[][] splitResult = ByteUtil.split(source2, sep2, 2);
assertSplitResult(expectedResult, splitResult);
// source with fewer splits than the limit
expectedResult = Bytes.toByteArrays(new String[] {"random", "stuff", ""});
splitResult = ByteUtil.split(source2, sep2, 100);
assertSplitResult(expectedResult, splitResult);
// source with limit of 1
expectedResult = new byte[][] {source2};
splitResult = ByteUtil.split(source2, sep2, 1);
assertSplitResult(expectedResult, splitResult);
}
代码示例来源:origin: twitter/hraven
@Test
public void testSplit() {
// single byte separator
byte[][] expected1 = Bytes
.toByteArrays(new String[] { "abc", "bcd", "cde" });
byte[][] splitresult = ByteUtil.split(source1, sep1);
assertSplitResult(expected1, splitresult);
// multi-byte separator, plus trailing separator
byte[][] expected2 = Bytes.toByteArrays(new String[] { "random", "stuff",
"" });
splitresult = ByteUtil.split(source2, sep2);
assertSplitResult(expected2, splitresult);
// leading and trailing separator
byte[][] expected3 = Bytes.toByteArrays(new String[] { "", "more", "stuff",
"" });
splitresult = ByteUtil.split(source3, sep3);
assertSplitResult(expected3, splitresult);
// source with no separator
byte[][] expected4 = Bytes.toByteArrays(new String[] { "singlesource" });
splitresult = ByteUtil.split(source4, sep4);
assertSplitResult(expected4, splitresult);
// source with empty component
byte[][] expected5 =
Bytes.toByteArrays(new String[]{ "abc", "", "bcd"});
splitresult = ByteUtil.split(source5, sep5);
assertSplitResult(expected5, splitresult);
byte[][] expected6 = new byte[][] {source6};
splitresult = ByteUtil.split(source6, sep6);
assertSplitResult(expected6, splitresult);
}
代码示例来源:origin: org.apache.hbase/hbase-server
.secureBulkLoadManager.setFsCreatedListener(fsCreatedListener);
testUtil.createTable(TABLE,FAMILY,Bytes.toByteArrays(SPLIT_ROWKEY));
内容来源于网络,如有侵权,请联系作者删除!