kbastani

INSERT INTO "baseballStats"
FROM FILE 's3://my-bucket/public_data_set/baseballStats/rawdata/'
OPTION(taskName=myTask-s3)
OPTION(input.fs.className=org.apache.pinot.plugin.filesystem.S3PinotFS)
OPTION(input.fs.prop.accessKey=my-key)
OPTION(input.fs.prop.secretKey=my-secret)
OPTION(input.fs.prop.region=us-west-2)

kbastani

(This is the transcript of a chat bot trained on Wikipedia around 2012)

Q: What is the first thought that comes to your mind when you wake up in the morning?

A: In Douglas Adams' popular comedy book, movie, television, and radio series The Hitchhiker's Guide to the Galaxy, the Answer to the Ultimate Question of Life, the Universe, and Everything is given the numeric solution "42", after seven and a half million years of calculation by a giant supercomputer called Deep Thought.

Q: How does a toddler think, when she cannot produce language herself, but does understand language others speak to her?

kbastani

Keybase proof

I hereby claim:

• I am kbastani on github.
• I am kbastani (https://keybase.io/kbastani) on keybase.
• I have a public key ASDY5WBsVgYdDXHnPLnzvgJ7ZtIbPfuJd8VlbJ8yV08yAgo

To claim this, I am signing this object:

kbastani

CQRS and Event Sourcing on Cloud Foundry

This project demonstrates the the use of CQRS and Event Sourcing with Cloud Foundry. It contains two Spring Boot microservices, both built using components provided by the Axon Framework. You can read the blog post that accompanies this project over on Wordpress.

This CQRS application is designed to run exclusively on Cloud Foundry.

Architecture Overview

kbastani

public class Aggregate<T> implements Aggregator<Long, KafkaEvent, KafkaEvent> {

    private final Class<T> clazz;
    private final Aggregator<Long, T, T> aggregation;

    public Aggregate(Class<T> clazz, Aggregator<Long, T, T> aggregation) {
        this.clazz = clazz;
        this.aggregation = aggregation;
    }

kbastani

license: gpl-3.0

kbastani

license: gpl-3.0

kbastani

VARIABLE clock

Init == clock \in {0, 1}

Tick == IF clock = 0 THEN clock' = 1 ELSE clock' = 0

Spec == Init /\ [][Tick]_<<clock>>

kbastani

#!/usr/bin/env bash

# Secure workaround for https://issues.sonatype.org/browse/MVNCENTRAL-1369
# Navigate to the root of your Spring Boot project where a Maven wrapper is present and run this script

cd .mvn/wrapper
wget https://gist.githubusercontent.com/kbastani/d4b4c92969ec5a22681bb3daa4a80343/raw/f166086ef051369383b02dfb74317cd07b6f2c6e/settings.xml

cd ../../
./mvnw clean install -s .mvn/wrapper/settings.xml

kbastani

package com.example;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

@Entity
public class User {