如何在 Ambari 中安装 hadoop写入其他集群es 的插件

在 Ambari 中安装 Hadoop 写入其他集群的 Elasticsearch 插件，可以按照以下步骤进行：

1. 打开 Ambari 管理控制台，并选择要安装插件的集群。

2. 在“服务”页面中，选择 Hadoop 的 Elasticsearch 插件，例如“Elasticsearch Hadoop”。

3. 点击“添加服务”按钮，并选择“Elasticsearch Hadoop”。

4. 在“分配主机”页面中，选择要安装插件的主机，并为其分配必要的资源。如果要将插件安装到多台主机上，需要在此页面中分别进行配置。

5. 在“自定义服务”页面中，根据需要配置插件的参数，例如 Elasticsearch 集群的主机和端口号、索引名称、数据分片等。

6. 点击“下一步”按钮，等待 Ambari 安装插件。

7. 安装完成后，在“服务”页面中启动插件。

8. 在 Hadoop 中编写代码，将数据写入到其他集群的 Elasticsearch 中。例如，在 MapReduce 程序中可以使用以下代码：

Job job = Job.getInstance();
job.setOutputFormatClass(EsOutputFormat.class);
job.setOutputKeyClass(NullWritable.class);
job.setOutputValueClass(MapWritable.class);
job.setMapperClass(MyMapper.class);
EsOutputFormat.setOutput(job, "es.nodes", "other_cluster_host:9200");
EsOutputFormat.setOutput(job, "es.resource", "index_name/type_name");

其中，`other_cluster_host` 是其他集群 Elasticsearch 的主机名或 IP 地址，`9200` 是 Elasticsearch 的端口号，`index_name` 是要写入的索引名称，`type_name` 是索引的类型名称。

这样就完成了在 Ambari 中安装 Hadoop 写入其他集群 Elasticsearch 的插件的过程。需要注意的是，安装过程中需要根据实际情况进行参数配置，以满足自己的需求。同时，在编写程序时也需要根据具体的情况进行代码修改。