compute the buckets and start the service concode_field_sep int bucketSpanInMillis concode_elem_sep long endOBucketsInMillis concode_elem_sep long expiryTimeInMillis concode_elem_sep Timer bucketSlidingTimer concode_elem_sep Bucket<T>[] buckets concode_elem_sep boolean isOuter concode_elem_sep Logger logger concode_elem_sep int noOfBuckets concode_elem_sep Map<Object,Set<Long>> key2Buckets concode_elem_sep long startOfBucketsInMillis concode_elem_sep long spanTimeInMillis concode_elem_sep Lock lock concode_elem_sep Map<Long,Bucket> dirtyBuckets concode_elem_sep List<T> unmatchedEvents concode_field_sep void deleteBucket concode_elem_sep void setBucketSpanInMillis concode_elem_sep Bucket<T> createBucket concode_elem_sep List<TimeEvent> getValidTuples concode_elem_sep long getSpanTimeInMillis concode_elem_sep void setSpanTimeInMillis concode_elem_sep long getBucketKeyFor concode_elem_sep boolean put concode_elem_sep int getBucketSpanInMillis concode_elem_sep void newEvent concode_elem_sep void startService concode_elem_sep void isOuterJoin concode_elem_sep List<T> getUnmatchedEvents concode_elem_sep void recomputeNumBuckets concode_elem_sep void deleteExpiredBuckets concode_elem_sep void shutdown
void function ( ) { setBucketSpanInMillis ( ( int ) ( spanTimeInMillis > ( long ) bucketSpanInMillis ? bucketSpanInMillis : spanTimeInMillis ) ) ; if ( buckets == null ) { recomputeNumBuckets ( ) ; } startService ( ) ; }