This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch release-2.72
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.72 by this push:
     new bc8edf7d370 revert 'Optimize data size estimation for proto coder.' 
(#37710)
bc8edf7d370 is described below

commit bc8edf7d3709ac4423e92ae61bec0ef2a80c5809
Author: RadosÅ‚aw Stankiewicz <[email protected]>
AuthorDate: Thu Feb 26 15:00:03 2026 +0100

    revert 'Optimize data size estimation for proto coder.' (#37710)
---
 sdks/python/apache_beam/coders/coder_impl.py | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/sdks/python/apache_beam/coders/coder_impl.py 
b/sdks/python/apache_beam/coders/coder_impl.py
index 2a3ce2cc882..3e0b5218b16 100644
--- a/sdks/python/apache_beam/coders/coder_impl.py
+++ b/sdks/python/apache_beam/coders/coder_impl.py
@@ -316,9 +316,6 @@ class ProtoCoderImpl(SimpleCoderImpl):
     proto_message.ParseFromString(encoded)  # This is in effect "ParsePartial".
     return proto_message
 
-  def estimate_size(self, value, nested=False):
-    return self._get_nested_size(value.ByteSize(), nested)
-
 
 class DeterministicProtoCoderImpl(ProtoCoderImpl):
   """For internal use only; no backwards-compatibility guarantees."""
@@ -338,9 +335,6 @@ class ProtoPlusCoderImpl(SimpleCoderImpl):
   def decode(self, value):
     return self.proto_plus_type.deserialize(value)
 
-  def estimate_size(self, value, nested=False):
-    return self._get_nested_size(type(value).pb(value).ByteSize(), nested)
-
 
 UNKNOWN_TYPE = 0xFF
 NONE_TYPE = 0

Reply via email to