twitter / scalding

A Scala API for Cascading
http://twitter.com/scalding
Apache License 2.0
3.48k stars 704 forks source link

Expose `FlowStateMap` #1854

Closed fwbrasil closed 6 years ago

fwbrasil commented 6 years ago

Problem

We have hadoop flow connectors that inspects the flow to produce warnings and gather information. Given that FlowStateMap is now private[scalding], these connectors break since they need to get the source information.

Solution

Expose the FlowStateMap companion object.

cc/ @johnynek @ttim @dieu