Find file History
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
..
Failed to load latest commit information.
.idea remove definition errors and other error handling refactorings Jun 25, 2018
gradle/wrapper
src/main factor out table data interface Aug 18, 2018
.gitignore add example and fix some problems in core Oct 9, 2017
README.md simple logging and some refactorings how operations and operation typ… Jun 23, 2018
build.gradle remove definition errors and other error handling refactorings Jun 25, 2018
examples.iml
gradlew add example 2 Oct 15, 2017
gradlew.bat add example and fix some problems in core Oct 9, 2017

README.md

  ____  _     _
 | __ )(_)___| |_ _ __ ___  ___________________________
 |  _ \| / __| __| '__/ _ \ 
 | |_) | \__ \ |_| | | (_) |  C O L U M N S  F I R S T
 |____/|_|___/\__|_|  \___/ ___________________________

Gitter chat

Bistro examples

This sub-project provides basic examples of using Bistro with sample data. More details can be found in the source files.

Bistro Engine

Name Data set Operations Description
Example1.java * calculate, link, accumulate Basic operations
Example2.java ds1: OrderItems.csv, Products.csv calculate, link, accumulate Compute sales for each product
Example3.java ds1: OrderItems.csv product, calculate, project, accumulate Compute sales for each order
Example4.java ds1: OrderItems.csv, Products.csv product, calculate, link, project, accumulate Compute sales for each product category
Example5.java ds3: BTC-EUR.csv calculate, roll Moving average (also smoothed) of daily bitcoin prices
Example6.java ds4: .krakenEUR.csv calculate, roll Compute volume weighted average price of bitcoin
Example7.java ds4: .krakenEUR.csv calculate, range, project, accumulate Compute hourly bitcoin price

Bistro Streams

Name Data set Operations Description
Example1.java simulated Basic operations
Example2.java ds4: .krakenEUR.csv roll Find peaks in moving aggregation with sliding windows
Example3.java ds4: .krakenEUR.csv range, project, accumulate, calculate Find peaks in moving aggregation using tumbling windows
Example4.java simulated project, link, accumulate Find number of clicks per region for last period
Example5.java simulated range, project, accumulate, calculate Find anomalous sensor values