Package | Description |
---|---|
org.apache.pirk.responder.wideskies.spark | |
org.apache.pirk.responder.wideskies.spark.streaming |
Constructor and Description |
---|
EncRowCalc(Accumulators accumIn,
BroadcastVars bvIn) |
EncRowCalcPrecomputedCache(Accumulators accumIn,
BroadcastVars bvIn) |
FilterData(Accumulators accumIn,
BroadcastVars bbVarsIn) |
Constructor and Description |
---|
FinalResponseFunction(Accumulators accumIn,
BroadcastVars bbVarsIn) |