Skip to content

Instantly share code, notes, and snippets.

View mxm's full-sized avatar

Maximilian Michels mxm

View GitHub Profile
@mxm
mxm / heaps.erl
Created April 24, 2014 21:01 — forked from larsmans/heaps.erl
% Copyright (c) 2010-2014, Lars Buitinck
% May be used, redistributed and modified under the terms of the
% GNU Lesser General Public License (LGPL), version 2.1 or later
% Heaps/priority queues in Erlang
% Heaps are data structures that return the entries inserted into them in
% sorted order. This makes them the data structure of choice for implementing
% priority queues, a central element of algorithms such as best-first/A*
% search and Kruskal's minimum-spanning-tree algorithm.
@mxm
mxm / feed.patch
Created January 15, 2015 17:24
Patch for adding an RSS feed to the Flink website
Index: _config.yml
===================================================================
--- _config.yml (revision 1652149)
+++ _config.yml (working copy)
@@ -5,6 +5,8 @@
# {{ site.CONFIG_KEY }}
#------------------------------------------------------------------------------
+url: http://flink.apache.org
+
@mxm
mxm / pre-push
Last active August 29, 2015 14:13
pre-push hook for Flink commiters
#!/bin/bash
####
##
## Pre-push hook which protects a remote branch
## by running a verify command before pushing.
##
## Should be place in .git/hooks/pre-push
##
## protected_remote can be a substring
@mxm
mxm / CustomSerializer.java
Created February 24, 2015 17:09
Custom Flink Serializer
package org.apache.flink.mytests.customserializer;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.core.memory.DataInputView;
import org.apache.flink.core.memory.DataOutputView;
import org.apache.flink.types.Value;
import java.io.IOException;
@mxm
mxm / LeftOuterJoinExample.java
Last active June 25, 2020 09:10
Example for a LEFT OUTER JOIN in Apache Flink
package org.myorg.quickstart;
import org.apache.flink.api.common.functions.CoGroupFunction;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.DataSource;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.util.Collector;
@mxm
mxm / shade.xml
Created September 2, 2015 10:01
Invalid signature file digest for Manifest main attributes
<configuration>
<filters>
<filter>
<artifact>*:*</artifact>
<excludes>
<exclude>META-INF/*.SF</exclude>
<exclude>META-INF/*.DSA</exclude>
<exclude>META-INF/*.RSA</exclude>
</excludes>
</filter>
@mxm
mxm / burgerbot.rb
Created October 7, 2015 12:41 — forked from daxadax/burgerbot.rb
burgerbot
#!/usr/bin/env ruby
# modified from https://gist.github.com/pbock/3ab260f3862c350e6b5f #
require 'watir-webdriver'
class BurgerBot
def initialize
@attempt_count = 0
@mxm
mxm / checkstyle.xml
Last active December 23, 2022 17:32
Google Java Checkstyle modified using tabs (mapped to 2 spaces) and 120 line length
<?xml version="1.0"?>
<!DOCTYPE module PUBLIC
"-//Puppy Crawl//DTD Check Configuration 1.3//EN"
"http://www.puppycrawl.com/dtds/configuration_1_3.dtd">
<!--
Checkstyle configuration that checks the Google coding conventions from:
- Google Java Style
https://google-styleguide.googlecode.com/svn-history/r130/trunk/javaguide.html
Checkstyle is very configurable. Be sure to read the documentation at
/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/bin/java -Didea.launcher.port=7534 "-Didea.launcher.bin.path=/opt/homebrew-cask/Caskroom/intellij-idea-ce/15.0/IntelliJ IDEA 15 CE.app/Contents/bin" -Dfile.encoding=UTF-8 -classpath "/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/lib/tools.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/
@mxm
mxm / deb-contents.txt
Last active April 2, 2016 18:33
Bigtop Flink binary RPM/Debian package contents
drwxr-xr-x root/root 0 2016-04-02 20:22 ./
drwxr-xr-x root/root 0 2016-04-02 20:22 ./usr/
drwxr-xr-x root/root 0 2016-04-02 20:22 ./usr/share/
drwxr-xr-x root/root 0 2016-04-02 20:22 ./usr/share/doc/
drwxr-xr-x root/root 0 2016-04-02 20:22 ./usr/share/doc/flink/
-rw-r--r-- root/root 5823 2016-04-02 20:22 ./usr/share/doc/flink/LICENSE.gz
-rw-r--r-- root/root 1308 2016-04-02 20:22 ./usr/share/doc/flink/README.txt
-rw-r--r-- root/root 411 2016-04-02 20:04 ./usr/share/doc/flink/copyright
-rw-r--r-- root/root 128 2016-04-02 20:04 ./usr/share/doc/flink/changelog.Debian.gz
-rw-r--r-- root/root 779 2016-04-02 20:22 ./usr/share/doc/flink/NOTICE