@PublicEvolving public static class StreamingFileSink.BulkFormatBuilder<IN,BucketID> extends StreamingFileSink.BucketsBuilder<IN,BucketID>
Modifier and Type | Method and Description |
---|---|
StreamingFileSink<IN> |
build()
Creates the actual sink.
|
<ID> StreamingFileSink.BulkFormatBuilder<IN,ID> |
withBucketAssigner(BucketAssigner<IN,ID> assigner) |
StreamingFileSink.BulkFormatBuilder<IN,BucketID> |
withBucketCheckInterval(long interval) |
public StreamingFileSink.BulkFormatBuilder<IN,BucketID> withBucketCheckInterval(long interval)
public <ID> StreamingFileSink.BulkFormatBuilder<IN,ID> withBucketAssigner(BucketAssigner<IN,ID> assigner)
public StreamingFileSink<IN> build()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.