Operators

• Base
  • assert_()
  • assert_1()
  • count()
  • distinct()
  • distinct_until_changed()
  • do_action()
  • filter()
  • first()
  • flat_map()
  • from_iterable()
  • group_by()
  • identity()
  • last()
  • map()
  • multiplex()
  • progress()
  • scan()
  • starmap()
  • start_with()
  • take()
  • tee_map()
  • with_latest_from()
• Error
  • create_error_router()
  • ignore()
  • map()
• Math
  • max()
  • mean()
  • min()
  • stddev()
  • sum()
  • variance()
  • Distributed
    • describe()
    • histogram()
    • max()
    • mean()
    • merge()
    • min()
    • quantile()
    • stddev()
    • update()
    • variance()
  • Formal
    • stddev()
    • variance()
• Container
  • csv
    • create_line_parser()
    • dump()
    • dump_to_file()
    • load()
    • load_from_file()
  • json
    • dump()
    • dump_to_file()
    • load()
    • load_from_file()
  • parquet
    • dump_to_file()
    • load_from_file()
• Data
  • batch()
  • cache()
  • clip()
  • decode()
  • encode()
  • fill_none()
  • lag()
  • roll()
  • sort()
  • split()
  • time_split()
  • to_array()
  • to_deque()
  • to_list()
• IO
  • read()
  • walk()
  • write()
• Framing
  • line
    • frame()
    • unframe()
  • length prefix
    • frame()
    • unframe()
• Compression
  • gzip
    • compress()
    • decompress()
  • zstd
    • compress()
    • decompress()
• State
  • MemoryStore
  • with_memory_store()
  • with_store()