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.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

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink extends org.apache.flink.streaming.api.functions.sink.RichSinkFunction<IN extends Object> implements Serializable

serialVersionUID:

1L

Serialized Fields

bucketCheckInterval

long bucketCheckInterval

Deprecated.

bucketsBuilder

org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder<IN extends Object,?,? extends org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder<IN extends Object,?,?>> bucketsBuilder

Deprecated.

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

serialVersionUID:

1L

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BulkFormatBuilder extends org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder<IN extends Object,BucketID extends Object,T extends org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BulkFormatBuilder<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 extends Object,BucketID extends Object> bucketAssigner

bucketCheckInterval

long bucketCheckInterval

bucketFactory

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

outputFileConfig

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

rollingPolicy

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

writerFactory

org.apache.flink.api.common.serialization.BulkWriter.Factory<IN extends Object> writerFactory

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultBulkFormatBuilder extends org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BulkFormatBuilder<IN extends Object,String,org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultBulkFormatBuilder<IN extends Object>> implements Serializable

serialVersionUID:

7493169281036370228L

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultRowFormatBuilder extends org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder<IN extends Object,String,org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultRowFormatBuilder<IN extends Object>> implements Serializable

serialVersionUID:

-8503344257202146718L

Class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder extends org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder<IN extends Object,BucketID extends Object,T extends org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder<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 extends Object,BucketID extends Object> bucketAssigner

bucketCheckInterval

long bucketCheckInterval

bucketFactory

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

encoder

org.apache.flink.api.common.serialization.Encoder<IN extends Object> encoder

outputFileConfig

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

rollingPolicy

org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN extends Object,BucketID extends Object> rollingPolicy