ipostelnik
ipostelnik
Added script to generate altsrc flag definitions, restricted list of types to the ones that provide implementation of FlagInputSourceExtension. ## What type of PR is this? - bug - cleanup...
Reading the value or checking for presence looks at the most specific subcommand that includes the flag on the command line. ## What type of PR is this? - feature...
This used to fail since ClojureFlow did not support ISelectFields protocol.
cascalog.api/union and cascalog.api/combine only work with queries. A common pattern in our code is to do (combine (select-fields tap1 FIELDS) (select-fields tap2 FIELDS)). This construct used to work in 1.x,...
My profiling showed that managing thread bindings for `*op-call*` and `*flow-process*` vars carries a lot of overhead. In my test these calls accounted for about 16% of flow execution, excluding...
Note this doesn't work for parallel aggregators because Cascading doesn't give access to keys in the AggregateBy.Functor
Functions declared using `(prepfn)` are treated by cascalog as vanila clojure funcitons and so behave as regular map/filter functions. If you want to make a prepared mapcat/buffer/aggregator you have to...