All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

APartitionTransactionContentReader, DropPartitionTransactionContentReader, IncrementalPartitionTransactionContentReader, InitialPartitionTransactionContentReader
```
public interface IPartitionTransactionContentReader
extends AutoCloseable
```
An object responsible for reading an IPartitionTransactionContent.
Do not keep any strong reference to this in non transient objects instance to prevent memory leaks.

Author:

ActiveViam

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`close()`
`IWritableRecordBlock<IRecordReader>`	`createRecordBlock()`	Creates a `IWritableRecordBlock` able to be filled with the records affected by the transaction.
`IWritableRecordBlock<IRecordReader>`	`createRecordBlock(int size)`	Creates a `IWritableRecordBlock` able to be filled with the records affected by the transaction.
`IRecordStream`	`getAddedRecordsStream()`	Gets the stream responsible for providing the records added in the partition by the transaction.
`IRecordStream`	`getDeletedRecordsStream()`	Gets the stream responsible for providing the records deleted in the partition by the transaction.
`IDroppedRecordStream`	`getDroppedContentStream()`	Gets the stream responsible for providing the records that have been dropped.
`IPair<IRecordStream,IRecordStream>`	`getUpdatedRecordsStreams()`	Gets the pair of records stream providing the records that have been updated.

- Method Detail
  - getAddedRecordsStream
```
IRecordStream getAddedRecordsStream()
```
    Gets the stream responsible for providing the records added in the partition by the transaction.
    
    Returns:
    
    the stream of added records, or null if no record has been added
  - getDeletedRecordsStream
```
IRecordStream getDeletedRecordsStream()
```
    Gets the stream responsible for providing the records deleted in the partition by the transaction.
    
    Returns:
    
    the stream of deleted records, or null if no record has been deleted
  - getUpdatedRecordsStreams
```
IPair<IRecordStream,IRecordStream> getUpdatedRecordsStreams()
```
    Gets the pair of records stream providing the records that have been updated.
    The left stream contains the new records, the right stream the old ones.
    
    Returns:
    
    the pair (newValues, oldValues) of record streams providing updated records, or null if no update occurred
  - getDroppedContentStream
```
IDroppedRecordStream getDroppedContentStream()
```
    Gets the stream responsible for providing the records that have been dropped.
    
    Returns:
    
    the stream of dropped records, or null if none have been dropped
  - createRecordBlock
```
IWritableRecordBlock<IRecordReader> createRecordBlock(int size)
```
    Creates a IWritableRecordBlock able to be filled with the records affected by the transaction.
    
    Parameters:
    
    size - the size of the record block to create
    
    Returns:
    
    a record block able to receive the content exposed by this reader
  - createRecordBlock
```
IWritableRecordBlock<IRecordReader> createRecordBlock()
```
    Creates a IWritableRecordBlock able to be filled with the records affected by the transaction.
    
    Returns:
    
    a record block able to receive the content exposed by this reader
  - close
```
void close()
```
    Specified by:
    
    close in interface AutoCloseable

Interface IPartitionTransactionContentReader

Method Summary

Method Detail

getAddedRecordsStream

getDeletedRecordsStream

getUpdatedRecordsStreams

getDroppedContentStream

createRecordBlock

createRecordBlock

close