apache_beam.coders.slow_stream module
A pure Python implementation of stream.pyx.
For internal use only; no backwards-compatibility guarantees.
-
class
apache_beam.coders.slow_stream.
OutputStream
[source]
Bases: object
For internal use only; no backwards-compatibility guarantees.
A pure Python implementation of stream.OutputStream.
-
write
(b, nested=False)[source]
-
write_byte
(val)[source]
-
write_var_int64
(v)[source]
-
write_bigendian_int64
(v)[source]
-
write_bigendian_uint64
(v)[source]
-
write_bigendian_int32
(v)[source]
-
write_bigendian_int16
(v)[source]
-
write_bigendian_double
(v)[source]
-
write_bigendian_float
(v)[source]
-
get
()[source]
-
size
()[source]
-
class
apache_beam.coders.slow_stream.
ByteCountingOutputStream
[source]
Bases: apache_beam.coders.slow_stream.OutputStream
For internal use only; no backwards-compatibility guarantees.
A pure Python implementation of stream.ByteCountingOutputStream.
-
write
(byte_array, nested=False)[source]
-
write_byte
(_)[source]
-
get_count
()[source]
-
get
()[source]
-
class
apache_beam.coders.slow_stream.
InputStream
(data)[source]
Bases: object
For internal use only; no backwards-compatibility guarantees.
A pure Python implementation of stream.InputStream.
-
size
()[source]
-
read
(size)[source]
-
read_all
(nested)[source]
-
read_byte
()[source]
-
read_var_int64
()[source]
-
read_bigendian_int64
()[source]
-
read_bigendian_uint64
()[source]
-
read_bigendian_int32
()[source]
-
read_bigendian_int16
()[source]
-
read_bigendian_double
()[source]
-
read_bigendian_float
()[source]
-
apache_beam.coders.slow_stream.
get_varint_size
(v)[source]
For internal use only; no backwards-compatibility guarantees.
Returns the size of the given integer value when encode as a VarInt.