没有合适的资源?快使用搜索试试~ 我知道了~
storey:实时数据+ ML管道
共154个文件
py:38个
woff:15个
woff2:15个
需积分: 9 0 下载量 126 浏览量
2021-03-25
20:24:49
上传
评论
收藏 3.7MB ZIP 举报
温馨提示
层 Storey是一个异步流媒体库,用于实时事件处理和功能提取。 在本文件中 :play_button: 有关更多信息,请参见。 API演练 Storey流包含由build_flow函数链接在一起的步骤,每个步骤都执行其指定的工作。 支持的步骤 输入步骤 Source AsyncSource ReadCSV ReadParquet DataframeSource 处理步骤 Filter Map FlatMap MapWithState Batch(max_events, timeout) -批量处理事件。 此步骤每隔max_events个事件发出一个批处理,或者从接收到批处理中的第一个事件起经过超时秒数后,将发出一个批处理。 Choice JoinWithV3IOTable SendToHttp AggregateByKey(aggregations,cache, key=None,
资源推荐
资源详情
资源评论
收起资源包目录
storey:实时数据+ ML管道 (154个子文件)
make.bat 795B
.buildinfo 230B
setup.cfg 59B
index.f658d18f9b420779cfdf24aa0a7e2d77.css 148KB
all.min.css 57KB
sphinx-book-theme.40e2e510f6b7d1648584402491bb10fe.css 37KB
sphinx-book-theme.css 12KB
basic.css 12KB
pygments.css 5KB
index.css 4KB
index.css 4KB
early_sense.csv 12.65MB
test-with-timestamp.csv 70B
test-with-timestamp-nanosecs.csv 70B
test-with-timestamp-microsecs.csv 64B
test-with-compact-timestamp.csv 52B
test-with-none-values.csv 48B
test.csv 21B
test-no-header.csv 12B
.dockerignore 5B
api.doctree 314KB
examples.doctree 5KB
index.doctree 4KB
overview.doctree 3KB
fa-solid-900.eot 198KB
fa-brands-400.eot 130KB
fa-regular-400.eot 34KB
api.html 89KB
genindex.html 17KB
examples.html 12KB
index.html 8KB
py-modindex.html 7KB
overview.html 7KB
search.html 6KB
webpack-macros.html 1KB
MANIFEST.in 132B
objects.inv 853B
jquery-3.4.1.js 274KB
jquery.js 86KB
index.d3f166471bb80abb5163.js 81KB
underscore-1.3.1.js 34KB
searchtools.js 16KB
underscore.js 12KB
language_data.js 11KB
doctools.js 9KB
searchindex.js 8KB
sphinx-book-theme.d31b09fe5c1d09cb49b26a786de4a05d.js 3KB
documentation_options.js 323B
LICENSE 11KB
Makefile 949B
Makefile 634B
README.md 4KB
LICENSE.md 1KB
LICENSE.md 1KB
test.parquet 3KB
environment.pickle 22KB
logo_colab.png 7KB
file.png 286B
minus.png 90B
plus.png 90B
test_aggregate_by_key.py 72KB
test_flow.py 71KB
test_aggregation_integration.py 66KB
table.py 55KB
flow.py 42KB
writers.py 32KB
sources.py 27KB
drivers.py 22KB
test_flow_integration.py 18KB
dtypes.py 14KB
aggregations.py 13KB
test_steps.py 10KB
test_azure_filesystem_integration.py 8KB
test_filesystems_integration.py 8KB
test_s3_filesystem_integration.py 7KB
windowed_store.py 7KB
integration_test_utils.py 7KB
utils.py 5KB
assertion.py 5KB
bench_flow.py 5KB
test_aggregate_store.py 4KB
dataframe.py 4KB
aggregation_utils.py 3KB
sample.py 2KB
test_types.py 2KB
conf.py 2KB
setup.py 2KB
test_windowed_store.py 2KB
partition.py 1KB
__init__.py 1KB
test_v3io.py 794B
flatten.py 566B
set-version.py 497B
foreach.py 332B
__init__.py 248B
__init__.py 0B
__init__.py 0B
__init__.py 0B
index.rst 3KB
examples.rst 1KB
共 154 条
- 1
- 2
资源评论
菊次郎的回南天
- 粉丝: 40
- 资源: 4565
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功