Package org.apache.flink.connector.file.table

Class SerializationSchemaAdapter

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.serialization.Encoder<org.apache.flink.table.data.RowData>

@Internal
public class SerializationSchemaAdapter
extends Object
implements org.apache.flink.api.common.serialization.Encoder<org.apache.flink.table.data.RowData>

Adapter to turn a SerializationSchema into a Encoder.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
SerializationSchemaAdapter(org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> serializationSchema)

Method Summary

Modifier and Type	Method	Description
void	encode(org.apache.flink.table.data.RowData element, OutputStream stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializationSchemaAdapter

public SerializationSchemaAdapter(org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> serializationSchema)

Method Detail

encode

public void encode(org.apache.flink.table.data.RowData element,
                   OutputStream stream)
            throws IOException

Specified by:

encode in interface org.apache.flink.api.common.serialization.Encoder<org.apache.flink.table.data.RowData>

Throws:

IOException