pyflink.multimodal.utils.scatter_results

scatter_results(results, valid_indices, total_len, default=None)

Place batch results back at their original indices.

Batch UDF helpers may skip corrupt or None inputs before invoking an expensive model. This helper restores those valid-row results to the original batch length and fills skipped positions with default.