feat: 支持文件系统的xAttr

1. 支持文件系统的xAttr;
2. 优化日志输出

Author: yuyang733

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.qcloud.cos</groupId>
     <artifactId>hadoop-cos</artifactId>
-    <version>3.1.0-5.8.4</version>
+    <version>3.1.0-5.8.5</version>
     <packaging>jar</packaging>
 
     <name>Apache Hadoop Tencent Qcloud COS Support</name>

src/main/java/org/apache/hadoop/fs/CosFileSystem.java

@@ -10,7 +10,7 @@
 @InterfaceStability.Unstable
 public class CosNConfigKeys extends CommonConfigurationKeys {
     public static final String USER_AGENT = "fs.cosn.user.agent";
-    public static final String DEFAULT_USER_AGENT = "cos-hadoop-plugin-v5.8.4";
+    public static final String DEFAULT_USER_AGENT = "cos-hadoop-plugin-v5.8.5";
 
     public static final String TENCENT_EMR_VERSION_KEY = "fs.emr.version";
 
@@ -43,7 +43,7 @@ public class CosNConfigKeys extends CommonConfigurationKeys {
 
     public static final String COSN_UPLOAD_BUFFER_SIZE_KEY = "fs.cosn.upload.buffer.size";
     public static final String COSN_UPLOAD_BUFFER_SIZE_PREV_KEY = "fs.cosn.buffer.size";
-    public static final int DEFAULT_UPLOAD_BUFFER_SIZE = -1;       // default is 128MB
+    public static final int DEFAULT_UPLOAD_BUFFER_SIZE = -1;
 
     public static final String COSN_BLOCK_SIZE_KEY = "fs.cosn.block.size";
     public static final long DEFAULT_BLOCK_SIZE = 128 * Unit.MB;

src/main/java/org/apache/hadoop/fs/CosNConfigKeys.java

@@ -6,13 +6,13 @@
 import java.io.IOException;
 
 public class CosNCopyFileTask implements Runnable {
-    private static Logger LOG = LoggerFactory.getLogger(CosNCopyFileTask.class);
+    private static final Logger LOG = LoggerFactory.getLogger(CosNCopyFileTask.class);
 
-    private NativeFileSystemStore store;
+    private final NativeFileSystemStore store;
 
-    private String srcKey;
-    private String dstKey;
-    private CosNCopyFileContext cosCopyFileContext;
+    private final String srcKey;
+    private final String dstKey;
+    private final CosNCopyFileContext cosCopyFileContext;
 
     public CosNCopyFileTask(NativeFileSystemStore store, String srcKey,
                             String dstKey,

src/main/java/org/apache/hadoop/fs/CosNCopyFileTask.java

@@ -6,12 +6,12 @@
 import java.io.IOException;
 
 public class CosNDeleteFileTask implements Runnable {
-    private static Logger LOG = LoggerFactory.getLogger(CosNCopyFileTask.class);
+    private static final Logger LOG = LoggerFactory.getLogger(CosNCopyFileTask.class);
 
-    private NativeFileSystemStore store;
+    private final NativeFileSystemStore store;
 
-    private String srcKey;
-    private CosNDeleteFileContext cosDeleteFileContext;
+    private final String srcKey;
+    private final CosNDeleteFileContext cosDeleteFileContext;
 
     public CosNDeleteFileTask(NativeFileSystemStore store, String srcKey,
                               CosNDeleteFileContext cosDeleteFileContext) {
@@ -24,10 +24,10 @@ public CosNDeleteFileTask(NativeFileSystemStore store, String srcKey,
     public void run() {
         boolean fail = false;
         try {
+            LOG.debug("Delete the cos key: {}.", srcKey);
             this.store.delete(srcKey);
         } catch (IOException e) {
-            LOG.warn("Exception thrown when delete file{}, exception:{}"
-                    , this.srcKey, e);
+            LOG.warn("Exception thrown when delete file [{}], exception: ", this.srcKey, e);
             fail = true;
             cosDeleteFileContext.setIOException(e);
         } finally {

src/main/java/org/apache/hadoop/fs/CosNDeleteFileTask.java

@@ -0,0 +1,24 @@
+package org.apache.hadoop.fs;
+
+import java.io.Serializable;
+
+public class CosNXAttr implements Serializable {
+    private String name;
+    private String value;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value;
+    }
+}