没有合适的资源?快使用搜索试试~ 我知道了~
automi:Go(alpha)的流处理API
共124个文件
go:96个
md:14个
txt:4个
需积分: 12 0 下载量 190 浏览量
2021-02-03
14:26:59
上传
评论
收藏 1.79MB ZIP 举报
温馨提示
Go(Alpha)的数据流处理API Automi是用于使用惯用的Go处理数据流的API。 使用Automi,程序可以通过组合应用于流的每个元素的操作阶段来处理数据块的流。 概念 Automi API用四个原语表达流,包括: 发射器:可以发射流元素的内存,网络或文件资源 流:代表流式传输数据元素的管道 流操作:可以附加到流上以处理流元素的代码 收集器:可以收集流式数据的内存,网络或文件资源。 Automi流在内部使用Go通道来路由数据。 这意味着Automi流将自动支持诸如缓冲,自动背压排队和并发安全性之类的功能。 使用Automi 现在,让我们探索一些示例,看看使用Automi传输和处理数据有多么容易。 请参阅目录中的所有示例。 示例:从切片流式传输到标准输出 第一个示例显示了使用Automi编写和表达流操作是多么容易。 在此示例中,符文值从切片中发出,并进行单独流式传输。 应用流运算符方法Filter过滤掉不需要的符文值,而Sort运算符方法对其余项进行排序。 最后,一个collector用于收集结果成io.Writer和通过管道输送到stdout 。 func ma
资源推荐
资源详情
资源评论
收起资源包目录
automi:Go(alpha)的流处理API (124个子文件)
csv 2.92MB
stats.csv 27KB
stats.csv 27KB
.gitignore 33B
funcs.go 17KB
stream_unaryop_test.go 9KB
stream_batch_test.go 8KB
funcs_test.go 8KB
unaryop_test.go 7KB
stream_batch.go 6KB
funcs_test.go 6KB
time.pb.go 6KB
stream.go 6KB
batch_test.go 5KB
funcs.go 5KB
csv.go 4KB
csv.go 4KB
batch.go 4KB
csv_test.go 3KB
collectcsv.go 3KB
collectslice.go 3KB
unaryop.go 3KB
csv_test.go 3KB
types.go 3KB
stream_test.go 3KB
binaryop.go 3KB
errorhandling.go 2KB
stream_unaryop.go 2KB
binaryop_test.go 2KB
scanner.go 2KB
stream_src_test.go 2KB
streamop.go 2KB
logging.go 2KB
streamop_test.go 2KB
reader.go 2KB
stream_log_test.go 2KB
func.go 2KB
context.go 2KB
md5.go 2KB
client.go 2KB
funcs.go 2KB
wordcount.go 2KB
writer.go 2KB
chan.go 2KB
slice.go 2KB
reflect_util.go 1KB
operations.go 1KB
sort_with.go 1KB
groupby_key.go 1KB
emitchan.go 1KB
sortby_key.go 1KB
emit_cust_slice.go 1KB
sumby_key.go 1KB
sortby_name.go 1KB
groupby_name.go 1KB
reader_test.go 1KB
scanner_test.go 1KB
writer_test.go 1KB
emitscanner.go 1KB
batch_triggers_test.go 1KB
emitreader.go 1KB
process.go 1KB
drain.go 1KB
chan_test.go 1KB
stats.go 1KB
sort.go 1KB
sum.go 1KB
sortby_pos.go 1KB
server.go 1010B
groupby_pos.go 1006B
sumby_name.go 995B
slice.go 953B
genwords.go 935B
genwords_test.go 926B
collectfunc.go 923B
sumby_pos.go 890B
null.go 861B
drain_test.go 849B
collectnull.go 848B
collectwriter.go 824B
echosvr.go 824B
httpsvr.go 815B
stream_binaryop.go 804B
main.go 803B
func_test.go 794B
main.go 789B
main.go 750B
main.go 734B
batch_triggers.go 700B
emit_rune_slice.go 695B
stream_binaryop_test.go 590B
slice_test.go 581B
slice_test.go 538B
null_test.go 511B
funcs_test.go 415B
log_util.go 181B
doc.go 158B
doc.go 90B
tuple.go 63B
doc.go 49B
共 124 条
- 1
- 2
资源评论
彭仕安
- 粉丝: 23
- 资源: 4679
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功