ComplexPayload (Flink : 2.0-preview1 API)

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 Description

static class ComplexPayload.InnerPayLoad
Nested class in state type.

Constructor Summary

Constructors
Constructor Description

ComplexPayload(Event event)

ComplexPayload(Event event, String strPayload)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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()