LICENSE
README.md
setup.cfg
setup.py
examples/__init__.py
examples/basic_map.py
examples/basic_reduce.py
examples/word_count_file.py
fluxt/__init__.py
fluxt/batch.py
fluxt/cli.py
fluxt/globals.py
fluxt/operation.py
fluxt/state.py
fluxt/transaction.py
fluxt.egg-info/PKG-INFO
fluxt.egg-info/SOURCES.txt
fluxt.egg-info/dependency_links.txt
fluxt.egg-info/entry_points.txt
fluxt.egg-info/requires.txt
fluxt.egg-info/top_level.txt
fluxt/app/__init__.py
fluxt/app/app.py
fluxt/app/datastream.py
fluxt/app/graph.py
fluxt/serialization/__init__.py
fluxt/serialization/encoders.py
fluxt/serialization/types.py
fluxt/sinks/__init__.py
fluxt/sinks/base.py
fluxt/sinks/file.py
fluxt/sinks/stdout.py
fluxt/sources/__init__.py
fluxt/sources/base.py
fluxt/sources/collection.py
fluxt/sources/file.py
fluxt/sources/kafka_source.py
fluxt/storage/__init__.py
fluxt/storage/base.py
fluxt/storage/level.py
tests/__init__.py
tests/test_operation.py
tests/app/__init__.py
tests/app/test_app.py
tests/app/test_datastream.py
tests/app/test_graph.py
tests/cli/__init__.py
tests/cli/test_cli.py
tests/serialization/__init__.py
tests/serialization/test_encoders.py
tests/serialization/test_types.py