开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 网格计算 > 查看源码
DFSLocation.java
资源名称：hadoop-0.20.0.tar.gz　[点击查看]
上传用户：quxuerui
上传日期：2018-01-08
资源大小：41811k
文件大小：3k
源码类别：

网格计算

开发平台：

Java

DFSLocation.java：源码内容
  1. /**
  2.  * Licensed to the Apache Software Foundation (ASF) under one
  3.  * or more contributor license agreements.  See the NOTICE file
  4.  * distributed with this work for additional information
  5.  * regarding copyright ownership.  The ASF licenses this file
  6.  * to you under the Apache License, Version 2.0 (the
  7.  * "License"); you may not use this file except in compliance
  8.  * with the License.  You may obtain a copy of the License at
  9.  *
  10.  *     http://www.apache.org/licenses/LICENSE-2.0
  11.  *
  12.  * Unless required by applicable law or agreed to in writing, software
  13.  * distributed under the License is distributed on an "AS IS" BASIS,
  14.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15.  * See the License for the specific language governing permissions and
  16.  * limitations under the License.
  17.  */
  19. package org.apache.hadoop.eclipse.dfs;
  21. import java.io.IOException;
  23. import org.apache.hadoop.eclipse.server.HadoopServer;
  24. import org.eclipse.core.runtime.IProgressMonitor;
  25. import org.eclipse.core.runtime.IStatus;
  26. import org.eclipse.core.runtime.Status;
  27. import org.eclipse.core.runtime.jobs.Job;
  29. /**
  30.  * DFS Content representation of a HDFS location
  31.  */
  32. public class DFSLocation implements DFSContent {
  34.   private final DFSContentProvider provider;
  36.   private final HadoopServer location;
  38.   private DFSContent rootFolder = null;
  40.   DFSLocation(DFSContentProvider provider, HadoopServer server) {
  41.     this.provider = provider;
  42.     this.location = server;
  43.   }
  45.   /* @inheritDoc */
  46.   @Override
  47.   public String toString() {
  48.     return this.location.getLocationName();
  49.   }
  51.   /*
  52.    * Implementation of DFSContent
  53.    */
  55.   /* @inheritDoc */
  56.   public DFSContent[] getChildren() {
  57.     if (this.rootFolder == null) {
  58.       /*
  59.        * DfsFolder constructor might block as it contacts the NameNode: work
  60.        * asynchronously here or this will potentially freeze the UI
  61.        */
  62.       new Job("Connecting to DFS " + location) {
  63.         @Override
  64.         protected IStatus run(IProgressMonitor monitor) {
  65.           try {
  66.             rootFolder = new DFSFolder(provider, location);
  67.             return Status.OK_STATUS;
  69.           } catch (IOException ioe) {
  70.             rootFolder =
  71.                 new DFSMessage("Error: " + ioe.getLocalizedMessage());
  72.             return Status.CANCEL_STATUS;
  74.           } finally {
  75.             // Under all circumstances, update the UI
  76.             provider.refresh(DFSLocation.this);
  77.           }
  78.         }
  79.       }.schedule();
  81.       return new DFSContent[] { new DFSMessage("Connecting to DFS "
  82.           + toString()) };
  83.     }
  84.     return new DFSContent[] { this.rootFolder };
  85.   }
  87.   /* @inheritDoc */
  88.   public boolean hasChildren() {
  89.     return true;
  90.   }
  91.   
  92.   /* @inheritDoc */
  93.   public void refresh() {
  94.     this.rootFolder = null;
  95.     this.provider.refresh(this);
  96.   }
  98.   /*
  99.    * Actions
  100.    */
  101.   
  102.   /**
  103.    * Refresh the location using a new connection
  104.    */
  105.   public void reconnect() {
  106.     this.refresh();
  107.   }
  108. }