assertEquals("Email", columns[1]);
        assertEquals("Age", columns[2]);
        assertEquals("Department", columns[3]);

        // Verify row count
        final String rowCount = extractData.getValues("row_count")[0];
        assertEquals("4", rowCount);
    }

    public void test_getText_null() {
        try {
            csvExtractor.getText(null, null);
            fail();

            extractData.putValues("columns", headers);
            extractData.putValue("column_count", String.valueOf(headers.length));
        }

        extractData.putValue("row_count", String.valueOf(rows.size()));

        return extractData;
    }

    /**
     * Gets the character set from parameters or uses the default.
     *
     * @param params the parameters

  private final ImmutableMap<R, ImmutableMap<C, V>> rowMap;
  private final ImmutableMap<C, ImmutableMap<R, V>> columnMap;

  @SuppressWarnings("Immutable") // We don't modify this after construction.
  private final int[] rowCounts;

  @SuppressWarnings("Immutable") // We don't modify this after construction.
  private final int[] columnCounts;

  @SuppressWarnings("Immutable") // We don't modify this after construction.

	if !ok {
		v = newInQueueStats(r.registry, bucket)
	}
	atomic.AddInt64(&v.nowBytes, sz)
	atomic.AddInt64(&v.nowCount, 1)
	r.qCache.bucketStats[bucket] = v
	atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, sz)
	atomic.AddInt64(&r.qCache.srQueueStats.nowCount, 1)
}

func (r *ReplicationStats) decQ(bucket string, sz int64, isDelMarker bool, opType replication.Type) {
	r.qCache.Lock()