fn create_unmatched_batch(
streamed_indices: &mut PrimitiveBuilder<UInt32Type>,
stream_batch: &SortedStreamBatch,
join_schema: Arc<Schema>,
) -> Result<RecordBatch>fn create_unmatched_batch(
streamed_indices: &mut PrimitiveBuilder<UInt32Type>,
stream_batch: &SortedStreamBatch,
join_schema: Arc<Schema>,
) -> Result<RecordBatch>