python-stream
说明
数据流式框架, 可用作数据清洗, 数据预处理, 数据迁移等应用场景
更优雅的流式数据处理方式
安装
pip install git+https://github.com/sandabuliu/python-stream.git
or
git clone https://github.com/sandabuliu/python-stream.git
cd python-agent
python setup.py install
QuickStart
Examples
Word Count
from pystream.executor.source import Memory
from pystream.executor.executor import Map, Iterator, ReducebyKey
data = Memory([
'W
1