Home
last modified time | relevance | path

Searched refs:addAccumulator (Results 1 – 7 of 7) sorted by relevance

/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/
H A DAccumulable.scala182 def addAccumulator(r: R, t: T): R method
207 def addAccumulator(growable: R, elem: T): R = { method
H A DAccumulator.scala72 def addAccumulator(t1: T, t2: T): T = { method
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/pipeline/
H A Ddocument_source_group.cpp279 groupStage->addAccumulator(statement); in create()
308 void DocumentSourceGroup::addAccumulator(AccumulationStatement accumulationStatement) { in addAccumulator() function in mongo::DocumentSourceGroup
386 pGroup->addAccumulator( in createFromBson()
896 pMerger->addAccumulator(copiedAccumuledField); in getMergeSources()
H A Ddocument_source_group.h85 void addAccumulator(AccumulationStatement accumulationStatement);
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/
H A DAccumulatorV2.scala492 override def add(v: T): Unit = _value = param.addAccumulator(_value, v)
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/
H A DAccumulatorSuite.scala54 def addAccumulator(t1: mutable.Set[A], t2: A) : mutable.Set[A] = { method
/dports/devel/spark/spark-2.1.1/core/src/test/java/org/apache/spark/
H A DJavaAPISuite.java1419 public Float addAccumulator(Float r, Float t) { in accumulators()