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

Bases: future.types.newobject.newobject

For internal use only; no backwards-compatibility guarantees.

A pure Python implementation of stream.OutputStream.

write(b, nested=False)

write_byte(val)

write_var_int64(v)

write_bigendian_int64(v)

write_bigendian_uint64(v)

write_bigendian_int32(v)

write_bigendian_double(v)

get()

size()

class apache_beam.coders.slow_stream.ByteCountingOutputStream

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)

write_byte(_)

get_count()

get()

class apache_beam.coders.slow_stream.InputStream(data)

Bases: future.types.newobject.newobject

For internal use only; no backwards-compatibility guarantees.

A pure Python implementation of stream.InputStream.

size()

read(size)

read_all(nested)

read_byte_py2()

read_byte_py3()

read_var_int64()

read_bigendian_int64()

read_bigendian_uint64()

read_bigendian_int32()

read_bigendian_double()

apache_beam.coders.slow_stream.get_varint_size(v)

For internal use only; no backwards-compatibility guarantees.

Returns the size of the given integer value when encode as a VarInt.