public static Duration getLeadTimeDurationFromConfig ( State state ) { String leadTimeProp = state . getProp ( DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME ) ; if ( leadTimeProp == null || leadTimeProp . length ( ) == 0 ) { return DEFAULT_PARTITIONED_SOURCE_PARTITION_LEAD_TIME ; } int leadTime = Integer . parseInt ( leadTimeProp ) ; DatePartitionType leadTimeGranularity = DEFAULT_DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY ; String leadTimeGranularityProp = state . getProp ( DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY ) ; if ( leadTimeGranularityProp != null ) { leadTimeGranularity = DatePartitionType . valueOf ( leadTimeGranularityProp ) ; } return new Duration ( leadTime * leadTimeGranularity . getUnitMilliseconds ( ) ) ; }
Retrieve the lead time duration from the LEAD_TIME and LEAD_TIME granularity config settings .