org.wikimedia.eventutilities.flink.stream

Class FileSinkJsonRowEncoder

java.lang.Object

org.wikimedia.eventutilities.flink.stream.FileSinkJsonRowEncoder

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.serialization.Encoder<org.apache.flink.types.Row>

public class FileSinkJsonRowEncoder
extends Object
implements org.apache.flink.api.common.serialization.Encoder<org.apache.flink.types.Row>

A FileSink Encoder that encodes event Rows to JSON strings. This class is designed to produce events compliant with the WMF Event Platform.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FileSinkJsonRowEncoder(org.apache.flink.api.java.typeutils.RowTypeInfo typeInformation, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row> serializationSchema, SerializableClock ingestionTimeClock)

Method Summary

Modifier and Type	Method and Description
void	encode(org.apache.flink.types.Row element, OutputStream stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSinkJsonRowEncoder

public FileSinkJsonRowEncoder(org.apache.flink.api.java.typeutils.RowTypeInfo typeInformation,
                              org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row> serializationSchema,
                              SerializableClock ingestionTimeClock)

Method Detail

encode

public void encode(org.apache.flink.types.Row element,
                   OutputStream stream)
            throws IOException

Specified by:

encode in interface org.apache.flink.api.common.serialization.Encoder<org.apache.flink.types.Row>

Throws:

IOException