Repository: incubator-blur Updated Branches: refs/heads/console-v2 [created] 293bcb34a
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/11a2529a/contrib/blur-console/blur-agent/src/main/java/org/apache/blur/agent/collectors/hdfs/HdfsCollector.java ---------------------------------------------------------------------- diff --git a/contrib/blur-console/blur-agent/src/main/java/org/apache/blur/agent/collectors/hdfs/HdfsCollector.java b/contrib/blur-console/blur-agent/src/main/java/org/apache/blur/agent/collectors/hdfs/HdfsCollector.java deleted file mode 100644 index 431c796..0000000 --- a/contrib/blur-console/blur-agent/src/main/java/org/apache/blur/agent/collectors/hdfs/HdfsCollector.java +++ /dev/null @@ -1,79 +0,0 @@ -package org.apache.blur.agent.collectors.hdfs; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -import java.net.URI; -import java.net.URISyntaxException; -import java.util.List; - -import org.apache.blur.agent.Agent; -import org.apache.blur.agent.connections.hdfs.interfaces.HdfsDatabaseInterface; -import org.apache.blur.agent.exceptions.HdfsThreadException; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; - - -public class HdfsCollector implements Runnable { - private static final Log log = LogFactory.getLog(HdfsCollector.class); - - private final URI defaultUri; - private final String hdfsName; - private final String user; - private final HdfsDatabaseInterface databaseConnection; - private final boolean collectHdfs; - - public HdfsCollector(final String hdfsName, final String defaultUri, final String thriftUri, final String user, - final List<String> activeCollectors, final HdfsDatabaseInterface databaseConnection) throws HdfsThreadException { - try { - this.defaultUri = new URI(defaultUri); - this.hdfsName = hdfsName; - this.user = user; - this.databaseConnection = databaseConnection; - this.collectHdfs = activeCollectors.contains("hdfs"); - - initializeHdfs(hdfsName, thriftUri); - - } catch (URISyntaxException e) { - log.error(e.getMessage(), e); - throw new HdfsThreadException(); - } catch (Exception e) { - log.error("An unkown error occured while creating the collector.", e); - throw new HdfsThreadException(); - } - } - - @Override - public void run() { - while (true) { - if (this.collectHdfs) { - new Thread(new HdfsStatsCollector(this.hdfsName, defaultUri, this.user, this.databaseConnection), "Hdfs Collector - " - + this.hdfsName).start(); - } - - try { - Thread.sleep(Agent.COLLECTOR_SLEEP_TIME); - } catch (InterruptedException e) { - break; - } - } - } - - private void initializeHdfs(String name, String thriftUri) throws URISyntaxException { - URI parsedThriftUri = new URI(thriftUri); - this.databaseConnection.setHdfsInfo(name, parsedThriftUri.getHost(), parsedThriftUri.getPort()); - } -} \ No newline at end of file
