This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| use serde::de::{Deserialize, MapAccess, SeqAccess, Visitor}; | |
| struct CommandVec<'de> { | |
| buffer: Vec<Command<'de>>, | |
| } | |
| #[derive(Debug)] | |
| enum Command<'de> { | |
| Null, | |
| Bool(bool), |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| kafka-avro-console-consumer --from-beginning --topic mysql.tpcch.customer --bootstrap-server localhost:9092 | grep '"mysql.tpcch.customer.Value":{"c_id":46,"c_d_id":7,"c_w_id":1' | |
| {"before":null,"after":{"mysql.tpcch.customer.Value":{"c_id":46,"c_d_id":7,"c_w_id":1,"c_first":{"string":"ndLUcD4Obmp"},"c_middle":{"string":"OE"},"c_last":{"string":"BARPRESESE"},"c_street_1":{"string":"oTJeZCyIdSgc"},"c_street_2":{"string":"Sa7TbYVQCEtg0s5CW9wE"},"c_city":{"string":"J9RKzZvAUFX"},"c_state":{"string":"nr"},"c_zip":{"string":"485311111"},"c_phone":{"string":"3857753553233294"},"c_since":{"int":18238},"c_credit":{"string":"GC"},"c_credit_lim":{"bytes":"LK@"},"c_discount":{"bytes":"\u0007e"},"c_balance":{"bytes":"ü\u0018"},"c_ytd_payment":{"bytes":"\u0003è"},"c_payment_cnt":{"int":1},"c_delivery_cnt":{"int":0},"c_data":{"string":"4lprImBI3cFg5fIYMkdvy@DUjcKt1uj0wjf5Diwjsv@I6iEvLbXHTJq50zBCivuC5LSJfbnQNSuQc5SJynNjU19fdjCGuD7EqxwmWuym68RW35rJpf6F5xq02zv9BsjYZATNR0sLTwxkLpfDmnASfOvZylXIEfRnJ8Z6d?GGkvXEIeeMhpiGM2l8PI7Iv80 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Cargo.toml | |
| [package] | |
| name = "zipkin" | |
| version = "0.1.0" | |
| authors = ["Frank McSherry <fmcsherry@me.com>"] | |
| [dependencies] | |
| timely = { git = "https://github.com/TimelyDataflow/timely-dataflow" } | |
| differential-dataflow = { git = "https://github.com/TimelyDataflow/differential-dataflow" } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <head> | |
| <script src="https://vega.github.io/vega/vega.js"></script> | |
| </head> | |
| <body> | |
| <div id="view"></div> | |
| <script type="text/javascript"> | |
| var my_spec = { | |
| "$schema": "https://vega.github.io/schema/vega/v4.json", |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| extern crate timely; | |
| extern crate differential_dataflow; | |
| extern crate actix; | |
| extern crate actix_web; | |
| extern crate futures; | |
| extern crate serde; | |
| #[macro_use] extern crate serde_derive; | |
| extern crate serde_json; |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| fn main() { | |
| let workers: usize = std::env::args().nth(1).unwrap().parse().unwrap(); | |
| let rounds: usize = std::env::args().nth(2).unwrap().parse().unwrap(); | |
| atomics(workers, rounds); | |
| mutex(workers, rounds); | |
| barrier(workers, rounds); | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| extern crate timely; | |
| extern crate differential_dataflow; | |
| extern crate actix; | |
| extern crate actix_web; | |
| extern crate futures; | |
| extern crate serde; | |
| #[macro_use] extern crate serde_derive; | |
| extern crate serde_json; |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <head> | |
| <script src="https://cdn.jsdelivr.net/npm/vega@4.0.0-rc.3"></script> | |
| <script type="text/javascript"> | |
| var my_spec = { | |
| "$schema": "https://vega.github.io/schema/vega/v4.json", | |
| "width": 400, | |
| "height": 200, | |
| "padding": 5, |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <style> | |
| .node rect { | |
| cursor: pointer; | |
| fill: #fff; | |
| fill-opacity: 0.5; | |
| stroke: #3182bd; | |
| stroke-width: 1.5px; | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <style> | |
| .node rect { | |
| cursor: pointer; | |
| fill: #fff; | |
| fill-opacity: 0.5; | |
| stroke: #3182bd; | |
| stroke-width: 1.5px; | |
| } |
NewerOlder