文件名称：swirl:高性能Erlang流处理器
文件大小：1.87MB
文件格式：ZIP
更新时间：2024-05-28 00:14:29
flow erlang high-performance stream-processing Erlang
漩涡 高性能Erlang流处理器 要求 Erlang 16.0以上 环境变量 名称 类型 默认 描述 mappers_max pos_integer（） 100 映射器的最大数量 reducers_max pos_integer（） 100 减速机最大数量 例子 开始流 ok = application : start ( swirl ), FlowMod = swirl_flow_example , FlowOpts = [ { stream_names , [ delivery ]}, { stream_filter , " exchange_id = 3 AND bidder_id IS NOT NULL " } ], MapperNodes = [ node ()], ReducerNode = node (), { ok , Flow } = swir
【文件预览】：
swirl-master
----.travis.yml(214B)
----rebar.lock(259B)
----bin()
--------rebar3(1.08MB)
--------elvis(788KB)
----test()
--------swirl_flow_example.erl(491B)
--------test.hrl(125B)
--------swirl_ql_tests.erl(3KB)
--------swirl_flow_tests.erl(2KB)
----rebar.config(1KB)
----include()
--------swirl.hrl(3KB)
----LICENSE(1KB)
----src()
--------swirl_flow.erl(5KB)
--------swirl_ql_parser.yrl(2KB)
--------swirl_tracker.erl(4KB)
--------swirl_sup.erl(486B)
--------swirl_config.erl(1KB)
--------swirl_reducer.erl(6KB)
--------swirl_mapper.erl(5KB)
--------swirl.app.src(243B)
--------swirl.erl(339B)
--------swirl_ql_lexer.xrl(1KB)
--------swirl_stream.erl(2KB)
--------swirl_ets_manager.erl(3KB)
--------swirl_ql.erl(2KB)
--------swirl_code_server.erl(2KB)
--------swirl_utils.erl(3KB)
----doc()
--------swirl_ql.md(2KB)
--------swirl_tracker.md(5KB)
--------swirl.md(768B)
--------swirl_flow.md(4KB)
--------swirl_utils.md(3KB)
--------swirl_mapper.md(6KB)
--------swirl_ets_manager.md(2KB)
--------swirl_ql_lexer.md(1KB)
--------swirl_code_server.md(2KB)
--------swirl_reducer.md(4KB)
--------swirl_config.md(2KB)
--------swirl_ql_parser.md(1KB)
--------swirl_stream.md(3KB)
--------swirl_sup.md(650B)
--------edoc-info(257B)
----.gitignore(104B)
----rebar.config.script(211B)
----elvis.config(1KB)
----Makefile(1020B)
----README.md(3KB)