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: apache_beam.coders.slow_stream.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.