BucketProcessor<T>
getProcessor()
Builder(Function<T,String> bucketIdExtractor, BucketProcessor<T> processor)