Uses of Interface
org.gcube.documentstore.persistence.PersistenceExecutor

Packages that use PersistenceExecutor

Package	Description
org.gcube.documentstore.persistence
org.gcube.documentstore.records.aggregation

Uses of PersistenceExecutor in org.gcube.documentstore.persistence

Classes in org.gcube.documentstore.persistence that implement PersistenceExecutor

Modifier and Type	Class	Description
class	DefaultPersitenceExecutor

Uses of PersistenceExecutor in org.gcube.documentstore.records.aggregation

Fields in org.gcube.documentstore.records.aggregation declared as PersistenceExecutor

Modifier and Type	Field	Description
protected final PersistenceExecutor	AggregationScheduler.persistenceExecutor

Methods in org.gcube.documentstore.records.aggregation with parameters of type PersistenceExecutor

Modifier and Type	Method	Description
void	AggregationScheduler.aggregate(Record record, PersistenceExecutor persistenceExecutor)	Get a record and try to aggregate with other buffered Records.
protected void	AggregationScheduler.aggregate(Record record, PersistenceExecutor persistenceExecutor, boolean forceFlush)	Aggregates the record, if any, and persists the buffered records when it is time to, or when forced.
void	AggregationScheduler.flush(PersistenceExecutor persistenceExecutor)
void	AggregationScheduler.flushAfterWaiting(PersistenceExecutor persistenceExecutor, long timeout, TimeUnit timeUnit)	Persists the buffered records with the given executor after waiting, at most for the given time, for the persistence in progress, if any.
static AggregationScheduler	AggregationScheduler.newInstance(PersistenceExecutor persistenceExecutor)
static AggregationScheduler	AggregationScheduler.newInstance(PersistenceExecutor persistenceExecutor, PersistenceBackendConfiguration configuration)
protected void	AggregationScheduler.persist(PersistenceExecutor persistenceExecutor, Record[] recordsToPersist)	Persists the records, one persistence at a time for this scheduler.
protected void	AggregationScheduler.reallyFlush(PersistenceExecutor persistenceExecutor)

Constructors in org.gcube.documentstore.records.aggregation with parameters of type PersistenceExecutor

Modifier	Constructor	Description
protected	AggregationScheduler(PersistenceExecutor persistenceExecutor)
protected	AggregationScheduler(PersistenceExecutor persistenceExecutor, AggregationConfiguration config)
	BufferAggregationScheduler(PersistenceExecutor persistenceExecutor)
	BufferAggregationScheduler(PersistenceExecutor persistenceExecutor, AggregationConfiguration config)