Hadoop streaming C++ getTaskId

Question

Я пытался найти способ получить (или передать) taskId моему картографу в C++. Я использую потоки хаопов. До сих пор я просто получил, как получить его на Java. Мне нужен идентификатор задачи, потому что я пытаюсь записать файл в HDFS, я использую libhdfs c, но когда я пытаюсь добавить одновременно, он терпит неудачу из-за аренды. В противном случае мне придется изменить весь мой код на Java.

Спасибо за внимание.

Answer 1

Я понял, что вместо использования Hadoop Streaming я мог бы использовать Hadoop Pipes для получения идентификатора taskID. Тем не менее, я не смог распечатать HDFS, поэтому я изменил свой InputFormat/RecordReader и использовал полученный в картотеке ключ для создания файлов с разными именами.