org.apache.flink.formats.compress.extractor

Interface Extractor<T>

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultExtractor

public interface Extractor<T>
extends Serializable

An Extractor turns a record into a byte array for writing data. For use with CompressWriters.

Method Summary

Modifier and Type	Method and Description
byte[]	extract(T element)

Method Detail

extract

byte[] extract(T element)