RecordBatch constructor

Implementation

RecordBatch(this.schema, List<ArrowArray> columns, {int? rowCount})
  : columns = List.unmodifiable(columns),
    rowCount = rowCount ?? (columns.isEmpty ? 0 : columns.first.length) {
  if (this.rowCount < 0) {
    throw RangeError.value(this.rowCount, 'rowCount', 'must be non-negative');
  }
  if (columns.length != schema.fields.length) {
    throw ArgumentError(
      'Column count ${columns.length} does not match schema field count ${schema.fields.length}',
    );
  }
  for (var i = 0; i < columns.length; i++) {
    final field = schema.fields[i];
    final column = columns[i];
    if (column.type != field.type) {
      throw ArgumentError(
        'Column $i (${field.name}) datatype does not match schema',
      );
    }
    if (column.length != this.rowCount) {
      throw ArgumentError(
        'Column $i (${field.name}) length ${column.length} does not match row count ${this.rowCount}',
      );
    }
    if (!field.nullable && column.validity.any((valid) => !valid)) {
      throw ArgumentError('Column $i (${field.name}) is not nullable');
    }
  }
}