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.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 and Description
static <IN> CompressWriterFactory<IN>	CompressWriters.forExtractor(Extractor<IN> extractor)

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

Constructor and 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.writers

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

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