EndOfPartitionEvent (Flink : 2.0-preview1 API)

java.lang.Object
- org.apache.flink.runtime.event.AbstractEvent
- - org.apache.flink.runtime.event.RuntimeEvent
  - - org.apache.flink.runtime.io.network.api.EndOfPartitionEvent

All Implemented Interfaces:

IOReadableWritable
```
public class EndOfPartitionEvent
extends RuntimeEvent
```
This event marks a subpartition as fully consumed.

Field Summary

Fields
Modifier and Type Field Description

static EndOfPartitionEvent INSTANCE
The singleton instance of this event.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object obj)`
`int`	`hashCode()`
`void`	`read(DataInputView in)`	Reads the object's internal data from the given data input view.
`String`	`toString()`
`void`	`write(DataOutputView out)`	Writes the object's internal data to the given data output view.

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Field Detail
  - INSTANCE
```
public static final EndOfPartitionEvent INSTANCE
```
    The singleton instance of this event.
- Method Detail
  - read
```
public void read(DataInputView in)
```
    Description copied from interface: IOReadableWritable
    
    Reads the object's internal data from the given data input view.
    
    Parameters:
    
    in - the input view to read the data from
  - write
```
public void write(DataOutputView out)
```
    Description copied from interface: IOReadableWritable
    
    Writes the object's internal data to the given data output view.
    
    Parameters:
    
    out - the output view to receive the data.
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - equals
```
public boolean equals(Object obj)
```
    Overrides:
    
    equals in class Object
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object