org.apache.flink.statefun.flink.common.protobuf

Class ProtobufSerializer<M extends com.google.protobuf.Message>

java.lang.Object

org.apache.flink.statefun.flink.common.protobuf.ProtobufSerializer<M>

@NotThreadSafe
public final class ProtobufSerializer<M extends com.google.protobuf.Message>
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
void	copy(org.apache.flink.core.memory.DataInputView source, org.apache.flink.core.memory.DataOutputView target)
M	deserialize(org.apache.flink.core.memory.DataInputView source)
ProtobufSerializer<M>	duplicate()
static <M extends com.google.protobuf.Message> ProtobufSerializer<M>	forMessageGeneratedClass(java.lang.Class<M> type)
void	serialize(M record, org.apache.flink.core.memory.DataOutputView target)

Methods inherited from class java.lang.Object

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

Method Detail

forMessageGeneratedClass

public static <M extends com.google.protobuf.Message> ProtobufSerializer<M> forMessageGeneratedClass(java.lang.Class<M> type)

serialize

public void serialize(M record,
                      org.apache.flink.core.memory.DataOutputView target)
               throws java.io.IOException

Throws:

java.io.IOException

deserialize

public M deserialize(org.apache.flink.core.memory.DataInputView source)
              throws java.io.IOException

Throws:

java.io.IOException

copy

public void copy(org.apache.flink.core.memory.DataInputView source,
                 org.apache.flink.core.memory.DataOutputView target)
          throws java.io.IOException

Throws:

java.io.IOException

duplicate

public ProtobufSerializer<M> duplicate()