org.apache.flink.statefun.sdk.java.message

Class MessageWrapper

java.lang.Object

org.apache.flink.statefun.sdk.java.message.MessageWrapper

All Implemented Interfaces:

Message

@Internal
public final class MessageWrapper
extends java.lang.Object
implements Message

Constructor Summary

Constructors

Constructor and Description
MessageWrapper(Address targetAddress, TypedValue typedValue)

Method Summary

Modifier and Type	Method and Description
<T> T	as(Type<T> type)
boolean	asBoolean()
double	asDouble()
float	asFloat()
int	asInt()
long	asLong()
java.lang.String	asUtf8String()
boolean	equals(java.lang.Object o)
int	hashCode()
<T> boolean	is(Type<T> type)
boolean	isBoolean()
boolean	isDouble()
boolean	isFloat()
boolean	isInt()
boolean	isLong()
boolean	isUtf8String()
Slice	rawValue()
Address	targetAddress()
java.lang.String	toString()
TypedValue	typedValue()
TypeName	valueTypeName()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

MessageWrapper

public MessageWrapper(Address targetAddress,
                      TypedValue typedValue)

Method Detail

targetAddress

public Address targetAddress()

Specified by:

targetAddress in interface Message

isLong

public boolean isLong()

Specified by:

isLong in interface Message

asLong

public long asLong()

Specified by:

asLong in interface Message

isUtf8String

public boolean isUtf8String()

Specified by:

isUtf8String in interface Message

asUtf8String

public java.lang.String asUtf8String()

Specified by:

asUtf8String in interface Message

isInt

public boolean isInt()

Specified by:

isInt in interface Message

asInt

public int asInt()

Specified by:

asInt in interface Message

isBoolean

public boolean isBoolean()

Specified by:

isBoolean in interface Message

asBoolean

public boolean asBoolean()

Specified by:

asBoolean in interface Message

isFloat

public boolean isFloat()

Specified by:

isFloat in interface Message

asFloat

public float asFloat()

Specified by:

asFloat in interface Message

isDouble

public boolean isDouble()

Specified by:

isDouble in interface Message

asDouble

public double asDouble()

Specified by:

asDouble in interface Message

is

public <T> boolean is(Type<T> type)

Specified by:

is in interface Message

as

public <T> T as(Type<T> type)

Specified by:

as in interface Message

valueTypeName

public TypeName valueTypeName()

Specified by:

valueTypeName in interface Message

rawValue

public Slice rawValue()

Specified by:

rawValue in interface Message

typedValue

public TypedValue typedValue()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object