From 8c3177d835bb86eed6127b390e2f39ca63ba1a04 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Thu, 4 Feb 2021 21:41:19 -0800 Subject: java: resolve parent directory if started with seaweedfs:// --- .../java/com/seaweedfs/examples/HdfsCopyFile.java | 25 ++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 other/java/examples/src/main/java/com/seaweedfs/examples/HdfsCopyFile.java (limited to 'other/java/examples/src') diff --git a/other/java/examples/src/main/java/com/seaweedfs/examples/HdfsCopyFile.java b/other/java/examples/src/main/java/com/seaweedfs/examples/HdfsCopyFile.java new file mode 100644 index 000000000..006c581c9 --- /dev/null +++ b/other/java/examples/src/main/java/com/seaweedfs/examples/HdfsCopyFile.java @@ -0,0 +1,25 @@ +package com.seaweedfs.examples; + +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.fs.FileSystem; +import org.apache.hadoop.fs.Path; +import org.apache.hadoop.io.IOUtils; + +import java.io.*; + +public class HdfsCopyFile { + public static void main(String[] args) throws IOException { + Configuration configuration = new Configuration(); + + configuration.set("fs.defaultFS", "seaweedfs://localhost:8888"); + configuration.set("fs.seaweedfs.impl", "seaweed.hdfs.SeaweedFileSystem"); + + FileSystem fs = FileSystem.get(configuration); + String source = "/Users/chris/tmp/test.zip"; + String destination = "/buckets/spark/test01.zip"; + InputStream in = new BufferedInputStream(new FileInputStream(source)); + + OutputStream out = fs.create(new Path(destination)); + IOUtils.copyBytes(in, out, 4096, true); + } +} -- cgit v1.2.3