@Test public void move_simple() throws Exception { touch("src/a.csv"); FileSystem fs = getTempFileSystem(); HadoopDataSourceUtil.move(new Counter(), fs, getPath("src"), getPath("dst")); assertThat(collect(), is(path("dst/a.csv"))); }
public static void move( Counter counter, FileSystem fs, Path from, Path to) throws IOException { try { move(counter, fs, from, fs, to, false, 0); } catch (InterruptedException e) { throw new IOException(e); } }
HadoopDataSourceUtil { public static void move( Counter counter, FileSystem fs, Path from, Path to) throws IOException { try { move(counter, fs, from, fs, to, false, 0); } catch (InterruptedException e) { throw new IOException(e); } } }
HadoopDataSourceUtil { public static void move( Counter counter, FileSystem fs, Path from, Path to) throws IOException { try { move(counter, fs, from, fs, to, false, 0); } catch (InterruptedException e) { throw new IOException(e); } } private  HadoopDataSourceUtil(); }
HadoopDataSourceUtil { public static void move( Counter counter, FileSystem fs, Path from, Path to) throws IOException { try { move(counter, fs, from, fs, to, false, 0); } catch (InterruptedException e) { throw new IOException(e); } } private  HadoopDataSourceUtil(); static List<DirectDataSourceProfile> loadProfiles(Configuration conf); static DirectDataSourceRepository loadRepository(Configuration conf); static boolean isLocalAttemptOutputDefined(LocalFileSystem localFileSystem); static Path getLocalTemporaryDirectory(LocalFileSystem localFileSystem); static OutputTransactionContext createContext(String executionId, String datasourceId); @Deprecated static OutputTransactionContext createContext(JobContext context, String datasourceId); @Deprecated static OutputAttemptContext createContext(TaskAttemptContext context, String datasourceId); static String getTransactionInfoExecutionId(Path transactionInfoPath); static Path getTransactionInfoPath(Configuration conf, String executionId); static Path getCommitMarkPath(Configuration conf, String executionId); static Collection<FileStatus> findAllTransactionInfoFiles(Configuration conf); static Path getSystemDir(Configuration conf); static Path getSystemDir(Configuration conf, boolean resolve); static List<FileStatus> search(FileSystem fs, Path base, FilePattern pattern); static List<FileStatus> onlyMinimalCovered(List<FileStatus> statList); static boolean contains(Path parent, Path child); static void move(
            Counter counter, FileSystem fs,
            Path from, Path to); static void moveFromLocal(
            Counter counter,
            LocalFileSystem localFs, FileSystem fs,
            Path from, Path to); static void move(
            Counter counter, FileSystem fs,
            Path from, Path to, int threads); static HadoopFileFormat<T> toHadoopFileFormat(
            Configuration configuration, DataFormat<T> format); }
HadoopDataSourceUtil { public static void move( Counter counter, FileSystem fs, Path from, Path to) throws IOException { try { move(counter, fs, from, fs, to, false, 0); } catch (InterruptedException e) { throw new IOException(e); } } private  HadoopDataSourceUtil(); static List<DirectDataSourceProfile> loadProfiles(Configuration conf); static DirectDataSourceRepository loadRepository(Configuration conf); static boolean isLocalAttemptOutputDefined(LocalFileSystem localFileSystem); static Path getLocalTemporaryDirectory(LocalFileSystem localFileSystem); static OutputTransactionContext createContext(String executionId, String datasourceId); @Deprecated static OutputTransactionContext createContext(JobContext context, String datasourceId); @Deprecated static OutputAttemptContext createContext(TaskAttemptContext context, String datasourceId); static String getTransactionInfoExecutionId(Path transactionInfoPath); static Path getTransactionInfoPath(Configuration conf, String executionId); static Path getCommitMarkPath(Configuration conf, String executionId); static Collection<FileStatus> findAllTransactionInfoFiles(Configuration conf); static Path getSystemDir(Configuration conf); static Path getSystemDir(Configuration conf, boolean resolve); static List<FileStatus> search(FileSystem fs, Path base, FilePattern pattern); static List<FileStatus> onlyMinimalCovered(List<FileStatus> statList); static boolean contains(Path parent, Path child); static void move(
            Counter counter, FileSystem fs,
            Path from, Path to); static void moveFromLocal(
            Counter counter,
            LocalFileSystem localFs, FileSystem fs,
            Path from, Path to); static void move(
            Counter counter, FileSystem fs,
            Path from, Path to, int threads); static HadoopFileFormat<T> toHadoopFileFormat(
            Configuration configuration, DataFormat<T> format); static final String PREFIX; static final String KEY_PATH; static final String KEY_SYSTEM_DIR; static final String KEY_LOCAL_TEMPDIR; static final String PREFIX_BEGIN_MARK; static final String PREFIX_COMMIT_MARK; static final String DEFAULT_SYSTEM_DIR; static final String TRANSACTION_INFO_DIR; static final Charset COMMENT_CHARSET; }