Package org.gridgain.internal.snapshots

Class TableSnapshotReader

java.lang.Object

org.gridgain.internal.snapshots.TableSnapshotReader

All Implemented Interfaces:

org.gridgain.internal.recovery.TableDataProvider

public class TableSnapshotReader
extends Object
implements org.gridgain.internal.recovery.TableDataProvider

Class for restoring a Snapshot for a table.

Constructor Summary

Constructors

Constructor	Description
TableSnapshotReader(TableSnapshotMeta tableSnapshotMeta, SnapshotFileSystem snapshotFileSystem, int version, UUID operationId, int tableId, String tableName, int chunkSize)	Constructor.

Method Summary

Modifier and Type	Method	Description
Flow.Publisher<org.apache.ignite.internal.storage.BinaryRowAndRowId>	partitionDataAsync(int partition, ExecutorService executorService)

Methods inherited from class java.lang.Object

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

Constructor Details

TableSnapshotReader

public TableSnapshotReader(TableSnapshotMeta tableSnapshotMeta,
 SnapshotFileSystem snapshotFileSystem,
 int version,
 UUID operationId,
 int tableId,
 String tableName,
 int chunkSize)

Constructor.

Method Details

partitionDataAsync

public Flow.Publisher<org.apache.ignite.internal.storage.BinaryRowAndRowId> partitionDataAsync(int partition,
 ExecutorService executorService)

The returned publisher opens the partition file eagerly when subscribed to and relies on a terminal signal or a cancellation to close it: the subscriber must eventually exhaust the stream or cancel the subscription, otherwise the file handle leaks.

Specified by:

partitionDataAsync in interface org.gridgain.internal.recovery.TableDataProvider