Package com.illumon.iris.db

Class ChunkMultiThreadedReader

java.lang.Object

com.illumon.iris.db.ChunkMultiThreadedReader

@ScriptApi
public class ChunkMultiThreadedReader
extends Object

Read a table in a parallel way. This is intended to be used for stress tests of the data pipeline.

Method Summary

Modifier and Type	Method	Description
static ChunkMultiThreadedReader	make(DynamicTable source, int divisions, int chunkSize)	Create and read the data.
void	readData()	Read the data from the table.

Methods inherited from class java.lang.Object

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

Method Details

make

public static ChunkMultiThreadedReader make(@NotNull
 DynamicTable source,
 int divisions,
 int chunkSize)

Create and read the data. You can re-read the data by calling readData()[

Parameters:

source - the source table

divisions - how many divisions to read the table in (the table is divided by rows)

chunkSize - how many rows to read at once

Returns:

a ChunkMultiThreadedReader for the source table

readData

public void readData()

Read the data from the table. Logs how many rows were read and how long the reads took after completion.