如何获得现有德鲁伊数据源的粒度

Question

我正在努力通过检索现有记录来更新现有记录，更新并随后更新记录。 因此，我需要获取现有数据源的粒度，这些数据源将在获取更新的记录时使用。

Answer 1

由于没有任何queryType返回粒度。 我已检索使用http://localhost:8081/druid/coordinator/v1/metadata/datasources/wikiticker

的数据源的信息然后获取的最后一个或任何段的间隔

 
     JSONArray segmentArray = (JSONArray) dataSourceObj.get("segments"); 
     JSONObject lastSegmentObject = new JSONObject(segmentArray.get(segmentArray.length()-1).toString()); 
     String granularityInterval = lastSegmentObject.get("interval").toString(); 

然后计算使用任何API例如日期间隔之间的差异：约达

 
      SimpleDateFormat format = new SimpleDateFormat(Constants.DATE_FORMAT); 
      Date intervalStart = format.parse(interval.split("/")[0]); 
      Date intervalEnd = format.parse(interval.split("/")[1]);
 
      DateTime startTime = new DateTime(intervalStart) ; 
      DateTime endTime = new DateTime(intervalEnd) ;
 

 Period jodaPeriod = new Period(startTime, endTime); 

     if(jodaPeriod.getYears() == 1){ 
      return DesignerConstants.DRUID_GRANULARITY_YEAR; 
     }else if(jodaPeriod.getMonths() == 1){ 
      return DesignerConstants.DRUID_GRANULARITY_MONTH; 
     }else if(jodaPeriod.getWeeks() == 1){ 
      return DesignerConstants.DRUID_GRANULARITY_WEEK; 
     }else if(jodaPeriod.getDays() == 1){ 
      return DesignerConstants.DRUID_GRANULARITY_DAY; 
     }else if(jodaPeriod.getHours() == 1){ 
      return DesignerConstants.DRUID_GRANULARITY_HOUR; 
     } 

     return "none"; 
    } 
</pre> 

Answer 2

FYI数据可以源具有多个分段粒度，这就是为什么没有查询会为您做到这一点。虽然上面的代码将返回与您问的原始问题不同的最后一个段的粒度。