org.apache.flink.statefun.sdk.state

Class RemotePersistedValue

java.lang.Object

org.apache.flink.statefun.sdk.state.RemotePersistedValue

@ForRuntime
public final class RemotePersistedValue
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
void	clear()
Expiration	expiration()
byte[]	get()
java.lang.String	name()
static RemotePersistedValue	of(java.lang.String stateName, TypeName typeName)
static RemotePersistedValue	of(java.lang.String stateName, TypeName typeName, Expiration expiration)
void	set(byte[] value)
TypeName	type()

Methods inherited from class java.lang.Object

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

Method Detail

of

public static RemotePersistedValue of(java.lang.String stateName,
                                      TypeName typeName)

of

public static RemotePersistedValue of(java.lang.String stateName,
                                      TypeName typeName,
                                      Expiration expiration)

get

public byte[] get()

set

public void set(byte[] value)

clear

public void clear()

name

public java.lang.String name()

type

public TypeName type()

expiration

public Expiration expiration()