Skip to content
This repository has been archived by the owner on Jan 23, 2020. It is now read-only.

Latest commit

 

History

History
41 lines (31 loc) · 1.83 KB

README.md

File metadata and controls

41 lines (31 loc) · 1.83 KB

Ambrose Cascading Support

Implementation

Ambrose integrates with Cascading via Cascading's FlowListener and FlowStepListener interfaces. The AmbroseCascadingNotifier implements both of these interfaces, and passes Cascading flow events on to an Ambrose StatsWriteService. For more information on Cascading see Cascading Getting Started.

The EmbeddedAmbroseCascadingNotifier, which extends AmbroseCascadingNotifier, records flow state in memory, and starts an embedded Jetty web server that hosts the Ambrose web application.

To use the EmbeddedAmbroseCascadingNotifier in your Cascading program, add the following code at the end of Cascading main:

// creates the embedded cascading notifier before tfidfFlow.complete();
EmbeddedAmbroseCascadingNotifier server = new EmbeddedAmbroseCascadingNotifier();

Then, add the listeners to your Flow:

flow.addListener(server);
flow.addStepListener(server);
flow.complete();

When your Cascading program executes, the embedded Jetty web server will (by default) bind to localhost port 8080, allowing you to browse to http://localhost:8080/ to see the Ambrose web application and its visualization of workflow state.

Authors