NicMcPhee

package umm.systems;

public class Mergesort implements Sorter {

  @Override
  public void sort(int[] values) {
    mergesortRange(values, 0, values.length);
  }

  private void mergesortRange(int[] values, int startIndex, int endIndex) {

NicMcPhee

services:
  server:
    container_name: server
    build: ./server # Location of the Dockerfile for the client
    restart: always
    environment:
      MONGO_ADDR: mongo # hostname of the mongo container
      MONGO_DB: prod
      WAIT_HOSTS: mongo:27017 # wait for mongo to start up before starting the server
    depends_on:

NicMcPhee

public class Main {
  public static void main(String[] args) {
    System.out.println("Hello from inside a Java container!");
  }
}

NicMcPhee

import java.util.concurrent.atomic.AtomicInteger;

public class ThreadDemo {
    private int count = 0;
    private AtomicInteger atomicCount = new AtomicInteger(0);

    public static void main(String[] args) throws InterruptedException {
        ThreadDemo demo = new ThreadDemo();
        demo.go();
    }

NicMcPhee

Using pipes to eliminate temporary files

This illustrates using pipes to eliminate temporary files. We start with a bash script that takes some demographic data (see MOCK_DATA.csv) specified as a file name as a command line argument. The script then outputs a count of how many people come from different states. The output on the included data file is:

 49 MN

NicMcPhee

<?xml version="1.0"?>
<company>
        <employee>
                <firstname>Tom</firstname>
                <lastname>Cruise</lastname>
        </employee>
        <employee>
                <firstname>Paul</firstname>
                <lastname>Enderson</lastname>
        </employee>

NicMcPhee

;;;;;;;;;;;;;;;;;;
;; The first way
;;;;;;;;;;;;;;;;;;

;; This use of atom is simple and works fine.

(def counter (atom -1))

(defn next-value []
  (swap! counter inc))

NicMcPhee

public class Counter {

    private int count = 0;

    public int getCount() {
        return count ;
    }

    /**
     * The "synchronized" keyword is crucial here; removing it will lead to serious

NicMcPhee

import java.net.*;
import java.io.*;

public class DateClient {
  public static final int portNumber = 6013;

  public static void main(String[] args) throws IOException {
    String server;
    // Use "127.0.0.1", i.e., localhost, if no server is specified.
    if (args.length == 0) {

NicMcPhee

// Clear the DB for a clean start
MATCH (n) DETACH DELETE n;

CREATE CONSTRAINT ON (i:Individual) ASSERT i.uuid IS UNIQUE;
CREATE CONSTRAINT ON (e:Errors) ASSERT e.Errors_vector IS UNIQUE;

CREATE INDEX ON :Individual(generation);
CREATE INDEX ON :Errors(total_error);

USING PERIODIC COMMIT