org.apache.flink.statefun.flink.state.processor.union

Class TaggedBootstrapData

java.lang.Object

org.apache.flink.statefun.flink.state.processor.union.TaggedBootstrapData

public class TaggedBootstrapData
extends java.lang.Object

Represents a single state bootstrap data entry, tagged with the address of its target StateBootstrapFunction as well as the index of its payload serializer within a union of multiple BootstrapDatasets.

See Also:

BootstrapDatasetUnion.apply(List)

Constructor Summary

Constructors

Constructor and Description
TaggedBootstrapData(Address target, java.lang.Object payload, int unionIndex)

Method Summary

Modifier and Type	Method and Description
TaggedBootstrapData	copy(org.apache.flink.api.common.typeutils.TypeSerializer<java.lang.Object> payloadSerializer)
static TaggedBootstrapData	createDefaultInstance()
java.lang.Object	getPayload()
Address	getTarget()
int	getUnionIndex()
void	setPayload(java.lang.Object payload)
void	setTarget(Address target)
void	setUnionIndex(int unionIndex)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaggedBootstrapData

public TaggedBootstrapData(Address target,
                           java.lang.Object payload,
                           int unionIndex)

Method Detail

createDefaultInstance

public static TaggedBootstrapData createDefaultInstance()

getTarget

public Address getTarget()

setTarget

public void setTarget(Address target)

getPayload

public java.lang.Object getPayload()

setPayload

public void setPayload(java.lang.Object payload)

getUnionIndex

public int getUnionIndex()

setUnionIndex

public void setUnionIndex(int unionIndex)

copy

public TaggedBootstrapData copy(org.apache.flink.api.common.typeutils.TypeSerializer<java.lang.Object> payloadSerializer)