org.apache.flink.streaming.tests.artificialstate

Class ComplexPayload

java.lang.Object

org.apache.flink.streaming.tests.artificialstate.ComplexPayload

All Implemented Interfaces:

Serializable

public class ComplexPayload
extends Object
implements Serializable

A state type used in the DataStreamAllroundTestProgram. Wraps an Event as state.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ComplexPayload.InnerPayLoad Nested class in state type.

Constructor Summary

Constructors

Constructor and Description
ComplexPayload(Event event)
ComplexPayload(Event event, String strPayload)

Method Summary

Modifier and Type	Method and Description
long	getEventTime()
ComplexPayload.InnerPayLoad	getInnerPayLoad()
List<String>	getStringList()
String	getStrPayload()

Methods inherited from class java.lang.Object

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

Constructor Detail

ComplexPayload

public ComplexPayload(Event event,
                      String strPayload)

ComplexPayload

public ComplexPayload(Event event)

Method Detail

getEventTime

public long getEventTime()

getStringList

public List<String> getStringList()

getStrPayload

public String getStrPayload()

getInnerPayLoad

public ComplexPayload.InnerPayLoad getInnerPayLoad()