kgorman

SELECT * FROM FOO ORDER BY 'baz' limit 9;

kgorman

SELECT * FROM FOO ORDER BY BAZ;

kgorman

hello world

this is a code snippet

• a list item
• another item

kgorman

#!/usr/bin/env python
from __future__ import print_function

import json
import os
import random
import time
import sys
from kafka import KafkaProducer

kgorman

class ApacheFlink < Formula
  desc "Scalable batch and stream data processing"
  homepage "https://flink.apache.org/"
  url "http://www.apache.org/dyn/closer.lua?path=/flink/flink-1.4.0/flink-1.4.0-bin-scala_2.11.tgz"
  version "1.4.0"
  sha256 "a6cee77e0719c42f0bd2d30e5a149a71ad50a708f163605c4570d418ba6c0035"
  head "https://github.com/apache/flink.git"

  bottle :unneeded

kgorman

def build_routes():
    """ return a geojson object with flight paths over last day """
    conn = database_connect()
    cur = conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
    output = cur.execute(
        """
        SELECT DISTINCT(tail)
        AS tail
        FROM planedemo_routes
        WHERE lat != ''

kgorman

Jun 21 20:54:52 vapipeline01 kernel: [2239310.896998] Out of memory: Kill process 1056 (pipelinedb) score 506 or sacrifice child
Jun 21 20:54:52 vapipeline01 kernel: [2239310.903418] Killed process 1056 (pipelinedb) total-vm:12751636kB, anon-rss:8306604kB, file-rss:128kB
Jun 21 20:54:52 vapipeline01 pipeline[15284]: [342-1] LOG:  autovacuum launcher process (PID 1056) was terminated by signal 9: Killed
Jun 21 20:54:52 vapipeline01 pipeline[15284]: [343-1] LOG:  terminating any other active server processes
Jun 21 20:54:52 vapipeline01 pipeline[1060]: [295-1] WARNING:  terminating connection because of crash of another server process
Jun 21 20:54:52 vapipeline01 pipeline[1191]: [294-1] WARNING:  terminating connection because of crash of another server process
Jun 21 20:54:52 vapipeline01 pipeline[1059]: [310-1] WARNING:  terminating connection because of crash of another server process
Jun 21 20:54:52 vapipeline01 pipeline[1162]: [294-1] WARNING:  terminating connection because of crash of another server proc

kgorman

#!/usr/bin/env python

"""A simple python script template.

"""

import os
import sys
import argparse

kgorman

-- here is my stream
drop stream test_stream cascade;
create stream test_stream (speed int, ts int, tail char(10));

create continuous view v1 as select ts, tail, speed from test_stream;

create continuous view v2 as select tail, keyed_max(ts, speed) from test_stream group by tail;

 -- put some data into it
insert into test_stream values (100, 1, 'YY');

kgorman

brew install sbt

cd /tmp
wget http://apache.spd.co.il/kafka/0.8.0/kafka_2.8.0-0.8.0.tar.gz 
tar -zxvf kafka_2.8.0-0.8.0.tar.gz -C /usr/local/
cd /usr/local/kafka_2.8.0-0.8.0

sbt update
sbt package