ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [3/4] incubator-ignite git commit: [IGNITE-218] workable version
Date Tue, 14 Apr 2015 14:04:40 GMT
[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 <iveselovskiy@gridgain.com>
Authored: Tue Apr 14 16:58:07 2015 +0300
Committer: iveselovskiy <iveselovskiy@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();
-////    }
-//}


Mime
View raw message