Skip to content

Instantly share code, notes, and snippets.

use serde::de::{Deserialize, MapAccess, SeqAccess, Visitor};
struct CommandVec<'de> {
buffer: Vec<Command<'de>>,
}
#[derive(Debug)]
enum Command<'de> {
Null,
Bool(bool),
@frankmcsherry
frankmcsherry / gist:c702701daa1eda979ec75b2f11bd992b
Created December 10, 2019 03:10
Debezium date discrepancy
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
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" }
<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",
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;
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);
}
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;
<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,
<style>
.node rect {
cursor: pointer;
fill: #fff;
fill-opacity: 0.5;
stroke: #3182bd;
stroke-width: 1.5px;
}
<style>
.node rect {
cursor: pointer;
fill: #fff;
fill-opacity: 0.5;
stroke: #3182bd;
stroke-width: 1.5px;
}