kbialek

#!/usr/bin/env python

import socket
import time
import re
import subprocess
import logging
import sys
import atexit
import argparse

kbialek

# https://github.com/PixlOne/logiops does not build under Ubuntu 20.04
# This gist show how to build the library using Ubuntu 20.10 running in a docker container

# Clone the repo
git clone git@github.com:PixlOne/logiops.git
cd logiops
git checkout v0.2.3

# Start Ubuntu 20.10 docker container
docker run -ti --rm -v $(pwd):/logiops ubuntu:20.10 /bin/bash

kbialek

package com.example.flink

import org.apache.flink.api.common.state.MapStateDescriptor
import org.apache.flink.streaming.api.functions.ProcessFunction
import org.apache.flink.streaming.api.scala._
import org.apache.flink.util.Collector

object RecentEventsExample {

  val RatingExpiration = 1 * 24 * 60 * 60 * 1000 // 1day in millis