org.apache.flink.connector.file.table

Class SerializationSchemaAdapter

java.lang.Object

org.apache.flink.connector.file.table.SerializationSchemaAdapter

All Implemented Interfaces:

Serializable, Encoder<RowData>

@Internal
public class SerializationSchemaAdapter
extends Object
implements Encoder<RowData>

Adapter to turn a SerializationSchema into a Encoder.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SerializationSchemaAdapter(SerializationSchema<RowData> serializationSchema)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializationSchemaAdapter

public SerializationSchemaAdapter(SerializationSchema<RowData> serializationSchema)

Method Detail

encode

public void encode(RowData element,
                   OutputStream stream)
            throws IOException

Description copied from interface: Encoder

Writes one element to the bucket file.

Specified by:

encode in interface Encoder<RowData>

Parameters:

element - the element to be written.

stream - the stream to write the element to.

Throws:

IOException