Part of #23494.
In datafusion-datasource-{csv,json,parquet}. Each DataSink implements try_to_proto + an inherent try_from_proto. Note: the new inherent try_from_proto intentionally replaces the old TryFromProto<&protobuf::*Sink> impls (a documented api-change). Blocked by #23498.
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.
Part of #23494.
In
datafusion-datasource-{csv,json,parquet}. EachDataSinkimplementstry_to_proto+ an inherenttry_from_proto. Note: the new inherenttry_from_protointentionally replaces the oldTryFromProto<&protobuf::*Sink>impls (a documented api-change). Blocked by #23498.Follow the pattern in #23494 (reference impl: #23495 /
ProjectionExec; full end-state draft: #23496). Addtry_to_protoinsideimpl ExecutionPlan for X, add the inherentX::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.