TermStreamer

TermStreamer()

A term streamer that can handle large expressions, by streaming terms to and from disk.

Methods

Name Description
fits_in_memory Check if the term stream fits in memory.
get_byte_size Get the byte size of the term stream.
get_num_terms Get the number of terms in the stream.
map Apply a transformer to all terms in the stream.
map_single_thread Apply a transformer to all terms in the stream using a single thread.
normalize Sort and fuse all terms in the stream.
push Push an expresssion to the term stream.
to_expression Convert the term stream into an expression. This may exceed the available memory.

fits_in_memory

TermStreamer.fits_in_memory()

Check if the term stream fits in memory.

get_byte_size

TermStreamer.get_byte_size()

Get the byte size of the term stream.

get_num_terms

TermStreamer.get_num_terms()

Get the number of terms in the stream.

map

TermStreamer.map(f)

Apply a transformer to all terms in the stream.

map_single_thread

TermStreamer.map_single_thread(f)

Apply a transformer to all terms in the stream using a single thread.

normalize

TermStreamer.normalize()

Sort and fuse all terms in the stream.

push

TermStreamer.push(expr)

Push an expresssion to the term stream.

to_expression

TermStreamer.to_expression()

Convert the term stream into an expression. This may exceed the available memory.