会员标签4.0

src/main/java/com/gic/spark/tag/TagProcess.java

@@ -111,8 +111,14 @@ public class TagProcess {
 
     public void process(boolean extractData){
 
+        if(null!=memberDatasource){
+            System.out.println("memberDatasource==>"+memberDatasource.getHiveTableName());
+            System.out.println("memberDatasource==>"+memberDatasource.getSourceKey());
+        }
+
         Map<Integer, List<TagProcessEntity>> tagGroupByEnterpriseMap = new HashMap<>();
         Map<Long, TagFilter> tagIdToFilterMap = new HashMap();
+
         for(SceneCrowdDTO sceneCrowdDTO:sceneCrowdDTOList){
             if(sceneCrowdDTO.getReal_Time()==2){
                 LinkedList<TagConditionGroupDTO> conditionGroupDTOS=sceneCrowdDTO.getConditionGroupDTOList();
@@ -130,7 +136,13 @@ public class TagProcess {
                         if(null!=tagFilter){
                             tagIdToFilterMap.put(conditionDTO.getTagId(),tagFilter);
                             for(DataSourceEntity sourceEntity:tagFilter.necessarySourceList()){
-                                System.out.println("tagEsFieldName==>"+conditionDTO.getTagEsFieldName()+" ,SourceKey==>"+sourceEntity.getSourceKey()+" ,HiveTableName==>"+sourceEntity.getHiveTableName());
+                                if(null!=sourceEntity){
+                                    System.out.println("tagEsFieldName==>"+conditionDTO.getTagEsFieldName());
+                                    System.out.println("SourceKey==>"+sourceEntity.getSourceKey());
+                                    System.out.println("HiveTableName==>"+sourceEntity.getHiveTableName());
+                                }else{
+                                    System.out.println("tagEsFieldName==>"+conditionDTO.getTagEsFieldName()+" ,sourceEntity==>"+sourceEntity);
+                                }
                             }
                         }
                     }