Zach Kelling zeekay

Streaming Systems:

Differential Dataflow - The code is ugly Rust, but the logic and linked papers are quite interesting.
Spinning Fast Iterative Dataflows - Flink's execution model. Also, coverage in the Morning Paper.
Discretized Streams - Spark Streaming's model of operation.
Google's Dataflow Model - This is now also available as Apache (Incubating) Beam.
Kafka Streams - Kafka offers "hipster stream processing," and a nice unification between tables and streams.

Streaming More G

Get Git log in JSON format

git log --pretty=format:'{%n  "commit": "%H",%n  "abbreviated_commit": "%h",%n  "tree": "%T",%n  "abbreviated_tree": "%t",%n  "parent": "%P",%n  "abbreviated_parent": "%p",%n  "refs": "%D",%n  "encoding": "%e",%n  "subject": "%s",%n  "sanitized_subject_line": "%f",%n  "body": "%b",%n  "commit_notes": "%N",%n  "verification_flag": "%G?",%n  "signer": "%GS",%n  "signer_key": "%GK",%n  "author": {%n    "name": "%aN",%n    "email": "%aE",%n    "date": "%aD"%n  },%n  "commiter": {%n    "name": "%cN",%n    "email": "%cE",%n    "date": "%cD"%n  }%n},'

The only information that aren't fetched are:

%B: raw body (unwrapped subject and body)
%GG: raw verification message from GPG for a signed commit

	#!/usr/bin/env sh

	repos='bridge bridge-react chat cli coreth dao docs exchange explorer faucet finance gsn indexer lattice lpm luxjs marketplace multiparty netrunner netrunner-sdk node oraclevm plugins-core safe safe-ios sites standard subnet-evm town ui vault vmsdk wallet zchain'

	for r in $repos;
	do git clone https://github.com/luxdefi/$r
	done

	#!/usr/bin/env python3

	from pwn import gdb, log, p64, process, remote, u64

	p = process('./vuln')
	# p = remote('mercury.picoctf.net', 49464)
	gdb.attach(p)

	offset = 136
	junk = b'A' * offset

	from tabulate import tabulate
	from collections import Iterable


	def attr(obj, a):
	"""
	Returns value of attribute on an object, calling attribute if necessary.
	"""
	v = getattr(obj, a, None)
	if callable(v):

	//
	// JAZMusician.h
	// JazzyApp
	//

	#import <Foundation/Foundation.h>

	/**
	JAZMusician models, you guessed it... Jazz Musicians!
	From Ellington to Marsalis, this class has you covered.

	location /webhook/17cbb307-94ec-446b-a17b-ab82594c974c {
	if ($request_method != 'POST') {
	return 405;
	}
	content_by_lua 'ngx.print(io.popen("/path/to/script.sh"):read("*a"))';
	}

	#!/usr/bin/env python2
	import os, pwd, select, signal, socket, sys, time

	irc = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
	username = pwd.getpwuid(os.getuid())
	hostname = socket.gethostname()

	if not sys.stdin.isatty(): sys.stdin = open('/dev/tty')

	def hello():

	"""
	Automate loading of F-Script Anywhere into any app.
	By Daniel Jalkut - @danielpunkass - http://indiestack.com/

	To set up:

	0. Make sure you have FScript.framework installed in /Library/Frameworks (http://www.fscript.org)
	1. Copy this script to ~/.lldb/fsa.py
	2. Add the following to your ~/.lldbinit file:

	#!/usr/bin/env bash
	bash --init-file bin/activate