beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [beam] branch master updated: Add a standard double coder urn.
Date Mon, 01 Apr 2019 09:05:29 GMT
This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 0799bf8  Add a standard double coder urn.
     new 88e1a93  Merge pull request #8166 Add a standard double coder.
0799bf8 is described below

commit 0799bf819a2dad3461697a561b8409f5d29ad463
Author: Robert Bradshaw <robertwb@google.com>
AuthorDate: Fri Mar 29 11:21:50 2019 +0100

    Add a standard double coder urn.
    
    Also add support for the Python SDK.
---
 model/pipeline/src/main/proto/beam_runner_api.proto | 5 +++++
 sdks/python/apache_beam/coders/coders.py            | 3 +++
 2 files changed, 8 insertions(+)

diff --git a/model/pipeline/src/main/proto/beam_runner_api.proto b/model/pipeline/src/main/proto/beam_runner_api.proto
index 4e819ed..fa2461f 100644
--- a/model/pipeline/src/main/proto/beam_runner_api.proto
+++ b/model/pipeline/src/main/proto/beam_runner_api.proto
@@ -554,6 +554,11 @@ message StandardCoders {
     // Components: None
     VARINT = 2 [(beam_urn) = "beam:coder:varint:v1"];
 
+    // Encodes the floating point value as a big-endian 64-bit integer
+    // according to the IEEE 754 double format bit layout.
+    // Components: None
+    DOUBLE = 11 [(beam_urn) = "beam:coder:double:v1"];
+
     // Encodes an iterable of elements.
     //
     // The encoding for an iterable [e1...eN] of known length N is
diff --git a/sdks/python/apache_beam/coders/coders.py b/sdks/python/apache_beam/coders/coders.py
index 2164161..7822d71 100644
--- a/sdks/python/apache_beam/coders/coders.py
+++ b/sdks/python/apache_beam/coders/coders.py
@@ -452,6 +452,9 @@ class FloatCoder(FastCoder):
     return hash(type(self))
 
 
+Coder.register_structured_urn(common_urns.coders.DOUBLE.urn, FloatCoder)
+
+
 class TimestampCoder(FastCoder):
   """A coder used for timeutil.Timestamp values."""
 


Mime
View raw message