[IGNITE-218] workable version
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/23b32dde Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/23b32dde Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/23b32dde Branch: refs/heads/ignite-218 Commit: 23b32ddecbfef976ed9f746fb69006c33bc46911 Parents: 1634a68 Author: iveselovskiy <iveselovs...@gridgain.com> Authored: Tue Apr 14 16:58:07 2015 +0300 Committer: iveselovskiy <iveselovs...@gridgain.com> Committed: Tue Apr 14 16:58:07 2015 +0300 ---------------------------------------------------------------------- .../hadoop/fs/HadoopDistributedFileSystem.java | 108 ------------------- 1 file changed, 108 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/23b32dde/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/fs/HadoopDistributedFileSystem.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/fs/HadoopDistributedFileSystem.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/fs/HadoopDistributedFileSystem.java deleted file mode 100644 index 6204a2a..0000000 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/fs/HadoopDistributedFileSystem.java +++ /dev/null @@ -1,108 +0,0 @@ -///* -//* 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. -//*/ -// -//package org.apache.ignite.internal.processors.hadoop.fs; -// -//import org.apache.hadoop.conf.*; -//import org.apache.hadoop.fs.*; -//import org.apache.hadoop.hdfs.*; -//import org.apache.hadoop.security.*; -//import org.apache.ignite.internal.util.typedef.*; -// -//import java.io.*; -//import java.lang.reflect.*; -//import java.net.*; -// -//import static org.apache.ignite.configuration.FileSystemConfiguration.*; -//import static org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem.*; -// -///** -//* Wrapper of HDFS for support of separated working directory. -//*/ -//public class HadoopDistributedFileSystem extends DistributedFileSystem { -//// /** User name for each thread. */ -//// private final ThreadLocal<String> userName = new ThreadLocal<String>() { -//// /** {@inheritDoc} */ -//// @Override protected String initialValue() { -//// return DFLT_USER_NAME; -//// } -//// }; -//// -//// /** Working directory for each thread. */ -//// private final ThreadLocal<Path> workingDir = new ThreadLocal<Path>() { -//// /** {@inheritDoc} */ -//// @Override protected Path initialValue() { -//// return getHomeDirectory(); -//// } -//// }; -// -// /** {@inheritDoc} */ -// @Override public void initialize(URI uri, Configuration conf) throws IOException { -// super.initialize(uri, conf); -// -// //setUser(getHadoopUser(conf)); -// } -// -// /** -// * Set user name and default working directory for current thread. -// * -// * @param userName User name. -// */ -// @Deprecated -// public void setUser(String userName) { -// //System.out.println(this + ": ##### setting user = " + userName + ", thread = " + Thread.currentThread()); -// -// DFSClient dfsClient = getClient(); -// -// try { -// Field f = DFSClient.class.getDeclaredField("ugi"); -// f.setAccessible(true); -// UserGroupInformation ugi = (UserGroupInformation)f.get(dfsClient); -// assert F.eq(ugi.getShortUserName(), userName); -// } catch (Throwable t) { -// t.printStackTrace(); -// } -// -// //this.userName.set(userName); -// -// //setWorkingDirectory(getHomeDirectory()); -// } -// -//// /** {@inheritDoc} */ -//// @Override public Path getHomeDirectory() { -//// Path path = new Path("/user/" + userName.get()); -//// -//// return path.makeQualified(getUri(), null); -//// } -//// -//// /** {@inheritDoc} */ -//// @Override public void setWorkingDirectory(Path dir) { -//// Path fixedDir = fixRelativePart(dir); -//// -//// String res = fixedDir.toUri().getPath(); -//// -//// if (!DFSUtil.isValidName(res)) -//// throw new IllegalArgumentException("Invalid DFS directory name " + res); -//// -//// workingDir.set(fixedDir); -//// } -//// -//// /** {@inheritDoc} */ -//// @Override public Path getWorkingDirectory() { -//// return workingDir.get(); -//// } -//}
