Using cascalog.cascading.operations/rename* from JCascalog

Skip to first unread message

David Kincaid

Sep 6, 2016, 7:38:32 PM9/6/16
to cascalog-user
I wonder if anyone out there knows how we might go about using the rename* function from JCascalog? I've tried something like this:

Flow flow = Api.compileFlow(getClass().getSimpleName(), sinkTap, query(observationTap, encounterTap, animalTap,

return (Flow) Util.bootSimpleFn("cascalog.cascading.operations", "rename*").invoke(flow, Arrays.asList("rowKey", "record"));

but that just generates an exception:

java.lang.IllegalArgumentException: No implementation of method: :generator of protocol: #'cascalog.cascading.types/IGenerator found for class: cascading.flow.hadoop.HadoopFlow

Anyone know if it should be possible or some other way to get a Cascading Rename operation into my Cascalog pipeline?



Sam Ritchie

Sep 14, 2016, 11:11:03 AM9/14/16
to cascalog-user
I've not used JCascalog, but I thought there was support for using the operations directly? You definitely won't be able to pull in any of the operations in that particular namespace, as those were designed as an intermediate layer for use from Clojure only.
You received this message because you are subscribed to the Google Groups "cascalog-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to
For more options, visit
Reply all
Reply to author
0 new messages