Skip to content

Instantly share code, notes, and snippets.

View benesch's full-sized avatar

Nikhil Benesch benesch

256 followers · 0 following
View GitHub Profile
@benesch
benesch / gist:288674bae2fcd6376ceaa2714547ed03
Last active July 24, 2020 15:14
select * from generate_series(100,200) g,
lateral (select * from int8_tbl a where g = q1 union all
select * from int8_tbl b where g = q2) ss
building:
%0 =
| Constant (100) (101) (102) (103) (104) (105) (106) (107) (108) (109) (110) (111) (112) (113) (114) (115) (116) (117) (118) (119) (120) (121) (122) (123) (124) (125) (126) (127) (128) (129) (130) (131) (132) (133) (134) (135) (136) (137) (138) (139) (140) (141) (142) (143) (144) (145) (146) (147) (148) (149) (150) (151) (152) (153) (154) (155) (156) (157) (158) (159) (160) (161) (162) (163) (164) (165) (166) (167) (168) (169) (170) (171) (172) (173) (174) (175) (176) (177) (178) (179) (180) (181) (182) (183) (184) (185) (186) (187) (188) (189) (190) (191) (192) (193) (194) (195) (196) (197) (198) (199) (200)
%1 =
@benesch
benesch / gist:787791fa96cc75660ecb29cd37d49ddc
Created May 3, 2020 06:05
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: MEMBERID [thrd:app]: Group "materialize-kafka-u1/u2": updating member id "(not-set)" -> ""
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: GroupCoordinator: Added new broker with NodeId -1
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: INIT [thrd:app]: librdkafka v1.4.2 (0x10402ff) materialized#consumer-3 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,sasl_oauthbearer, CMAKE GNU GNU PKGCONFIG HDRHISTOGRAM ZLIB LIBDL PLUGINS SSL SASL_SCRAM SASL_OAUTHBEARER SASL_CYRUS C11THREADS C
@benesch
benesch / changes.diff
Created April 20, 2020 03:18
diff --git a/src/coord/timestamp.rs b/src/coord/timestamp.rs
index e598528b..90a74aaf 100644
--- a/src/coord/timestamp.rs
+++ b/src/coord/timestamp.rs
@@ -20,7 +20,6 @@ use std::time::{Duration, SystemTime, UNIX_EPOCH};
use avro::schema::Schema;
use avro::types::Value;
-
use lazy_static::lazy_static;
@benesch
benesch / gist:61c057c6ede1bbd46f537c478e41bf3e
Created February 19, 2020 20:15
285200 11897 core::ptr::real_drop_in_place
273772 1913 core::iter::traits::iterator::Iterator::try_fold
188306 2058 core::option::Option<T>::map
160776 396 alloc::raw_vec::RawVec<T,A>::reserve_internal
99375 895 core::result::Result<T,E>::map
66836 232 serde::ser::Serializer::collect_seq
62964 159 timely::dataflow::operators::generic::builder_rc::OperatorBuilder<G>::build::{{closure}}
56983 277 <alloc::vec::Vec<T> as alloc::vec::SpecExtend<T,I>>::spec_extend
55235 159 timely::dataflow::operators::generic::builder_rc::OperatorBuilder<G>::build
52750 1029 core::iter::traits::iterator::Iterator::fold
@benesch
benesch / bad.plan
Created January 28, 2020 04:44
Let {
l5 = Distinct {
group_key: [#3],
Get { materialize.public.tab0 (u1) }
}
} in
Let {
l9 = Reduce {
group_key: [#0],
aggregates: [any(#0 = #2)],
@benesch
benesch / errors.txt
Created December 13, 2019 20:48
benesch@langur$ cargo check
Checking pgwire v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/pgwire)
warning: unused imports: `Future`, `future`
--> src/pgwire/lib.rs:21:15
|
21 | use futures::{future, Future};
| ^^^^^^ ^^^^^^
|
= note: `#[warn(unused_imports)]` on by default
@benesch
benesch / errors.txt
Created December 13, 2019 20:48
benesch@langur$ cargo check
Checking pgwire v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/pgwire)
warning: unused imports: `Future`, `future`
--> src/pgwire/lib.rs:21:15
|
21 | use futures::{future, Future};
| ^^^^^^ ^^^^^^
|
= note: `#[warn(unused_imports)]` on by default
@benesch
benesch / gist:d951e026d89bab90fee665a2f2aa5c85
Created November 28, 2019 01:33
benesch@langur$ cargo test -p materialized -- prepared
Compiling pgwire v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/pgwire)
warning: unused import: `Row`
--> src/pgwire/codec.rs:28:19
|
28 | use repr::{Datum, Row, ScalarType};
| ^^^
|
= note: `#[warn(unused_imports)]` on by default
@benesch
benesch / Cargo.lock.diff
Created August 22, 2019 05:29
diff --git a/Cargo.lock b/Cargo.lock
index b2d13ca..d88fd6c 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -36,7 +36,7 @@ dependencies = [
"fnv 1.0.6 (registry+https://github.com/rust-lang/crates.io-index)",
"serde 1.0.99 (registry+https://github.com/rust-lang/crates.io-index)",
"serde_derive 1.0.99 (registry+https://github.com/rust-lang/crates.io-index)",
- "timely 0.10.0 (git+https://github.com/TimelyDataflow/timely-dataflow)",
+ "timely 0.10.0 (git+https://github.com/benesch/timely-dataflow.git?branch=sample)",
@benesch
benesch / 37705.patch
Created May 22, 2019 16:13
diff --git a/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go b/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go
index a88e4f6068..e0702f3336 100644
--- a/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go
+++ b/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go
@@ -22,6 +22,7 @@ import (
"github.com/cockroachdb/cockroach/pkg/storage/engine"
"github.com/cockroachdb/cockroach/pkg/util/log"
+ "github.com/pkg/errors"
)