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: future.types.newobject.newobject

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_double(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: future.types.newobject.newobject

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_py2()[source]
read_byte_py3()[source]
read_var_int64()[source]
read_bigendian_int64()[source]
read_bigendian_uint64()[source]
read_bigendian_int32()[source]
read_bigendian_double()[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.