IN
- record typepublic static final class StreamingFileSink.DefaultBulkFormatBuilder<IN> extends StreamingFileSink.BulkFormatBuilder<IN,String,StreamingFileSink.DefaultBulkFormatBuilder<IN>>
StreamingFileSink
using a bulk format.DEFAULT_BUCKET_CHECK_INTERVAL
build, createBuckets, createBucketWriter, getBucketCheckInterval, withBucketAssigner, withBucketCheckInterval, withNewBucketAssigner, withOutputFileConfig, withRollingPolicy
self
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.