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