Package org.apache.wayang.flink.compiler.criterion

Class WayangValue<T>

java.lang.Object

org.apache.wayang.flink.compiler.criterion.WayangValue<T>

All Implemented Interfaces:

Serializable, org.apache.flink.core.io.IOReadableWritable, org.apache.flink.types.Value

public class WayangValue<T>
extends Object
implements org.apache.flink.types.Value

Implementation of Value of flink for use in Wayang

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
WayangValue()
WayangValue(T element)

Method Summary

Modifier and Type	Method	Description
byte[]	convertToByte()
T	convertToObject(byte[] array)
T	get()
void	read(org.apache.flink.core.memory.DataInputView dataInputView)
String	toString()
void	write(org.apache.flink.core.memory.DataOutputView dataOutputView)

Methods inherited from class java.lang.Object

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

Constructor Details

WayangValue

public WayangValue()

WayangValue

public WayangValue(T element)

Method Details

write

public void write(org.apache.flink.core.memory.DataOutputView dataOutputView)
           throws IOException

Specified by:

write in interface org.apache.flink.core.io.IOReadableWritable

Throws:

IOException

read

public void read(org.apache.flink.core.memory.DataInputView dataInputView)
          throws IOException

Specified by:

read in interface org.apache.flink.core.io.IOReadableWritable

Throws:

IOException

convertToByte

public byte[] convertToByte()

convertToObject

public T convertToObject(byte[] array)

toString

public String toString()

Overrides:

toString in class Object

get

public T get()