Class RSIterableCapture

java.lang.Object
io.nosqlbench.adapter.cqld4.processors.RSIterableCapture
All Implemented Interfaces:
ResultSetProcessor, ResultProcessor<com.datastax.oss.driver.api.core.cql.AsyncResultSet,com.datastax.oss.driver.api.core.cql.Row>
public class RSIterableCapture extends Object implements ResultSetProcessor
An accumulator for rows, sized to a page of results.

  • Constructor Summary

    Constructors
    Constructor
    Description
    RSIterableCapture()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    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.
    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

    • RSIterableCapture

      public RSIterableCapture()

  • Method Details

    • 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>