elastic_flow

v0.1.0

elastic_flow v0.1.0 ElasticFlow.Example

Everyone loves examples! This is a simple program similar to Flow’s example.. a word counting problem! Follow the instructions from the README to setup and try it out. Estimated time: 5 minutes.

Link to this section Summary

Functions

aggregate(result, previous_results)

The programs aggregation method, configured to be run against incoming results

count_words(enumerable)

Word counting flow. Set your config to use this as a task

get_window()

Custom distribut window to force more distribution for the small essay example data

results()

Retrieve the aggregated results of the example

run(file_name \\ "lib/example/data/essay.txt")
setup()

A simple out of place utility to connect to other local nodes and simulate a distributed system. Helpful for running the example quickly

Link to this section Functions

Link to this function aggregate(result, previous_results)

The programs aggregation method, configured to be run against incoming results

Link to this function count_words(enumerable)

Word counting flow. Set your config to use this as a task

Link to this function get_window()

Custom distribut window to force more distribution for the small essay example data

Since distribute uses each_state, resetting is necessary to avoid sending duplicate data.

Link to this function results()

Retrieve the aggregated results of the example

Link to this function run(file_name \\ "lib/example/data/essay.txt")
Link to this function setup()

A simple out of place utility to connect to other local nodes and simulate a distributed system. Helpful for running the example quickly