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.