add toNodePara

src/main/java/com/winhc/dataworks/flow/touch/bean/OdpsTableSchema.java

@@ -6,6 +6,10 @@ import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;
 
+import java.util.Arrays;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
 /**
  * @Author: XuJiakai
  * @Date: 2020/6/23 14:16
@@ -34,6 +38,20 @@ public class OdpsTableSchema {
      */
     private String dupliCols;
 
+    public String toNodePara() {
+        return Arrays.stream(this.getClass().getDeclaredFields()).map(f -> {
+            String name = f.getName();
+            try {
+                f.setAccessible(true);
+                String o = ((String) f.get(this));
+                return name + "=" + o;
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            return null;
+        }).filter(Objects::nonNull).collect(Collectors.joining(" "));
+    }
+
     @Override
     public String toString() {
         return JsonUtils.jsonObjToString(this);

src/main/java/com/winhc/dataworks/flow/touch/test/TestFlow.java

@@ -1,5 +1,6 @@
 package com.winhc.dataworks.flow.touch.test;
 
+import com.winhc.dataworks.flow.touch.bean.OdpsTableSchema;
 import com.winhc.dataworks.flow.touch.configuration.SchemaInit;
 
 /**
@@ -9,6 +10,8 @@ import com.winhc.dataworks.flow.touch.configuration.SchemaInit;
  */
 public class TestFlow {
     public static void main(String[] args) {
-        System.out.println(SchemaInit.MAP);
+        OdpsTableSchema company_env_punishment = SchemaInit.MAP.get("company_env_punishment");
+
+        System.out.println(company_env_punishment.toNodePara());
     }
 }