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: bytes, nested: bool = False) → None[source]
-
write_byte(val)[source]
-
write_var_int64(v: int) → None[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() → bytes[source]
-
size() → int[source]
-
class apache_beam.coders.slow_stream.ByteCountingOutputStream[source]
Bases: OutputStream
For internal use only; no backwards-compatibility guarantees.
A pure Python implementation of stream.ByteCountingOutputStream.
-
write(byte_array: bytes, nested: bool = False) → None[source]
-
write_byte(_)[source]
-
get_count()[source]
-
get()[source]
-
class apache_beam.coders.slow_stream.InputStream(data: bytes)[source]
Bases: object
For internal use only; no backwards-compatibility guarantees.
A pure Python implementation of stream.InputStream.
-
size()[source]
-
read(size: int) → bytes[source]
-
read_all(nested: bool) → bytes[source]
-
read_byte() → int[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.