org.apache.flink.formats.compress.extractor

Class DefaultExtractor<T>

java.lang.Object

org.apache.flink.formats.compress.extractor.DefaultExtractor<T>

Type Parameters:

T - The type of element to extract from.

All Implemented Interfaces:

Serializable, Extractor<T>

public class DefaultExtractor<T>
extends Object
implements Extractor<T>

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultExtractor()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultExtractor

public DefaultExtractor()

Method Detail

extract

public byte[] extract(T element)

Specified by:

extract in interface Extractor<T>