Как сделать вывод преобразователя hadoop обработанным собственным редуктором?
Теперь, когда преобразователь Hadoop выведет несколько блоков, он будет перенесен на новый узел, где работает редуктор. Несмотря на то, что узел, который выполняет преобразователь, также запускает редуктор, он не гарантирует, что его выходные блоки будут обрабатываться тем же локальным редуктором.
Но я должен заставить это работать так. Что мне нужно, так это сделать так, чтобы блоки, созданные с помощью выходных данных мапперов, обрабатывались только редуктором, работающим на том же узле.
Пожалуйста, помогите, чтобы дать мне несколько советов.