RecordDeserializer (Flink : 2.0-SNAPSHOT API)

All Known Implementing Classes:

SpillingAdaptiveSpanningRecordDeserializer
```
public interface RecordDeserializer<T extends IOReadableWritable>
```
Interface for turning sequences of memory segments into records.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static class RecordDeserializer.DeserializationResult
Status of the deserialization result.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`clear()`
`RecordDeserializer.DeserializationResult`	`getNextRecord(T target)`
`CloseableIterator<Buffer>`	`getUnconsumedBuffer()`	Gets the unconsumed buffer which needs to be persisted in unaligned checkpoint scenario.
`void`	`setNextBuffer(Buffer buffer)`

- Method Detail
  - getNextRecord
```
RecordDeserializer.DeserializationResult getNextRecord(T target)
                                                throws IOException
```
    Throws:
    
    IOException
  - setNextBuffer
```
void setNextBuffer(Buffer buffer)
            throws IOException
```
    Throws:
    
    IOException
  - clear
```
void clear()
```
  - getUnconsumedBuffer
```
CloseableIterator<Buffer> getUnconsumedBuffer()
                                       throws IOException
```
    Gets the unconsumed buffer which needs to be persisted in unaligned checkpoint scenario.
    Note that the unconsumed buffer might be null if the whole buffer was already consumed before and there are no partial length or data remained in the end of buffer.
    
    Throws:
    
    IOException