Package com.atlassian.confluence.impl.backuprestore.restore.stash

Class ImportedObjectsStashImpl

java.lang.Object

com.atlassian.confluence.impl.backuprestore.restore.stash.ImportedObjectsStashImpl

All Implemented Interfaces:

ImportedObjectsStash

public class ImportedObjectsStashImpl
extends Object
implements ImportedObjectsStash

Allows to temporarily "stash" imported objects and then read them. For performance reasons, current implementation allows to write records first and read them only when all records are written. When the reading started, no more writing is allowed.

Since:

7.20.0

Constructor Summary

Constructors

Constructor	Description
ImportedObjectsStashImpl(String name, int iteration, StashObjectsWriter stashObjectsWriter, StashObjectsReader stashObjectsReader)

Method Summary

Modifier and Type	Method	Description
void	add(ImportedObjectV2 object)	Different threads can add objects to the stash in parallel.
Integer	getIterationNumber()
String	getName()
long	getNumberOfRetrievedObjects()
long	getNumberOfWrittenObjects()
boolean	hasMoreRecords()
List<ImportedObjectV2>	readObjects(int numberOfObjects)	Read a collection of objects from the stash.

Methods inherited from class java.lang.Object

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

Constructor Details

ImportedObjectsStashImpl

public ImportedObjectsStashImpl(String name,
 int iteration,
 StashObjectsWriter stashObjectsWriter,
 StashObjectsReader stashObjectsReader)

Method Details

add

public void add(ImportedObjectV2 object)
         throws BackupRestoreException

Different threads can add objects to the stash in parallel.

Specified by:

add in interface ImportedObjectsStash

Throws:

BackupRestoreException

readObjects

public List<ImportedObjectV2> readObjects(int numberOfObjects)
                                   throws BackupRestoreException

Description copied from interface: ImportedObjectsStash

Read a collection of objects from the stash. If the stash has fewer objects than numberOfObjects, all objects will be returned.

Specified by:

readObjects in interface ImportedObjectsStash

Parameters:

numberOfObjects - number of objects.

Returns:

collection of objects

Throws:

BackupRestoreException

getName

public String getName()

Specified by:

getName in interface ImportedObjectsStash

Returns:

stash name

getIterationNumber

public Integer getIterationNumber()

Specified by:

getIterationNumber in interface ImportedObjectsStash

Returns:

iteration number

getNumberOfWrittenObjects

public long getNumberOfWrittenObjects()

Specified by:

getNumberOfWrittenObjects in interface ImportedObjectsStash

Returns:

number of objects written to the stash.

getNumberOfRetrievedObjects

public long getNumberOfRetrievedObjects()

Specified by:

getNumberOfRetrievedObjects in interface ImportedObjectsStash

Returns:

number of objects read from the stash by this moment.

hasMoreRecords

public boolean hasMoreRecords()

Specified by:

hasMoreRecords in interface ImportedObjectsStash

Returns:

true if the stash has records to read.