Uses of Interface
org.apache.flink.formats.compress.extractor.Extractor

Packages that use Extractor

Package	Description
org.apache.flink.formats.compress
org.apache.flink.formats.compress.extractor
org.apache.flink.formats.compress.writers

Uses of Extractor in org.apache.flink.formats.compress

Methods in org.apache.flink.formats.compress with parameters of type Extractor

Modifier and Type	Method	Description
static <IN> CompressWriterFactory<IN>	CompressWriters.forExtractor(Extractor<IN> extractor)

Constructors in org.apache.flink.formats.compress with parameters of type Extractor

Constructor	Description
CompressWriterFactory(Extractor<IN> extractor)	Creates a new CompressWriterFactory using the given Extractor to assemble either HadoopCompressionBulkWriter or NoCompressionBulkWriter based on whether a Hadoop CompressionCodec name is specified.

Uses of Extractor in org.apache.flink.formats.compress.extractor

Classes in org.apache.flink.formats.compress.extractor that implement Extractor

Modifier and Type	Class	Description
class	DefaultExtractor<T>	A Extractor implementation that extracts element to string with line separator.

Uses of Extractor in org.apache.flink.formats.compress.writers

Constructors in org.apache.flink.formats.compress.writers with parameters of type Extractor

Constructor	Description
HadoopCompressionBulkWriter(org.apache.hadoop.io.compress.CompressionOutputStream out, Extractor<T> extractor)
NoCompressionBulkWriter(org.apache.flink.core.fs.FSDataOutputStream outputStream, Extractor<T> extractor)