Not a really clean way; one option would be to call getSize(Configuration) on the underlying Source you're reading from, and if it returns zero, substitute in a Pipeline.emptyPCollection() in the place where you would have called pipeline.read(Source).
J On Mon, May 18, 2015 at 6:09 AM, David Ortiz <[email protected]> wrote: > Hello, > > Is there a way to get my pipeline to load an empty collection instead > of throwing an exception when I pass in a globbed path that doesn't match > anything? It's part of a list of paths that otherwise match things. > > Thanks, > Dave > -- Director of Data Science Cloudera <http://www.cloudera.com> Twitter: @josh_wills <http://twitter.com/josh_wills>
