RDF Stream Processing (continuous queries)

RDF Stream Processing — continuous-query and windowed-evaluation micro-benchmarks over streaming RDF.

Latest commit a40cf2a1 · every metric smaller-is-better · each group header shows a competitive summary computed live from real same-box competitor numbers (or an honest placeholder where none exist yet).

No same-box competitor baseline has been gathered for this suite yet — sparq's absolute numbers are shown below.

Benchmark	sparq	Unit
rsp persistentdict triples per (s)`rsp_persistentdict_triples_per_s`	2,591,538	triples_per_s
rsp sliding sum delta w0 rows`rsp_sliding_sum_delta_w0_rows`	2	rows
rsp sliding sum delta w1 rows`rsp_sliding_sum_delta_w1_rows`	1	rows
rsp sliding sum delta w2 rows`rsp_sliding_sum_delta_w2_rows`	2	rows
rsp sliding sum delta w3 rows`rsp_sliding_sum_delta_w3_rows`	2	rows
rsp sliding sum delta w4 rows`rsp_sliding_sum_delta_w4_rows`	1	rows
rsp sliding sum pdict w0 rows`rsp_sliding_sum_pdict_w0_rows`	2	rows
rsp sliding sum pdict w1 rows`rsp_sliding_sum_pdict_w1_rows`	1	rows
rsp sliding sum pdict w2 rows`rsp_sliding_sum_pdict_w2_rows`	2	rows
rsp sliding sum pdict w3 rows`rsp_sliding_sum_pdict_w3_rows`	2	rows
rsp sliding sum pdict w4 rows`rsp_sliding_sum_pdict_w4_rows`	1	rows
rsp sliding sum rebuild w0 rows`rsp_sliding_sum_rebuild_w0_rows`	2	rows
rsp sliding sum rebuild w1 rows`rsp_sliding_sum_rebuild_w1_rows`	1	rows
rsp sliding sum rebuild w2 rows`rsp_sliding_sum_rebuild_w2_rows`	2	rows
rsp sliding sum rebuild w3 rows`rsp_sliding_sum_rebuild_w3_rows`	2	rows
rsp sliding sum rebuild w4 rows`rsp_sliding_sum_rebuild_w4_rows`	1	rows
rsp srbench groupby state w0 rows`rsp_srbench_groupby_state_w0_rows`	2	rows
rsp srbench groupby state w1 rows`rsp_srbench_groupby_state_w1_rows`	2	rows
rsp srbench groupby state w2 rows`rsp_srbench_groupby_state_w2_rows`	2	rows
rsp srbench groupby state w3 rows`rsp_srbench_groupby_state_w3_rows`	0	rows
rsp srbench join w0 rows`rsp_srbench_join_w0_rows`	3	rows
rsp srbench join w1 rows`rsp_srbench_join_w1_rows`	2	rows
rsp srbench join w2 rows`rsp_srbench_join_w2_rows`	2	rows
rsp srbench join w3 rows`rsp_srbench_join_w3_rows`	0	rows
rsp tumbling avg delta w0 rows`rsp_tumbling_avg_delta_w0_rows`	1	rows
rsp tumbling avg delta w1 rows`rsp_tumbling_avg_delta_w1_rows`	1	rows
rsp tumbling avg delta w2 rows`rsp_tumbling_avg_delta_w2_rows`	1	rows
rsp tumbling avg delta w3 rows`rsp_tumbling_avg_delta_w3_rows`	1	rows
rsp tumbling avg delta w4 rows`rsp_tumbling_avg_delta_w4_rows`	1	rows
rsp tumbling avg pdict w0 rows`rsp_tumbling_avg_pdict_w0_rows`	1	rows
rsp tumbling avg pdict w1 rows`rsp_tumbling_avg_pdict_w1_rows`	1	rows
rsp tumbling avg pdict w2 rows`rsp_tumbling_avg_pdict_w2_rows`	1	rows
rsp tumbling avg pdict w3 rows`rsp_tumbling_avg_pdict_w3_rows`	1	rows
rsp tumbling avg pdict w4 rows`rsp_tumbling_avg_pdict_w4_rows`	1	rows
rsp tumbling avg rebuild w0 rows`rsp_tumbling_avg_rebuild_w0_rows`	1	rows
rsp tumbling avg rebuild w1 rows`rsp_tumbling_avg_rebuild_w1_rows`	1	rows
rsp tumbling avg rebuild w2 rows`rsp_tumbling_avg_rebuild_w2_rows`	1	rows
rsp tumbling avg rebuild w3 rows`rsp_tumbling_avg_rebuild_w3_rows`	1	rows
rsp tumbling avg rebuild w4 rows`rsp_tumbling_avg_rebuild_w4_rows`	1	rows
rsp tumbling groupby join delta w0 rows`rsp_tumbling_groupby_join_delta_w0_rows`	2	rows
rsp tumbling groupby join delta w1 rows`rsp_tumbling_groupby_join_delta_w1_rows`	2	rows
rsp tumbling groupby join delta w2 rows`rsp_tumbling_groupby_join_delta_w2_rows`	0	rows
rsp tumbling groupby join pdict w0 rows`rsp_tumbling_groupby_join_pdict_w0_rows`	2	rows
rsp tumbling groupby join pdict w1 rows`rsp_tumbling_groupby_join_pdict_w1_rows`	2	rows
rsp tumbling groupby join pdict w2 rows`rsp_tumbling_groupby_join_pdict_w2_rows`	0	rows
rsp tumbling groupby join rebuild w0 rows`rsp_tumbling_groupby_join_rebuild_w0_rows`	2	rows
rsp tumbling groupby join rebuild w1 rows`rsp_tumbling_groupby_join_rebuild_w1_rows`	2	rows
rsp tumbling groupby join rebuild w2 rows`rsp_tumbling_groupby_join_rebuild_w2_rows`	0	rows