package cascading.stats;and then we have in scalding's CascadeJob:
public abstract class CascadingStats { }
public class CascadeStats extends CascadingStats {}
public class Cascade {
public CascadeStats getCascadeStats { /* ... */ }
}
package com.twitter.scalding;Which is fine. Now in Cascading 3.0.0-wip-115, the definition has slightly changed:
abstract class Job(...) {
protected def handleStats(statsData: CascadingStats /* bang! */ ) { /* ... */ }
}
abstract class CascadeJob(...) extends Job(...) {
override def run = {
val flows = jobs.map { _.buildFlow }
val cascade = new CascadeConnector().connect(flows: _*)
preProcessCascade(cascade)
cascade.complete()
postProcessCascade(cascade)
val statsData = cascade.getCascadeStats /* returns a CascadeStats (inherited) */
handleStats(statsData)
statsData.isSuccessful
}
}
package cascading.stats;When one tries to build scalding against cascading 3.0.0 [*], the scala compiler complains on c.t.scalding.Job#handleStats, because the cascading Jar provides CascadingStats[Child] and saying just CascadingStats is illegal (it must at least be CascadingStats[_]); equivalent java code would be tolerated, with possibly a warning.
public abstract class CascadingStats<Child> { }
public class FlowStats { }
public class CascadeStats extends CascadingStats<FlowStats> {}
public class Cascade {
public CascadeStats getCascadeStats { /* ... */ } /* same */
}
--
You received this message because you are subscribed to the Google Groups "cascading-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to cascading-use...@googlegroups.com.
To post to this group, send email to cascadi...@googlegroups.com.
Visit this group at http://groups.google.com/group/cascading-user.
To view this discussion on the web visit https://groups.google.com/d/msgid/cascading-user/5555C90A.70703%40transparencyrights.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "cascading-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to cascading-use...@googlegroups.com.
To post to this group, send email to cascadi...@googlegroups.com.
Visit this group at http://groups.google.com/group/cascading-user.
To view this discussion on the web visit https://groups.google.com/d/msgid/cascading-user/5555C90A.70703%40transparencyrights.com.
For more options, visit https://groups.google.com/d/optout.
To view this discussion on the web visit https://groups.google.com/d/msgid/cascading-user/CANX%3DQ2qyPSY1f%3D%3DKX6_ijyx3jwPy%3DULfhRWEcPKy7tFtg0asSQ%40mail.gmail.com.
For more options, visit https://groups.google.com/d/optout.
Cyrille
CHÉPÉLOV
Chief Innovation Officer
Transparency
Rights Management
15 rue Jean-Baptiste Berlier - Hall B, 75013 Paris
T : +33 1 84 16 52 74 / F : +33 1 84 17 83 34