incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cr...@apache.org
Subject [01/53] [partial] Initial commit of console v2. Sorry for the large commit
Date Mon, 17 Feb 2014 16:06:37 GMT
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


Mime
View raw message