Package org.elasticsearch.hadoop.yarn.client

Examples of org.elasticsearch.hadoop.yarn.client.ClientRpc

144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
            throw new IllegalStateException(String.format("Cannot upload %s in HDFS at %s", src.getAbsolutePath(), dst), ex);
        }
    }

    private void start() {
        ClientRpc client = new ClientRpc(getConf());
        ApplicationId id = null;
        ApplicationReport report = null;

        try {
            YarnLauncher launcher = new YarnLauncher(client, cfg);
            id = launcher.run();
            report = client.getReport(id);
        } finally {
            client.close();
        }

        System.out.println(String.format("Launched a %d %s Elasticsearch-YARN cluster [%s@%s] at %tc",
                cfg.containersToAllocate(), (cfg.containersToAllocate() > 1 ? "nodes" : "node"), id, report.getTrackingUrl(), report.getStartTime()));
    }
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
        System.out.println(String.format("Launched a %d %s Elasticsearch-YARN cluster [%s@%s] at %tc",
                cfg.containersToAllocate(), (cfg.containersToAllocate() > 1 ? "nodes" : "node"), id, report.getTrackingUrl(), report.getStartTime()));
    }

    private void stop() {
        ClientRpc client = new ClientRpc(getConf());
        client.start();
        try {
            List<ApplicationReport> esApps = client.listEsClustersAlive();
            for (ApplicationReport report : esApps) {
                System.out.println(String.format("Stopping Elasticsearch-YARN Cluster with id %s", report.getApplicationId()));
            }
            List<ApplicationReport> apps = client.killEsApps();
            for (ApplicationReport report : apps) {
                System.out.println(String.format("Stopped Elasticsearch-YARN cluster with id %s", report.getApplicationId()));
            }
        } finally {
            client.close();
        }
    }
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
            client.close();
        }
    }

    private void status() {
        ClientRpc client = new ClientRpc(getConf());
        client.start();
        List<ApplicationReport> esApps = null;
        try {
            esApps = client.listEsClusters();
        } finally {
            client.close();
        }
        System.out.println(buildStatusReport(esApps));
    }
View Full Code Here
TOP

Related Classes of org.elasticsearch.hadoop.yarn.client.ClientRpc

  • org.apache.hadoop.yarn.api.records.ApplicationReport
  • org.apache.hadoop.yarn.api.records.YarnApplicationState
  • org.apache.hadoop.yarn.conf.YarnConfiguration
  • org.elasticsearch.hadoop.yarn.cli.YarnBootstrap
  • org.elasticsearch.hadoop.yarn.EsYarnException
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.