mustafaakin

SELECT destinationport,
  COUNT(*) AS total
FROM flows
WHERE action = ‘REJECT’
GROUP BY destinationport
ORDER BY total DESC LIMIT 10

mustafaakin

SELECT corr(bytes,packets), action FROM flows GROUP BY action

mustafaakin

SELECT sum(packets) AS total,
  split_part(sourceaddress,’.’, 1) = ‘10’ AS isInternal,
  action
FROM flows
GROUP BY 2, action
ORDER BY total DESC LIMIT 10

mustafaakin

SELECT destinationaddress,
  SUM(bytes) AS totalBytes
  FROM flows TABLESAMPLE SYSTEM (10)
GROUP BY destinationaddress
ORDER BY totalBytes DESC LIMIT 10

mustafaakin

func communicateJava(input interface{}) (interface{}, error) {
  inBytes, err := json.Marshal(input)
  inputStr := string(inBytes)
  goRequest <- inputStr
  respStr := <-javaResponse
  var resp interface{}
  err = json.Unmarshal([]byte(respStr), &resp)
}

//export Java_Test_start

mustafaakin

System.loadLibrary("Hello");
start();
while (true) {
  String request = readRequest();
  KMeansResult response = kMeans.calculate(request);
  String response = response.toString();
  writeResponse(response);
  }
}

mustafaakin

mustafaakin

import os
import sqlite3

import cv2
import numpy as np


def score(filename):
    image = cv2.imread(filename)
    gray = cv2.cvtColor(image, cv2.COLOR_BGR2GRAY)

mustafaakin

import org.json.JSONObject;
import org.json.JSONTokener;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class Test {

mustafaakin

route:
  # Main route
  routes: 
    # This route allows dumping all events because it has no fields to match and no drop rules.
    - match:
      - receiver: dump
    # This starts another route, drops all the events in *test* namespaces and Normal events 
    # for capturing critical events 
    - drop:
      - namespace: "*test*"