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: object

For internal use only; no backwards-compatibility guarantees.

A pure Python implementation of stream.OutputStream.

write(b: bytes, nested: bool = False) → None

write_byte(val)

write_var_int64(v: int) → None

write_bigendian_int64(v)

write_bigendian_uint64(v)

write_bigendian_int32(v)

write_bigendian_int16(v)

write_bigendian_double(v)

write_bigendian_float(v)

get() → bytes

size() → int

class apache_beam.coders.slow_stream.ByteCountingOutputStream

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

write_byte(_)

get_count()

get()

class apache_beam.coders.slow_stream.InputStream(data: bytes)

Bases: object

For internal use only; no backwards-compatibility guarantees.

A pure Python implementation of stream.InputStream.

size()

read(size: int) → bytes

read_all(nested: bool) → bytes

read_byte() → int

read_var_int64()

read_bigendian_int64()

read_bigendian_uint64()

read_bigendian_int32()

read_bigendian_int16()

read_bigendian_double()

read_bigendian_float()

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.