org.apache.flink.api.common.serialization

Interface Encoder<IN>

Type Parameters:

IN - The type of the elements that are being written by the sink.

All Superinterfaces:

Serializable

All Known Implementing Classes:

JsonFileSystemFormatFactory.JsonRowDataEncoder, SimpleStringEncoder

@PublicEvolving
public interface Encoder<IN>
extends Serializable

A Encoder is used by the streaming file sink to perform the actual writing of the incoming elements to the files in a bucket.

Method Summary

Modifier and Type	Method and Description
void	encode(IN element, OutputStream stream) Writes one element to the bucket file.

Method Detail

encode

void encode(IN element,
            OutputStream stream)
     throws IOException

Writes one element to the bucket file.

Parameters:

element - the element to be written.

stream - the stream to write the element to.

Throws:

IOException