java - Hadoop在程序中的映射器中输入数据,而不是文件中的数据

标签 java hadoop

我正在尝试不要将文件用作Hadoop中的输入。我有我的Java程序,它会生成类似“鸡”,“10”的输出,并将它们存储在数组中,并且我希望将此条目直接提供给Mapper类。有谁知道如何将此类输入直接输入到Hadoop中而不使用文件作为输入?
非常感谢

最佳答案

您应该使用自己的扩展InputFormat<K,V>的类,并告诉hadoop作业使用此类而不是FileInputFormat。在此处查看documentation

关于java - Hadoop在程序中的映射器中输入数据,而不是文件中的数据,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8509695/

相关文章:

java - 什么是NullPointerException,我该如何解决?

java - onSensorChanged 在锁定屏幕 3 分钟后停止调用

hadoop - 可用于创建数据管道的不同工具

hadoop - 致命数据节点.DataNode : Exception in secureMain

scala - 在SPARK SQL中读取分区的HIVE表

java - 无法处理上下文配置的位置和类

JavaFX 2 : How to load stylesheet into a Scene subclass distributed as part of a library?

java - 错误 : No resource found that matches the given name (at 'title' with value '@string/menu_settings' )

hadoop - hive 在分区表上添加列不起作用

hadoop - Hive 数据存储在哪里?