本文整理了Java中org.apache.hadoop.hbase.util.Base64.decode()
方法的一些代码示例,展示了Base64.decode()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Base64.decode()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.util.Base64
类名称:Base64
方法名:decode
[英]Decodes data from Base64 notation, automatically detecting gzip-compressed data and decompressing it.
[中]对Base64符号中的数据进行解码,自动检测gzip压缩数据并对其进行解压缩。
代码示例来源:origin: forcedotcom/phoenix
@Override
public Object toObject(String value) {
if (value == null || value.length() == 0) {
return null;
}
return Base64.decode(value);
}
代码示例来源:origin: forcedotcom/phoenix
@Override
public Object toObject(String value) {
if (value == null || value.length() == 0) {
return null;
}
return Base64.decode(value);
}
代码示例来源:origin: com.aliyun.hbase/alihbase-common
/**
* Decodes data from Base64 notation, automatically detecting gzip-compressed
* data and decompressing it.
*
* @param s the string to decode
* @return the decoded data
* @since 1.4
*/
public static byte[] decode(String s) {
return decode(s, NO_OPTIONS);
}
代码示例来源:origin: co.cask.hbase/hbase
/**
* Decodes data from Base64 notation, automatically detecting gzip-compressed
* data and decompressing it.
*
* @param s the string to decode
* @return the decoded data
* @since 1.4
*/
public static byte[] decode(String s) {
return decode(s, NO_OPTIONS);
}
代码示例来源:origin: harbby/presto-connectors
/**
* Decodes data from Base64 notation, automatically detecting gzip-compressed
* data and decompressing it.
*
* @param s the string to decode
* @return the decoded data
* @since 1.4
*/
public static byte[] decode(String s) {
return decode(s, NO_OPTIONS);
}
代码示例来源:origin: org.apache.phoenix/phoenix-core
public static byte[] getIndexMaintainers(final Configuration configuration){
Preconditions.checkNotNull(configuration);
return Base64.decode(configuration.get(INDEX_MAINTAINERS));
}
代码示例来源:origin: org.apache.phoenix/phoenix-core
@VisibleForTesting
static Character getCharacter(Configuration conf, String confKey) {
String strValue = conf.get(confKey);
if (strValue == null) {
return null;
}
return new String(Base64.decode(strValue)).charAt(0);
}
代码示例来源:origin: co.cask.hbase/hbase
private static byte[] getKeyFromConf(Configuration conf,
String base64Key, String deprecatedKey) {
String encoded = conf.get(base64Key);
if (encoded != null) {
return Base64.decode(encoded);
}
String oldStyleVal = conf.get(deprecatedKey);
if (oldStyleVal == null) {
return null;
}
LOG.warn("Using deprecated configuration " + deprecatedKey +
" - please use static accessor methods instead.");
return Bytes.toBytes(oldStyleVal);
}
代码示例来源:origin: org.apache.phoenix/phoenix-core
@Override
public Object toObject(String value) {
if (value == null || value.length() == 0) {
return null;
}
Object object = Base64.decode(value);
if (object == null) { throw newIllegalDataException(
"Input: [" + value + "] is not base64 encoded"); }
return object;
}
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
private static byte[] getKeyFromConf(Configuration conf,
String base64Key, String deprecatedKey) {
String encoded = conf.get(base64Key);
if (encoded != null) {
return Base64.decode(encoded);
}
String oldStyleVal = conf.get(deprecatedKey);
if (oldStyleVal == null) {
return null;
}
LOG.warn("Using deprecated configuration " + deprecatedKey +
" - please use static accessor methods instead.");
return Bytes.toBytesBinary(oldStyleVal);
}
代码示例来源:origin: co.cask.hbase/hbase
/**
* Converts the given Base64 string back into a Scan instance.
*
* @param base64 The scan details.
* @return The newly created Scan instance.
* @throws IOException When reading the scan instance fails.
*/
static Scan convertStringToScan(String base64) throws IOException {
ByteArrayInputStream bis = new ByteArrayInputStream(Base64.decode(base64));
DataInputStream dis = new DataInputStream(bis);
Scan scan = new Scan();
scan.readFields(dis);
return scan;
}
代码示例来源:origin: harbby/presto-connectors
private static byte[] getKeyFromConf(Configuration conf,
String base64Key, String deprecatedKey) {
String encoded = conf.get(base64Key);
if (encoded != null) {
return Base64.decode(encoded);
}
String oldStyleVal = conf.get(deprecatedKey);
if (oldStyleVal == null) {
return null;
}
LOG.warn("Using deprecated configuration " + deprecatedKey +
" - please use static accessor methods instead.");
return Bytes.toBytes(oldStyleVal);
}
代码示例来源:origin: harbby/presto-connectors
/**
* Handles common parameter initialization that a subclass might want to leverage.
* @param context
*/
protected void doSetup(Context context) {
Configuration conf = context.getConfiguration();
// If a custom separator has been used,
// decode it back from Base64 encoding.
separator = conf.get(ImportTsv.SEPARATOR_CONF_KEY);
if (separator == null) {
separator = ImportTsv.DEFAULT_SEPARATOR;
} else {
separator = new String(Base64.decode(separator));
}
skipBadLines = context.getConfiguration().getBoolean(ImportTsv.SKIP_LINES_CONF_KEY, true);
badLineCount = context.getCounter("ImportTsv", "Bad Lines");
}
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
/**
* Handles common parameter initialization that a subclass might want to leverage.
* @param context
*/
protected void doSetup(Context context) {
Configuration conf = context.getConfiguration();
// If a custom separator has been used,
// decode it back from Base64 encoding.
separator = conf.get(ImportTsv.SEPARATOR_CONF_KEY);
if (separator == null) {
separator = ImportTsv.DEFAULT_SEPARATOR;
} else {
separator = new String(Base64.decode(separator));
}
skipBadLines = context.getConfiguration().getBoolean(ImportTsv.SKIP_LINES_CONF_KEY, true);
logBadLines = context.getConfiguration().getBoolean(ImportTsv.LOG_BAD_LINES_CONF_KEY, false);
badLineCount = context.getCounter("ImportTsv", "Bad Lines");
}
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
/**
* Converts the given Base64 string back into a Scan instance.
*
* @param base64 The scan details.
* @return The newly created Scan instance.
* @throws IOException When reading the scan instance fails.
*/
public static Scan convertStringToScan(String base64) throws IOException {
byte [] decoded = Base64.decode(base64);
return ProtobufUtil.toScan(ClientProtos.Scan.parseFrom(decoded));
}
代码示例来源:origin: sematext/HBaseHUT
/**
* Converts the given Base64 string back into a UpdateProcessor instance.
*
* @param upClassName The updateProcessor class name.
* @param base64 The updateProcessor details.
* @return The newly created updateProcessor instance.
* @throws java.io.IOException When reading the updateProcessor instance fails.
*/
static UpdateProcessor convertStringToUpdateProcessor(String upClassName, String base64)
throws IOException {
UpdateProcessor up = createInstance(upClassName, UpdateProcessor.class);
if (base64 != null) {
ByteArrayInputStream bis = new ByteArrayInputStream(Base64.decode(base64));
DataInputStream dis = new DataInputStream(bis);
up.readFields(dis);
}
return up;
}
代码示例来源:origin: org.apache.crunch/crunch-hbase
public static Scan convertStringToScan(String string) throws IOException {
ClientProtos.Scan proto = ClientProtos.Scan.parseFrom(Base64.decode(string));
return ProtobufUtil.toScan(proto);
}
代码示例来源:origin: com.aliyun.hbase/alihbase-rest
protected T fromPB(String pb) throws
Exception {
return (T)clazz.getMethod("getObjectFromMessage", byte[].class).invoke(
clazz.getDeclaredConstructor().newInstance(),
Base64.decode(AS_PB));
}
代码示例来源:origin: harbby/presto-connectors
/**
* Converts the given Base64 string back into a Scan instance.
*
* @param base64 The scan details.
* @return The newly created Scan instance.
* @throws IOException When reading the scan instance fails.
*/
static Scan convertStringToScan(String base64) throws IOException {
byte [] decoded = Base64.decode(base64);
ClientProtos.Scan scan;
try {
scan = ClientProtos.Scan.parseFrom(decoded);
} catch (InvalidProtocolBufferException ipbe) {
throw new IOException(ipbe);
}
return ProtobufUtil.toScan(scan);
}
代码示例来源:origin: mozilla-metrics/akela
/**
* Converts base64 scans string back into a Scan array
* @param base64
* @return
* @throws IOException
*/
public static Scan[] convertStringToScanArray(final String base64) throws IOException {
final DataInputStream dis = new DataInputStream(new ByteArrayInputStream(Base64.decode(base64)));
ArrayWritable aw = new ArrayWritable(Scan.class);
aw.readFields(dis);
Writable[] writables = aw.get();
Scan[] scans = new Scan[writables.length];
for (int i=0; i < writables.length; i++) {
scans[i] = (Scan)writables[i];
}
return scans;
}
内容来源于网络,如有侵权,请联系作者删除!