Class StatisticsMergeBatch

All Implemented Interfaces:
AutoCloseable, Iterable<VectorWrapper<?>>, CloseableRecordBatch, RecordBatch, VectorAccessible

public class StatisticsMergeBatch extends AbstractSingleRecordBatch<StatisticsMerge>
Example input and output: Schema of incoming batch:
    "columns"       : MAP - Column names
       "region_id"  : VARCHAR
       "sales_city" : VARCHAR
       "cnt"        : VARCHAR
    "statscount" : MAP - Number of entries (rows)
       "region_id"  : BIGINT - statscount(region_id)
                      in incoming batch
       "sales_city" : BIGINT - statscount(sales_city)
       "cnt"        : BIGINT - statscount(cnt)
    "nonnullstatcount" : MAP - Number of non-null entries (rows)
       "region_id"  : BIGINT - nonnullstatcount(region_id)
       "sales_city" : BIGINT - nonnullstatcount(sales_city)
       "cnt"        : BIGINT - nonnullstatcount(cnt)
   .... another map for next stats function ....
 
Schema of outgoing batch:
    "schema" : BIGINT - Schema number. For each schema change this number is incremented.
    "computed" : DATE - What time is it computed?
    "columns"       : MAP - Column names
       "region_id"  : VARCHAR
       "sales_city" : VARCHAR
       "cnt"        : VARCHAR
    "statscount" : MAP - Number of entries (rows)
       "region_id"  : BIGINT - statscount(region_id) - aggregation over all values of region_id
                      in incoming batch
       "sales_city" : BIGINT - statscount(sales_city)
       "cnt"        : BIGINT - statscount(cnt)
    "nonnullstatcount" : MAP - Number of non-null entries (rows)
       "region_id"  : BIGINT - nonnullstatcount(region_id)
       "sales_city" : BIGINT - nonnullstatcount(sales_city)
       "cnt"        : BIGINT - nonnullstatcount(cnt)
   .... another map for next stats function ....