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 givenExtractorto assemble eitherHadoopCompressionBulkWriterorNoCompressionBulkWriterbased 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 classDefaultExtractor<T>AExtractorimplementation 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)
-