Merge to freshly filtered pipes

[JPatrick Davenport]

Hello,
I'm trying to filter two pipes independently of each other and then merge the results. This occurs in a subassembly. When I try to hook up the flow I get
cascading.flow.planner.PlannerException: [currentClaims][com.ngsmedicare.fps.mie.podiatry.PrepareClaimsStreams.<init>(PrepareClaimsStreams.java:22)] Every may only be preceded by another Every or a Group pipe, found: Each(currentClaims)[RegexFilter[decl:ALL]].

What am I missing?

Thanks,
JPD

[JPatrick Davenport]

Never mind. The issue seems to be with me passing the result of the merge to a group by.

[Chris K Wensel]

First, you can write the partial planner DOT file from a PlannerException.

Second, it doesn't sound like that's what you were really doing (passing a Merge to a GroupBy) by looking at the error message. if you really were, send me the dot file so I can write a test. If you weren't, just use the GroupBy for merging instead of Merge (see the constructor options).

ckw

--
You received this message because you are subscribed to the Google Groups "cascading-user" group.
To view this discussion on the web visit https://groups.google.com/d/msg/cascading-user/-/3tLx4Tv4GbcJ.
To post to this group, send email to cascadi...@googlegroups.com.
To unsubscribe from this group, send email to cascading-use...@googlegroups.com.
For more options, visit this group at http://groups.google.com/group/cascading-user?hl=en.

--

Chris K Wensel

ch...@concurrentinc.com

http://concurrentinc.com