com.bigdata.journal

Class AbstractMROWTestCase.WriterTask

java.lang.Object

com.bigdata.journal.AbstractMROWTestCase.WriterTask

All Implemented Interfaces:

Callable<Integer>

Enclosing class:

AbstractMROWTestCase

public static class AbstractMROWTestCase.WriterTask
extends Object
implements Callable<Integer>

Run a writer.

The writer exposes state to the readers so that they can perform reads on written records and so that the can validate those reads against ground truth.

Constructor Summary

Constructors

Constructor and Description
AbstractMROWTestCase.WriterTask(IRawStore store, int reclen, long nwrites2, long writeDelayMillis)

Method Summary

Methods

Modifier and Type	Method and Description
Integer	call() Writes any remaining records (starts from nrecs and runs to nwrites so we can pre-write some records first).
AbstractMROWTestCase.Record	getRandomGroundTruthRecord() Return a randomly choosen ground truth record.
void	write() Write a random record and record it in records.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMROWTestCase.WriterTask

public AbstractMROWTestCase.WriterTask(IRawStore store,
                               int reclen,
                               long nwrites2,
                               long writeDelayMillis)

Method Detail

getRandomGroundTruthRecord

public AbstractMROWTestCase.Record getRandomGroundTruthRecord()

Return a randomly choosen ground truth record.

call

public Integer call()
             throws Exception

Writes any remaining records (starts from nrecs and runs to nwrites so we can pre-write some records first).

Specified by:

call in interface Callable<Integer>

Returns:

The #of records written.

Throws:

Exception

write

public void write()

Write a random record and record it in records.