This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import Utils | |
import org.apache.spark.streaming.StreamingContext._ | |
import org.apache.spark.streaming.{Seconds, StreamingContext} | |
import StreamingContext._ | |
import org.apache.spark.SparkContext._ | |
import org.apache.spark.streaming.twitter._ | |
import org.apache.spark.SparkConf | |
import org.apache.spark.{SparkConf, SparkContext} |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This gist includes components of a simple workflow application that created a directory and moves files within | |
hdfs to this directory; | |
Emails are sent out to notify designated users of success/failure of workflow. There is a prepare section, | |
to allow re-run of the action..the prepare essentially negates the move done by a potential prior run | |
of the action. Sample data is also included. | |
The sample application includes: | |
-------------------------------- | |
1. Oozie actions: hdfs action and email action | |
2. Oozie workflow controls: start, end, and kill. |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This gist includes components of a simple workflow application that created a directory and moves files within | |
hdfs to this directory; | |
Emails are sent out to notify designated users of success/failure of workflow. There is a prepare section, | |
to allow re-run of the action..the prepare essentially negates the move done by a potential prior run | |
of the action. Sample data is also included. | |
The sample application includes: | |
-------------------------------- | |
1. Oozie actions: hdfs action and email action | |
2. Oozie workflow controls: start, end, and kill. |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/* | |
* Convert from OpenCV image and write movie with FFmpeg | |
* | |
* Copyright (c) 2016 yohhoy | |
*/ | |
#include <iostream> | |
#include <vector> | |
// FFmpeg | |
extern "C" { | |
#include <libavformat/avformat.h> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#include "ScreenCapture.h" | |
#include <algorithm> | |
#include <atomic> | |
#include <chrono> | |
#include <iostream> | |
#include <locale> | |
#include <string> | |
#include <thread> | |
#include <vector> | |
#include <queue> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#include "ScreenCapture.h" | |
#include <algorithm> | |
#include <atomic> | |
#include <chrono> | |
#include <iostream> | |
#include <locale> | |
#include <string> | |
#include <thread> | |
#include <vector> | |
#include <queue> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#include "ScreenCapture.h" | |
#include <algorithm> | |
#include <atomic> | |
#include <chrono> | |
#include <iostream> | |
#include <locale> | |
#include <string> | |
#include <thread> | |
#include <vector> | |
#include <queue> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
https://blog.socialcops.com/engineering/machine-learning-for-big-data/ |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
$ ./sbt update | |
[warn] Executing in batch mode. | |
[warn] For better performance, hit [ENTER] to switch to interactive mode, or | |
[warn] consider launching sbt without any commands, or explicitly passing 'shell' | |
[info] Loading project definition from /Users/geri/work/scalding/project | |
[info] Updating {file:/Users/geri/work/scalding/project/}scalding-build... | |
[info] Resolving org.fusesource.jansi#jansi;1.4 ... | |
[info] Done updating. | |
[warn] There may be incompatibilities among your library dependencies. | |
[warn] Here are some of the libraries that were evicted: |
This file has been truncated, but you can view the full file.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
$ ./sbt update | |
[warn] Executing in batch mode. | |
[warn] For better performance, hit [ENTER] to switch to interactive mode, or | |
[warn] consider launching sbt without any commands, or explicitly passing 'shell' | |
[info] Loading project definition from /Users/geri/work/scalding/project | |
[info] Updating {file:/Users/geri/work/scalding/project/}scalding-build... | |
[info] Resolving org.fusesource.jansi#jansi;1.4 ... | |
[info] Done updating. | |
[warn] There may be incompatibilities among your library dependencies. | |
[warn] Here are some of the libraries that were evicted: |