update codes

bin/start_tag.sh

@@ -27,7 +27,7 @@ $JAR_DIR/ctr-estimate-1.0-SNAPSHOT.jar \
 --retryInteral 3000 \
 --checkpointPath 'hdfs://bj-gmei-hdfs/user/data/flink/ctr-estimate-tag/checkpoint' \
 --parallelism 6 \
---startTime '2020-04-04 11:42:00' \
+--startTime '2020-04-04 11:53:00' \
 >> /data/log/ctr-estimate/ctr-estimate-tag.out 2>&1 &
 
 tail -f /data/log/ctr-estimate/ctr-estimate-tag.out

src/main/java/com/gmei/data/ctr/bean/CtrEstimateTagEtl.java

@@ -11,13 +11,13 @@ public class CtrEstimateTagEtl {
     private String estimateType;
     private Integer count;
     private String cardContentType;
-    private Long cardId;
+    private String cardId;
     private String partitionDate;
     private String lastUpdateTime;
     private String type;
     private String keyWord;
 
-    public CtrEstimateTagEtl(String deviceId, String cardContentType, Long cardId, String estimateType, Integer count, String partitionDate, String lastUpdateTime,String type,String keyWord) {
+    public CtrEstimateTagEtl(String deviceId, String cardContentType, String cardId, String estimateType, Integer count, String partitionDate, String lastUpdateTime,String type,String keyWord) {
         this.deviceId = deviceId;
         this.cardContentType = cardContentType;
         this.cardId = cardId;
@@ -48,11 +48,11 @@ public class CtrEstimateTagEtl {
         this.cardContentType = cardContentType;
     }
 
-    public Long getCardId() {
+    public String getCardId() {
         return cardId;
     }
 
-    public void setCardId(Long cardId) {
+    public void setCardId(String cardId) {
         this.cardId = cardId;
     }
 

src/main/java/com/gmei/data/ctr/operator/CtrEstimateTagOperator.java

@@ -82,7 +82,7 @@ public class CtrEstimateTagOperator implements BaseOperator{
                                     }
                                     if (StringUtils.isNotBlank(clId)) {
                                         String cardContentType = paramsObject.getString("card_content_type");
-                                        Long cardId = paramsObject.getLong("card_id");
+                                        String cardId = paramsObject.getString("card_id");
                                         if (null != cardContentType && null != cardId) {
                                             if ("service".equals(cardContentType) || "diary".equals(cardContentType) ||
                                                     "tractate".equals(cardContentType) || "answer".equals(cardContentType)) {
@@ -121,7 +121,7 @@ public class CtrEstimateTagOperator implements BaseOperator{
                             }
                             if (StringUtils.isNotBlank(clId)) {
                                 String cardContentType = paramsObject.getString("card_content_type");
-                                Long cardId = paramsObject.getLong("card_id");
+                                String cardId = paramsObject.getString("card_id");
                                 ctrEstimateTagEtl.setDeviceId(deviceId);
                                 if (null != cardContentType && null != cardId) {
                                     ctrEstimateTagEtl.setCardId(cardId);