Elias Levy eliaslevy
eliaslevy
/ gist:fad450e91d7d5e769f52
Created
May 14, 2015 17:06
Test of RethinkDB Ruby Driver Connection Thread-Safety
This file contains 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
| #!/opt/jruby-1.7.20/bin/jruby -J-Xmx10000m | |
| require 'benchmark' | |
| require 'jruby/synchronized' | |
| require 'rethinkdb' | |
| include RethinkDB::Shortcuts | |
| module RethinkDB | |
| class Connection | |
| alias_method :old_send, :send |
eliaslevy
/ gist:2712199
Created
May 16, 2012 16:58
This file contains 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
| #!/usr/bin/env ruby | |
| require 'amqp' | |
| amqp_connection_config = { | |
| :host => "localhost", | |
| :port => 5672, | |
| :user => "guest", | |
| :pass => "guest", | |
| :vhost => "/", |
eliaslevy
/ gist:2722379
Created
May 18, 2012 00:12
This file contains 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
| #!/usr/bin/env ruby | |
| require 'amqp' | |
| require 'logger' | |
| amqp_connection_config = { | |
| :host => "localhost", | |
| :port => 5672, | |
| :user => "guest", | |
| :pass => "guest", |
eliaslevy
/ EventTimeTriggerWithEarlyAndLateFiring.java
Created
June 6, 2016 23:41
Modified EventTimeTriggerWithEarlyAndLateFiring with firing suppression if there aren't any new events between timers
This file contains 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
| package com.dataartisans.beam_comparison.customTriggers; | |
| package com.cisco.sbg.amp; | |
| import org.apache.flink.api.common.state.ValueState; | |
| import org.apache.flink.api.common.state.ValueStateDescriptor; | |
| import org.apache.flink.api.common.typeutils.base.BooleanSerializer; | |
| import org.apache.flink.api.common.typeutils.base.LongSerializer; | |
| import org.apache.flink.hadoop.shaded.com.google.common.base.Preconditions; | |
| import org.apache.flink.streaming.api.windowing.time.Time; |
eliaslevy
/ SpecificAvroSerde.scala
Created
October 5, 2016 21:43
Avro SpecificRecord Serde for Kafka
This file contains 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
| package example.kstreams | |
| import org.apache.kafka.common.serialization.Serde | |
| import org.apache.kafka.common.serialization.Serializer | |
| import org.apache.kafka.common.serialization.Deserializer | |
| import java.io.ByteArrayInputStream | |
| import java.io.ByteArrayOutputStream | |
| import org.apache.avro.io.EncoderFactory |
This file contains 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
| # Helper method that publishes a message to an exchange and waits for a | |
| # broker acknowledgement using RabbitMQ's publisher confirmation extension. | |
| # | |
| # Confirm mode must already be enabled in the channel. You can turn | |
| # confirm mode on using channel.confirm_select. You must only do this | |
| # once. | |
| # | |
| # It also raises an error if you use the mandatory and/or immediate | |
| # options, and these constrains cannot be meet by the broker. | |
| # |
eliaslevy
/ Scan.py
Created
June 13, 2017 23:34
— forked from enjoylife/Scan.py
Python implementation of SCAN: A Structural Clustering Algorithm for Networks
This file contains 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
| # -*- coding: utf-8 -*- | |
| """ | |
| SCAN: A Structural Clustering Algorithm for Networks | |
| As described in http://ualr.edu/nxyuruk/publications/kdd07.pdf | |
| """ | |
| from collections import deque | |
| import numpy as np | |
| from scipy.sparse import csr_matrix |
This file contains 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
| import org.apache.flink.api.common.state.ValueState | |
| import org.apache.flink.api.common.state.ValueStateDescriptor | |
| import org.apache.flink.api.common.typeinfo.TypeHint | |
| import org.apache.flink.streaming.api.windowing.triggers.Trigger | |
| import org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext | |
| import org.apache.flink.streaming.api.windowing.triggers.TriggerResult | |
| import org.apache.flink.streaming.api.windowing.triggers.TriggerResult.{CONTINUE, FIRE, FIRE_AND_PURGE, PURGE} | |
| import org.apache.flink.streaming.api.windowing.time.Time | |
| import org.apache.flink.streaming.api.windowing.windows.TimeWindow |
eliaslevy
/ openvpn.template
Created
November 7, 2015 04:25
OpenVPN CloudFormation template to attach a VPN AS to an existing VPC with an Internet Gateway
This file contains 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
| { | |
| "AWSTemplateFormatVersion": "2010-09-09", | |
| "Description": "OpenVPN Access Server", | |
| "Mappings": { | |
| "RegionMap": { | |
| "us-east-1" : { "AMI" : "ami-5fe36434" }, | |
| "us-west-1" : { "AMI" : "ami-8bf40fcf" }, | |
| "us-west-2" : { "AMI" : "ami-9fe2f2af" }, | |
| "eu-west-1" : { "AMI" : "ami-03644074" }, | |
| "eu-central-1" : { "AMI" : "ami-507f7e4d" }, |
eliaslevy
/ sfmajor2018.json
Last active
June 10, 2018 02:45
This file contains 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
| { | |
| "nodes":[ | |
| {"name": "Pass 2: Amy Farah Weiss" }, | |
| {"name": "Pass 2: Angela Alioto" }, | |
| {"name": "Pass 2: Ellen Lee Zhou" }, | |
| {"name": "Pass 2: Jane Kim" }, | |
| {"name": "Pass 2: London Breed" }, | |
| {"name": "Pass 2: Mark Leno" }, | |
| {"name": "Pass 2: Michelle Bravo" }, | |
| {"name": "Pass 2: Richie Greenberg" }, |