Serialized Form

Package org.apache.flink.formats.hadoop.bulk

Class org.apache.flink.formats.hadoop.bulk.DefaultHadoopFileCommitterFactory extends Object implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.api.functions.sink.filesystem

Class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactoryImpl extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.filesystem.HadoopPathBasedBulkFormatBuilder extends org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink.BucketsBuilder<IN,BucketID,T extends HadoopPathBasedBulkFormatBuilder<IN,BucketID,T>> implements Serializable

serialVersionUID:

1L

Serialized Fields

basePath

org.apache.flink.core.fs.Path basePath

bucketAssigner

org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID> bucketAssigner

bucketFactory

org.apache.flink.streaming.api.functions.sink.filesystem.BucketFactory<IN,BucketID> bucketFactory

fileCommitterFactory

HadoopFileCommitterFactory fileCommitterFactory

outputFileConfig

org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig

rollingPolicy

org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<IN,BucketID> rollingPolicy

serializableConfiguration

SerializableConfiguration serializableConfiguration

writerFactory

HadoopPathBasedBulkWriter.Factory<IN> writerFactory

Class org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig extends Object implements Serializable

Serialized Fields

partPrefix

String partPrefix

partSuffix

String partSuffix

Class org.apache.flink.streaming.api.functions.sink.filesystem.SerializableConfiguration extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException