- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
谁能告诉我在 Hadoop 中(在映射阶段)将 BytesWritable 类型转换为 InputStream 的最佳方法?我有使用 InputStream 类型的适当方法,我想在我的 MR 程序中使用它。
谢谢!
最佳答案
在下面的代码中,您可以看到字节数组是如何转换为输入流的。现在要获取字节数组,您可以使用 BytesWritable get bytes 获取字节数组的方法。在获取字节数组后,您可以在映射器中使用上述代码逻辑来获取输入流。我希望能回答您的查询。所以我认为这可能是我可以建议的最佳方法之一。
您好,我想您可以检查以下代码:-
public class ByteArrToInputStream {
public static void main(String a[]){
String str = "converting to input stream";
byte[] content = str.getBytes();
int size = content.length;
InputStream is = null;
byte[] b = new byte[size];
try {
is = new ByteArrayInputStream(content);
is.read(b);
System.out.println("Data Recovered: "+new String(b));
} catch (IOException e) {
e.printStackTrace();
} finally {
try{
if(is != null) is.close();
} catch (Exception ex){
}
}
}
关于hadoop - 在 Hadoop 中将 BytesWritable 类型转换为 InputStream,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19241842/
if (value instanceof BytesWritable) { BytesWritable b = (BytesWritable) value; byte[] bytes
我想使用 hadoop 示例 RandomWriter 进行基准测试并生成文件。键和值的类型都是 BytesWritable。那么我该如何使用 Spark 对这个文件进行排序呢?看来我不能直接调用 s
谁能帮我把 BytesWritable 转换成 byte[]。如果我使用值是 BytesWritable 的 value.getBytes(),我会得到额外的字节。 谢谢 最佳答案 您遇到的问题是 B
谁能告诉我在 Hadoop 中(在映射阶段)将 BytesWritable 类型转换为 InputStream 的最佳方法?我有使用 InputStream 类型的适当方法,我想在我的 MR 程序中使
我尝试了不同的方法来创建一个大型的 Hadoop SequenceFile只是一个短的(1GB)值(BytesWriteable)。 以下示例适用于开箱即用: https://svn.apache.o
我正在使用 hadoop 编写程序。我的问题代码如下(代码在映射器中): byte[] tmp = new byte[2]; tmp[0] = 0x01; tmp[1] = 0x02; BytesWr
我正在为 Generic UDF 自定义解压缩评估函数编写测试用例,该函数执行 zip 文件的解压缩。这个 jar 在 Hivequery 中使用。这里是测试用例的代码, public void te
我是一名优秀的程序员,十分优秀!