Toggle navigation
Home
org.apache.flink.streaming.connectors.fs.bucketing.Bucketer to org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner
No. of Instances - 14
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Variable
bucketer
to
assigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
assigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
assigner
bucketer
to
assigner
bucketer
to
bucketAssigner
bucketer
to
assigner
bucketer
to
bucketAssigner
bucketer
to
bucketAssigner
bucketer
to
assigner
Cascading Type Change (Different)
DefaultBucketFactory<>
to
DefaultBucketFactoryImpl<>
DefaultBucketFactory<>
to
DefaultBucketFactoryImpl<>
DefaultBucketFactory<>
to
DefaultBucketFactoryImpl<>
Add or Remove Method invocation
StreamingFileSink.forBulkFormat(new Path(outDir.toURI()),writer).withBucketer(bucketer).withBucketCheckInterval(bucketCheckInterval).withBucketFactory(bucketFactory)
to
StreamingFileSink.forBulkFormat(new Path(outDir.toURI()),writer).withBucketAssigner(bucketer).withBucketCheckInterval(bucketCheckInterval).withBucketFactory(bucketFactory)
StreamingFileSink.forRowFormat(new Path(outDir.toURI()),writer).withBucketer(bucketer).withRollingPolicy(rollingPolicy).withBucketCheckInterval(bucketCheckInterval).withBucketFactory(bucketFactory)
to
StreamingFileSink.forRowFormat(new Path(outDir.toURI()),writer).withBucketAssigner(bucketer).withRollingPolicy(rollingPolicy).withBucketCheckInterval(bucketCheckInterval).withBucketFactory(bucketFactory)