Class RSProcessors

java.lang.Object

io.nosqlbench.adapter.cqld4.RSProcessors

All Implemented Interfaces:

ResultProcessor<com.datastax.oss.driver.api.core.cql.AsyncResultSet,com.datastax.oss.driver.api.core.cql.Row>, Supplier<List<ResultSetProcessor>>

public class RSProcessors
extends Object
implements ResultProcessor<com.datastax.oss.driver.api.core.cql.AsyncResultSet,com.datastax.oss.driver.api.core.cql.Row>, Supplier<List<ResultSetProcessor>>

Constructor Summary

Constructors

Constructor	Description
RSProcessors()

Method Summary

Modifier and Type	Method	Description
RSProcessors	add(Supplier<ResultSetProcessor> processor)
void	buffer(com.datastax.oss.driver.api.core.cql.Row element)	For each element in the container, buffer it.
void	flush()	Once all the elements of the result have been buffered, flush must be called.
List<ResultSetProcessor>	get()
List<Supplier<ResultSetProcessor>>	getProcessors()
void	start(long cycle, com.datastax.oss.driver.api.core.cql.AsyncResultSet container)	Call the start method before any buffering of results.

Methods inherited from class java.lang.Object

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

Constructor Details

RSProcessors

public RSProcessors()

Method Details

get

public List<ResultSetProcessor> get()

Specified by:

get in interface Supplier<List<ResultSetProcessor>>

getProcessors

public List<Supplier<ResultSetProcessor>> getProcessors()

add

public RSProcessors add(Supplier<ResultSetProcessor> processor)

start

public void start(long cycle,
 com.datastax.oss.driver.api.core.cql.AsyncResultSet container)

Description copied from interface: ResultProcessor

Call the start method before any buffering of results.

Specified by:

start in interface ResultProcessor<com.datastax.oss.driver.api.core.cql.AsyncResultSet,com.datastax.oss.driver.api.core.cql.Row>

Parameters:

cycle - The cycle that the result is associated with. This is for presentation only.

container - The result object which holds individual result elements.

buffer

public void buffer(com.datastax.oss.driver.api.core.cql.Row element)

Description copied from interface: ResultProcessor

For each element in the container, buffer it. The effect of buffering is contextual. For ResultProcessors which need to see all the result data before applying its effect, simply buffer the elements to an internal container type.

Specified by:

buffer in interface ResultProcessor<com.datastax.oss.driver.api.core.cql.AsyncResultSet,com.datastax.oss.driver.api.core.cql.Row>

Parameters:

element -

flush

public void flush()

Description copied from interface: ResultProcessor

Once all the elements of the result have been buffered, flush must be called. ResultProcessors which need to see all the data can finish processing here.

Specified by:

flush in interface ResultProcessor<com.datastax.oss.driver.api.core.cql.AsyncResultSet,com.datastax.oss.driver.api.core.cql.Row>