org.corfudb.infrastructure

Class BatchProcessor

java.lang.Object

org.corfudb.infrastructure.BatchProcessor

All Implemented Interfaces:

AutoCloseable

public class BatchProcessor
extends Object
implements AutoCloseable

This class manages access for operations that need ordering while executing against the backing storage.

Constructor Summary

Constructors

Constructor and Description
BatchProcessor(StreamLog streamLog, long sealEpoch, boolean sync) Returns a new BatchProcessor for a stream log.

Method Summary

Modifier and Type	Method and Description
<T> CompletableFuture<T>	addTask(BatchWriterOperation.Type type, CorfuPayloadMsg msg) Add a task to the processor.
void	close()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchProcessor

public BatchProcessor(StreamLog streamLog,
                      long sealEpoch,
                      boolean sync)

Returns a new BatchProcessor for a stream log.

Parameters:

streamLog - stream log for writes (can be in memory or file)

sealEpoch - All operations stamped with epoch less than the epochWaterMark are discarded.

streamLog - the backing log (can be in memory or file)

sync - If true, the batch writer will sync writes to secondary storage

Method Detail

addTask

public <T> CompletableFuture<T> addTask(@Nonnull
                                        BatchWriterOperation.Type type,
                                        @Nonnull
                                        CorfuPayloadMsg msg)

Add a task to the processor.

Parameters:

type - The request type

msg - The request message

Returns:

returns a future result for the request, if it expects one

close

public void close()

Specified by:

close in interface AutoCloseable