Skip to content

Instantly share code, notes, and snippets.

View orenitamar's full-sized avatar

Oren Itamar orenitamar

View GitHub Profile
@mxm
mxm / CustomTrigger.java
Created October 18, 2016 13:53
A custom Trigger implementation for Flink 1.1.3 which triggers 1) a window computation on every element 2) doesn't emit duplicate window outputs 3) sends out a special -1 element when a timeout occurs.
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
@cevaris
cevaris / generate_key.sh
Last active May 5, 2024 19:34
Sign and Verify using Python pycrypto
#!/usr/bin/env bash
# Generate RSA private key
openssl genrsa -out private_key.pem 1024
@garnaat
garnaat / gist:2938586
Created June 15, 2012 20:37
Setting up OrdinaryCallingFormat for S3 in boto
import boto
from boto.s3.connection import OrdinaryCallingFormat
c = boto.connect_s3(calling_format=OrdinaryCallingFormat())