Hadoopストリーミングでは、特定のタスクを処理するノードのIDを取得する方法はありますか?
例えとして、このスニペットはタスクの入力ファイルの名前を示します。
#!/usr/bin/env python
import os
map_input_file = str(os.environ["map_input_file"])
os.environ["map_node_id"]のようなものを探しています。ノードへの一意のハンドルはすべて機能します...
Hadoopストリーミングでは、特定のタスクを処理するノードのIDを取得する方法はありますか?
例えとして、このスニペットはタスクの入力ファイルの名前を示します。
#!/usr/bin/env python
import os
map_input_file = str(os.environ["map_input_file"])
os.environ["map_node_id"]のようなものを探しています。ノードへの一意のハンドルはすべて機能します...