com.bigdata.journal

Class AbstractMRMWTestCase.WriterTask

java.lang.Object

com.bigdata.journal.AbstractMRMWTestCase.WriterTask

All Implemented Interfaces:

Callable<Integer>

Enclosing class:

AbstractMRMWTestCase

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

Run a writer.

The writer uses a AbstractMRMWTestCase.GroundTruth object to expose 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
AbstractMRMWTestCase.WriterTask(AbstractMRMWTestCase.GroundTruth groundTruth, IRawStore store, int reclen, int nwrites, boolean forceToDisk)

Method Summary

Methods

Modifier and Type	Method and Description
Integer	call() Writes N records.
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

AbstractMRMWTestCase.WriterTask

public AbstractMRMWTestCase.WriterTask(AbstractMRMWTestCase.GroundTruth groundTruth,
                               IRawStore store,
                               int reclen,
                               int nwrites,
                               boolean forceToDisk)

Parameters:

groundTruth - Used to store ground truth for written records.

store - The store on which records will be written.

reclen - The maximum record length to write - random length records of up to this length will be written.

nwrites - The #of records to write.

Method Detail

call

public Integer call()
             throws Exception

Writes N records.

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.