test_record_batch_codec

Functions

_columns([rows]) → list[dau_driver.stream_codec.RecordBatchColumn]
test_record_batch_round_trip() → None
test_payload_regions_are_64_byte_aligned_and_non_overlapping() → None
test_operations_travel_with_the_batch() → None
test_arrow_round_trip() → None
test_arrow_batch_with_nulls_rejected() → None
test_arrow_batch_with_strings_rejected() → None
test_column_payload_length_mismatch_rejected() → None
test_limits_enforced_on_encode_and_decode() → None
test_truncated_batch_rejected() → None
test_prepared_taq_shaped_batch_round_trips() → None
test_arrow_encode_handles_sliced_arrays() → None

Module Contents

test_record_batch_codec._columns(rows: int = 4) → list[dau_driver.stream_codec.RecordBatchColumn]

test_record_batch_codec.test_record_batch_round_trip() → None

test_record_batch_codec.test_payload_regions_are_64_byte_aligned_and_non_overlapping() → None

test_record_batch_codec.test_operations_travel_with_the_batch() → None

test_record_batch_codec.test_arrow_round_trip() → None

test_record_batch_codec.test_arrow_batch_with_nulls_rejected() → None

test_record_batch_codec.test_arrow_batch_with_strings_rejected() → None

test_record_batch_codec.test_column_payload_length_mismatch_rejected() → None

test_record_batch_codec.test_limits_enforced_on_encode_and_decode() → None

test_record_batch_codec.test_truncated_batch_rejected() → None

test_record_batch_codec.test_prepared_taq_shaped_batch_round_trips() → None

test_record_batch_codec.test_arrow_encode_handles_sliced_arrays() → None