Repository navigation
Proto: migrate ParquetSource #23517
Description
Part of #23494.
datafusion-datasource-parquet. Like the simple scans plus the pushdown predicate (via ctx.encode_expr/decode_expr) and TableParquetOptions (via proto-common); rebuild the reader factory from ctx.task_ctx().runtime_env(). Blocked by #23497.
Follow the pattern in #23494 (reference impl: #23495 / ProjectionExec; full end-state draft: #23496). Add try_to_proto inside impl ExecutionPlan for X, add the inherent X::try_from_proto, repoint the decode arm, and delete the old central arm in the same PR (that is the proof the hook is reached). Keep the wire format byte-for-byte identical.
Metadata
Metadata
Assignees
Labels
No labels
Activity
buraksenn commentedon Jul 22, 2026
take
adriangb commentedon Aug 7, 2026
@buraksenn you should be able to work on this now
buraksenn commentedon Aug 7, 2026
I've already implemented from @kumarUjjawal PR a while back. Rebasing to main and opening a PR soon for this and #23516
Add DataSource/FileSource proto hooks and FileScanConfig serde (apac…
refactor(proto): migrate ParquetSource serde (apache#24169)
Add DataSource/FileSource proto hooks and FileScanConfig serde (apac…
refactor(proto): migrate ParquetSource serde (apache#24169)