public static class FileSink.RowFormatBuilder<IN,T extends FileSink.RowFormatBuilder<IN,T>> extends Object
Modifier | Constructor and Description |
---|---|
protected |
RowFormatBuilder(Path basePath,
Encoder<IN> encoder,
BucketAssigner<IN,String> bucketAssigner) |
protected |
RowFormatBuilder(Path basePath,
long bucketCheckInterval,
Encoder<IN> encoder,
BucketAssigner<IN,String> assigner,
RollingPolicy<IN,String> policy,
FileWriterBucketFactory<IN> bucketFactory,
OutputFileConfig outputFileConfig) |
Modifier and Type | Method and Description |
---|---|
FileSink<IN> |
build()
Creates the actual sink.
|
T |
withBucketAssigner(BucketAssigner<IN,String> assigner) |
T |
withBucketCheckInterval(long interval) |
T |
withOutputFileConfig(OutputFileConfig outputFileConfig) |
T |
withRollingPolicy(RollingPolicy<IN,String> policy) |
protected RowFormatBuilder(Path basePath, Encoder<IN> encoder, BucketAssigner<IN,String> bucketAssigner)
protected RowFormatBuilder(Path basePath, long bucketCheckInterval, Encoder<IN> encoder, BucketAssigner<IN,String> assigner, RollingPolicy<IN,String> policy, FileWriterBucketFactory<IN> bucketFactory, OutputFileConfig outputFileConfig)
public T withBucketCheckInterval(long interval)
public T withBucketAssigner(BucketAssigner<IN,String> assigner)
public T withRollingPolicy(RollingPolicy<IN,String> policy)
public T withOutputFileConfig(OutputFileConfig outputFileConfig)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.