Class BatchedDataPoints

src/core/BatchedDataPoints.java:34–525

Receives new data points and stores them in compacted form. No points are written until flushNow is called. This ensures that true batch dynamics can be leveraged. This implementation will allow an entire hours worth of data to be written in a single transaction to the data table.

 * worth of data to be written in a single transaction to the data table.
 */
final class BatchedDataPoints implements WritableDataPoints {

  /**
   * The {@code TSDB} instance we belong to.
   */
  private final TSDB tsdb;

  /**
   * The row key. Optional salt + 3 bytes for the metric name, 4 bytes for the 
   * base timestamp, 6 bytes per tag (3 for the name, 3 for the value).
   */
  private byte[] row_key;

  /**
   * Track the last timestamp written for this series.
   */
  private long last_timestamp;

  /**
   * Number of data points in this row.
   */
  private int size = 0;

  /**
   * Storage of the compacted qualifier.
   */
  private byte[] batched_qualifier = new byte[Const.MAX_TIMESPAN * 4];

  /**
   * Storage of the compacted value.
   */
  private byte[] batched_value = new byte[Const.MAX_TIMESPAN * 8];

  /**
   * Track the index position where the next qualifier gets written.
   */
  private int qualifier_index = 0;

  /**
   * Track the index position where the next value gets written.
   */
  private int value_index = 0;

  /**
   * Track the base time for this batch of points.
   */
  private long base_time;

  /**
   * Constructor.
   * 
   * @param tsdb The TSDB we belong to.
   */
  BatchedDataPoints(final TSDB tsdb, final String metric, 
      final Map<String, String> tags) {
    this.tsdb = tsdb;
    setSeries(metric, tags);
  }