test_record_batch

Functions

_header(row_count, columns, payload_offset, payload_length) → dau_core.stream.BatchHeader
_column(field_id, offset, rows, width_bytes[, ...]) → dau_core.stream.ColumnDescriptor
test_valid_multi_column_batch_passes() → None
test_column_count_mismatch_rejected() → None
test_column_cap_enforced() → None
test_row_cap_enforced() → None
test_batch_extent_cap_enforced() → None
test_duplicate_field_ids_rejected() → None
test_overlapping_column_payloads_rejected() → None
test_misaligned_column_offset_rejected() → None
test_row_count_mismatch_rejected() → None

Module Contents

test_record_batch._header(row_count: int, columns: int, payload_offset: int, payload_length: int) → dau_core.stream.BatchHeader

test_record_batch._column(field_id: int, offset: int, rows: int, width_bytes: int, logical_type: dau_core.stream.LogicalType = LogicalType.INT32) → dau_core.stream.ColumnDescriptor

test_record_batch.test_valid_multi_column_batch_passes() → None

test_record_batch.test_column_count_mismatch_rejected() → None

test_record_batch.test_column_cap_enforced() → None

test_record_batch.test_row_cap_enforced() → None

test_record_batch.test_batch_extent_cap_enforced() → None

test_record_batch.test_duplicate_field_ids_rejected() → None

test_record_batch.test_overlapping_column_payloads_rejected() → None

test_record_batch.test_misaligned_column_offset_rejected() → None

test_record_batch.test_row_count_mismatch_rejected() → None