Name		Name	Last commit message	Last commit date
parent directory ..
aggregate		aggregate
datetime		datetime
demo		demo
functions		functions
get_value		get_value
import_python		import_python
insert_types		insert_types
joins		joins
json		json
logic_operation		logic_operation
loop		loop
mathematical		mathematical
memory_temporary_storage		memory_temporary_storage
nginx-log		nginx-log
parameter_variable		parameter_variable
raw_query		raw_query
strings		strings
time_window		time_window
transform		transform
type_annotation		type_annotation
window_aggregate		window_aggregate
yield_data		yield_data
README.md		README.md

README.md

示例详解

mathematical

数字和数学计算

strings

字符串处理

parameter_variable

动态参数变量

type_annotation

类型注解，不同数据库join时需保证类型一致，如Mongo的主键_id保存到mysql时一般为varchar，join查询需做类型转换保证类型一致

get_value

读取复杂数据结构值

yield_data

数组展开

import_python

导入Python模块调用自定义函数

memory_temporary_storage

使用内存保存临时结果

json

JSON函数

aggregate

聚合计算

transform

transform数据转换（纵横表转换）

raw_query

可在SQL中添加raw query查询，充分利用数据库功能及性能

insert_types

insert into指定合并数据类型（插入 I，更新否则插入 UI，更新否则插入其余删除 UDI，先删除再插入 DI）

demo

查询JSON文件统计每个站点订单额

nginx-log

查询Nginx日志文件统计访问量最多的前3个IP