Skip to content

Instantly share code, notes, and snippets.

View grevian's full-sized avatar

Josh Hayes-Sheen grevian

View GitHub Profile
@tonvanbart
tonvanbart / Main.java
Created August 22, 2019 11:55
Flink job showing how to create a Flink source from a websocket connection.
package com.kpn.datalab.mab;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.flink.api.common.functions.RichMapFunction;
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
@captn3m0
captn3m0 / 01-Introduction.mkd
Last active October 6, 2015 00:58
Quick Primer to Software Development

This document is guided at SDSLabs members, but should be equally valid to anyone working in technology.

I've tried to keep all advice language agnostic and independent from any technology. This is like a series of short blog posts I've condensed to a single gist. Feel free to fork and give some more of such advice.

@zefer
zefer / ConsumerDAO.cfc
Created December 17, 2010 15:05
An example DAO using cfmongodb. The model object is an API consumer.
<cfcomponent extends="beans.model.AbstractServiceObject" output="false" hint="">
<cffunction name="init" access="public" output="false" returntype="beans.model.ConsumerDAO">
<cfscript>
// something random to append to passwords to prevent reverse md5 lookups
variables.salt = "_8sh3m9cc"
super.init( argumentcollection: arguments );