minyk

FROM dit4c/dit4c-container-zeppelin:latest

RUN echo "@community http://dl-cdn.alpinelinux.org/alpine/edge/community" >>  /etc/apk/repositories && echo "@testing http://dl-cdn.alpinelinux.org/alpine/edge/testing" >>  /etc/apk/repositories
RUN apk add --update python-dev gfortran build-base py-numpy@community py-scipy@testing

minyk

from time import sleep_ms
from machine import Pin, I2C

# Default Address
SI7021_I2C_DEFAULT_ADDR = 0x40

# Commands
CMD_MEASURE_RELATIVE_HUMIDITY_HOLD_MASTER_MODE = 0xE5
CMD_MEASURE_RELATIVE_HUMIDITY = 0xF5
CMD_MEASURE_TEMPERATURE_HOLD_MASTER_MODE = 0xE3

minyk

      machine.vm.provider 'virtualbox' do |v, override|
        v.name = machine.vm.hostname
        v.cpus = machine_type['cpus'] || 2
        v.memory = machine_type['memory'] || 2048
        v.customize ['modifyvm', :id, '--natdnshostresolver1', 'on']
        v.customize ['setproperty', 'machinefolder','/data/vagrant/vmz']

        override.vm.network :private_network, ip: machine_type['ip']
      end

minyk

sudo apt-get install xz-utils
sudo apt-get install git
sudo apt-get install build-essential
sudo apt-get install libavahi-compat-libdnssd-dev

minyk

var inputDF = sqlContext.read.json("/tmp/test1.json")
val query = sqlContext.sql("SELECT age FROM test WHERE age > 30")

val plan = query.queryExecution

minyk

{
  "id": "/dashboard/kibana",
  "cmd": null,
  "cpus": 1,
  "mem": 512,
  "disk": 0,
  "instances": 1,
  "container": {
    "docker": {
      "image": "kibana",

minyk

{
  "id": "/dashboard/elasticsearch",
  "cmd": null,
  "cpus": 1,
  "mem": 1024,
  "disk": 0,
  "instances": 1,
  "container": {
    "docker": {
      "image": "elasticsearch",

minyk

{
  "id": "nifi",
  "cmd": null,
  "cpus": 1,
  "mem": 1024,
  "disk": 1000,
  "instances": 1,
  "container": {
    "docker": {

minyk

{
  "id": "/hue",
  "cmd": null,
  "cpus": 1,
  "mem": 512,
  "disk": 0,
  "instances": 1,
  "container": {
    "type": "DOCKER",
    "volumes": [],

minyk

FlowFile flowFile = session.get();

# Do something with flowFile.

flowFile = session.write(flowFile, new OutputStreamCallback() {
    @Override
    public void process(OutputStream out) throws IOException {

    }
});