Skip to content

Instantly share code, notes, and snippets.

@ixaxaar
ixaxaar / client.py
Created September 27, 2014 08:54
Simple zeromq client that keeps track of dropped messages
#!/usr/bin/env python
import zmq
import time
def client():
context = zmq.Context()
socket = context.socket(zmq.PULL)
socket.setsockopt(zmq.LINGER, -1)
@ixaxaar
ixaxaar / server.py
Created September 27, 2014 08:50
Simple zeromq push server
#!/usr/bin/env python
import time
import zmq
def server():
context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.setsockopt(zmq.LINGER,0)
socket.connect('tcp://127.0.0.1:8880')
@ixaxaar
ixaxaar / broker.py
Created September 27, 2014 08:49
A simple zeromq PUSH-PULL streamer device
#!/usr/bin/env python
import zmq
def main():
try:
context = zmq.Context(1)
# Socket facing clients
frontend = context.socket(zmq.PULL)
@ixaxaar
ixaxaar / cql_constructor.js
Created July 11, 2014 08:29
CQL query generator in node.js
var _ = require('underscore');
var cassandra = function(client) {
var that = this;
that.__query__ = "";
that.__error__ = false;
that.__q__ = null;
return that;
};
# DATA FRAME OPERATIONS IN R
# Create data frame
# A dataset is ~ table (list of vectors)
id <- c(1,2,3)
name <- c("John", "Kirk", "AJ")
age <- c(21,27,18)
employees <- data.frame(ID=id, Name=name, Age=age)
employees
/*
* object.watch polyfill
*
* 2012-04-03
*
* By Eli Grey, http://eligrey.com
* Public Domain.
* NO WARRANTY EXPRESSED OR IMPLIED. USE AT YOUR OWN RISK.
*/
# DATA FRAME OPERATIONS IN R
# Create data frame
# A dataset is ~ table (list of vectors)
id <- c(1,2,3)
name <- c("John", "Kirk", "AJ")
age <- c(21,27,18)
employees <- data.frame(ID=id, Name=name, Age=age)
employees