= Time & Versioning in Graphs
== Time as Attributes
- Long (Seconds or Milliseconds since Epoch)
- String ISO-XXX -> comparable
- Simple String yyyy-mm-dd
Issues:
= Time & Versioning in Graphs
== Time as Attributes
Issues:
// This example shows how to use row_number and rank to create | |
// a dataframe of precipitation values associated with a zip and date | |
// from the closest NOAA station | |
import org.apache.spark.sql.expressions.Window | |
import org.apache.spark.sql.functions._ | |
// mocked NOAA weather station data | |
case class noaaData(zip:String,station:String,date:Long,value:String=null,distance:Int) | |
val t = Seq( |
set -g default-terminal "screen-256color" | |
# change prefix command to C-z | |
set -g prefix C-z | |
unbind C-b | |
bind C-z last-window | |
bind z send-prefix | |
# setup | and - for window splitting | |
unbind % | |
bind | split-window -h |
A complete list of RxJS 5 operators with easy to understand explanations and runnable examples.
#!/bin/bash | |
MAXTIME=30 | |
PORTS=() | |
START_TSTAMP=$(date "+%s") | |
function help() { | |
>&2 echo "Wait until a port becomes open" | |
>&2 echo | |
>&2 echo "Usage: $0 [options] -h HOST -p Port" |
A running example of the code from:
This gist creates a working example from blog post, and a alternate example using simple worker pool.
TLDR: if you want simple and controlled concurrency use a worker pool.
Superseded by this.