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