A C D E F G H N O W
All Classes All Packages

A

addElement(T) - Method in class org.apache.flink.formats.compress.writers.HadoopCompressionBulkWriter

addElement(T) - Method in class org.apache.flink.formats.compress.writers.NoCompressionBulkWriter

C

CompressWriterFactory<IN> - Class in org.apache.flink.formats.compress

A factory that creates for bulk writers that, when provided with a CompressionCodec, they compress the data they write.

CompressWriterFactory(Extractor<IN>) - Constructor for class org.apache.flink.formats.compress.CompressWriterFactory

Creates a new CompressWriterFactory using the given Extractor to assemble either HadoopCompressionBulkWriter or NoCompressionBulkWriter based on whether a Hadoop CompressionCodec name is specified.

CompressWriters - Class in org.apache.flink.formats.compress

Convenience builder for creating CompressWriterFactory instances.

CompressWriters() - Constructor for class org.apache.flink.formats.compress.CompressWriters

create(FSDataOutputStream) - Method in class org.apache.flink.formats.compress.CompressWriterFactory

D

DefaultExtractor<T> - Class in org.apache.flink.formats.compress.extractor

A Extractor implementation that extracts element to string with line separator.

DefaultExtractor() - Constructor for class org.apache.flink.formats.compress.extractor.DefaultExtractor

E

extract(T) - Method in class org.apache.flink.formats.compress.extractor.DefaultExtractor

extract(T) - Method in interface org.apache.flink.formats.compress.extractor.Extractor

Extractor<T> - Interface in org.apache.flink.formats.compress.extractor

An Extractor turns a record into a byte array for writing data.

F

finish() - Method in class org.apache.flink.formats.compress.writers.HadoopCompressionBulkWriter

finish() - Method in class org.apache.flink.formats.compress.writers.NoCompressionBulkWriter

flush() - Method in class org.apache.flink.formats.compress.writers.HadoopCompressionBulkWriter

flush() - Method in class org.apache.flink.formats.compress.writers.NoCompressionBulkWriter

forExtractor(Extractor<IN>) - Static method in class org.apache.flink.formats.compress.CompressWriters

G

getExtension() - Method in class org.apache.flink.formats.compress.CompressWriterFactory

H

HadoopCompressionBulkWriter<T> - Class in org.apache.flink.formats.compress.writers

A BulkWriter implementation that writes data that have been compressed using Hadoop CompressionCodec.

HadoopCompressionBulkWriter(CompressionOutputStream, Extractor<T>) - Constructor for class org.apache.flink.formats.compress.writers.HadoopCompressionBulkWriter

N

NoCompressionBulkWriter<T> - Class in org.apache.flink.formats.compress.writers

A BulkWriter implementation that does not compress data.

NoCompressionBulkWriter(FSDataOutputStream, Extractor<T>) - Constructor for class org.apache.flink.formats.compress.writers.NoCompressionBulkWriter

O

org.apache.flink.formats.compress - package org.apache.flink.formats.compress

org.apache.flink.formats.compress.extractor - package org.apache.flink.formats.compress.extractor

org.apache.flink.formats.compress.writers - package org.apache.flink.formats.compress.writers

W

withHadoopCompression(String) - Method in class org.apache.flink.formats.compress.CompressWriterFactory

Compresses the data using the provided Hadoop CompressionCodec.

withHadoopCompression(String, Configuration) - Method in class org.apache.flink.formats.compress.CompressWriterFactory

Compresses the data using the provided Hadoop CompressionCodec and Configuration.

A C D E F G H N O W
All Classes All Packages