format the code

Author: zhisheng17

flink-learning-common/src/main/java/com/zhisheng/common/constant/PropertiesConstants.java

@@ -17,7 +17,6 @@ public class PropertiesConstants {
     public static final String CONSUMER_FROM_TIME = "consumer.from.time";
     public static final String STREAM_PARALLELISM = "stream.parallelism";
     public static final String STREAM_SINK_PARALLELISM = "stream.sink.parallelism";
-    public static final String STREAM_DEFAULT_PARALLELISM = "stream.default.parallelism";
     public static final String STREAM_CHECKPOINT_ENABLE = "stream.checkpoint.enable";
     public static final String STREAM_CHECKPOINT_DIR = "stream.checkpoint.dir";
     public static final String STREAM_CHECKPOINT_TYPE = "stream.checkpoint.type";

flink-learning-common/src/main/java/com/zhisheng/common/schemas/LogSchema.java

@@ -7,7 +7,7 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 
 /**
  * Log Schema ，支持序列化和反序列化
@@ -32,7 +32,7 @@ public boolean isEndOfStream(LogEvent logEvent) {
 
     @Override
     public byte[] serialize(LogEvent logEvent) {
-        return gson.toJson(logEvent).getBytes(Charset.forName("UTF-8"));
+        return gson.toJson(logEvent).getBytes(StandardCharsets.UTF_8);
     }
 
     @Override

flink-learning-common/src/main/java/com/zhisheng/common/schemas/MetricSchema.java

@@ -7,14 +7,13 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 
 /**
  * Metric Schema ，支持序列化和反序列化
- *
+ * <p>
  * blog：http://www.54tianzhisheng.cn/
  * 微信公众号：zhisheng
- *
  */
 public class MetricSchema implements DeserializationSchema<MetricEvent>, SerializationSchema<MetricEvent> {
 
@@ -32,7 +31,7 @@ public boolean isEndOfStream(MetricEvent metricEvent) {
 
     @Override
     public byte[] serialize(MetricEvent metricEvent) {
-        return gson.toJson(metricEvent).getBytes(Charset.forName("UTF-8"));
+        return gson.toJson(metricEvent).getBytes(StandardCharsets.UTF_8);
     }
 
     @Override

flink-learning-common/src/main/java/com/zhisheng/common/schemas/OrderLineSchema.java

@@ -7,7 +7,7 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 
 /**
  * OrderLine Schema ，支持序列化和反序列化
@@ -31,7 +31,7 @@ public boolean isEndOfStream(OrderLineEvent orderLineEvent) {
 
     @Override
     public byte[] serialize(OrderLineEvent orderLineEvent) {
-        return gson.toJson(orderLineEvent).getBytes(Charset.forName("UTF-8"));
+        return gson.toJson(orderLineEvent).getBytes(StandardCharsets.UTF_8);
     }
 
     @Override

flink-learning-common/src/main/java/com/zhisheng/common/schemas/OrderSchema.java

@@ -7,7 +7,7 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 
 /**
  * order Schema ，支持序列化和反序列化
@@ -31,7 +31,7 @@ public boolean isEndOfStream(OrderEvent orderEvent) {
 
     @Override
     public byte[] serialize(OrderEvent orderEvent) {
-        return gson.toJson(orderEvent).getBytes(Charset.forName("UTF-8"));
+        return gson.toJson(orderEvent).getBytes(StandardCharsets.UTF_8);
     }
 
     @Override

flink-learning-common/src/main/java/com/zhisheng/common/schemas/ProductSchema.java

@@ -7,7 +7,7 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 
 /**
  * Product Schema ，支持序列化和反序列化
@@ -31,7 +31,7 @@ public boolean isEndOfStream(ProductEvent productEvent) {
 
     @Override
     public byte[] serialize(ProductEvent productEvent) {
-        return gson.toJson(productEvent).getBytes(Charset.forName("UTF-8"));
+        return gson.toJson(productEvent).getBytes(StandardCharsets.UTF_8);
     }
 
     @Override

flink-learning-common/src/main/java/com/zhisheng/common/schemas/ShopSchema.java

@@ -7,7 +7,7 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 
 /**
  * Shop Schema ，支持序列化和反序列化
@@ -31,7 +31,7 @@ public boolean isEndOfStream(ShopEvent shopEvent) {
 
     @Override
     public byte[] serialize(ShopEvent shopEvent) {
-        return gson.toJson(shopEvent).getBytes(Charset.forName("UTF-8"));
+        return gson.toJson(shopEvent).getBytes(StandardCharsets.UTF_8);
     }
 
     @Override

flink-learning-common/src/main/java/com/zhisheng/common/schemas/UserSchema.java

@@ -7,7 +7,7 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 
 /**
  * User Schema ，支持序列化和反序列化
@@ -31,7 +31,7 @@ public boolean isEndOfStream(UserEvent userEvent) {
 
     @Override
     public byte[] serialize(UserEvent userEvent) {
-        return gson.toJson(userEvent).getBytes(Charset.forName("UTF-8"));
+        return gson.toJson(userEvent).getBytes(StandardCharsets.UTF_8);
     }
 
     @Override