Package | Description |
---|---|
org.apache.flink.streaming.api.functions.sink.filesystem |
Modifier and Type | Method and Description |
---|---|
Buckets<IN,BucketID> |
HadoopPathBasedBulkFormatBuilder.createBuckets(int subtaskIndex) |
abstract Buckets<IN,BucketID> |
StreamingFileSink.BucketsBuilder.createBuckets(int subtaskIndex) |
Buckets<IN,BucketID> |
StreamingFileSink.RowFormatBuilder.createBuckets(int subtaskIndex) |
Buckets<IN,BucketID> |
StreamingFileSink.BulkFormatBuilder.createBuckets(int subtaskIndex) |
Constructor and Description |
---|
StreamingFileSinkHelper(Buckets<IN,?> buckets,
boolean isRestored,
OperatorStateStore stateStore,
ProcessingTimeService procTimeService,
long bucketCheckInterval) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.