Apache SAMOA on Flink试用

apt-get install -y maven

apt-get update

apt-get install -y git openjdk-7-jdk vim maven

wget http://archive.apache.org/dist/flink/flink-0.10.2/flink-0.10.2-bin-hadoop2.tgz
tar -xzvf flink-0.10.2-bin-hadoop2.tgz

vim ~/flink-0.10.2/conf/flink-conf.yaml #taskmanager.numberOfTaskSlots

cd ~/flink-0.10.2/bin

./start-local.sh

git clone https://github.com/apache/incubator-samoa.git
vim ~/incubator-samoa/bin/samoa-flink.properties

cd ~/incubator-samoa/

mvn -Pflink package

bin/samoa flink target/SAMOA-Flink-0.5.0-incubating-SNAPSHOT.jar "PrequentialEvaluation -d /tmp/dump.csv -i 1000000 -f 100000 -l (classifiers.trees.VerticalHoeffdingTree -p 4) -s (generators.RandomTreeGenerator -c 2 -o 10 -u 10)"
http://ip:8081/
参考：
https://github.com/apache/incubator-samoa/pull/11 https://qconlondon.com/london-2016/system/files/presentation-slides/robertmetzger.pdf