Using cascalog.cascading.operations/rename* from JCascalog

[David Kincaid]

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,
                errorTap));


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?

Thanks,

Dave

[Sam Ritchie]

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 cascalog-use...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.