Home
last modified time | relevance | path

Searched refs:CompactBuffer (Results 1 – 12 of 12) sorted by relevance

/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/collection/
H A DCompactBuffer.scala30 private[spark] class CompactBuffer[T: ClassTag] extends Seq[T] with Serializable {
67 def += (value: T): CompactBuffer[T] = {
82 def ++= (values: TraversableOnce[T]): CompactBuffer[T] = {
85 case compactBuf: CompactBuffer[T] =>
154 private[spark] object CompactBuffer {
155 def apply[T: ClassTag](): CompactBuffer[T] = new CompactBuffer[T]
157 def apply[T: ClassTag](value: T): CompactBuffer[T] = {
158 val buf = new CompactBuffer[T]
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/util/collection/
H A DCompactBufferSuite.scala24 val b = new CompactBuffer[Int]
36 val b = new CompactBuffer[Int]
50 val b = new CompactBuffer[Int]
69 val b2 = new CompactBuffer[Int]
79 val b3 = new CompactBuffer[Int]
94 val b = new CompactBuffer[Int]
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/
H A DBroadcastNestedLoopJoinExec.scala30 import org.apache.spark.util.collection.{BitSet, CompactBuffer}
261 val buf: CompactBuffer[InternalRow] = new CompactBuffer()
272 val buf: CompactBuffer[InternalRow] = new CompactBuffer()
282 val notMatched: CompactBuffer[InternalRow] = new CompactBuffer()
297 val buf: CompactBuffer[InternalRow] = new CompactBuffer()
319 val matchedRows = new CompactBuffer[InternalRow]
/dports/math/vtk9/VTK-9.1.0/ThirdParty/vtkm/vtkvtkm/vtk-m/vtkm/rendering/raytracing/
H A DChannelBufferOperations.h33 class CompactBuffer : public vtkm::worklet::WorkletMapField
40 CompactBuffer(const vtkm::Int32 numChannels) in CompactBuffer() function
109 vtkm::worklet::DispatcherMapField<detail::CompactBuffer> dispatcher( in Compact()
110 detail::CompactBuffer(buffer.NumChannels)); in Compact()
/dports/math/vtk8/VTK-8.2.0/ThirdParty/vtkm/vtk-m/vtkm/rendering/raytracing/
H A DChannelBufferOperations.h43 class CompactBuffer : public vtkm::worklet::WorkletMapField
50 CompactBuffer(const vtkm::Int32 numChannels) in CompactBuffer() function
120 vtkm::worklet::DispatcherMapField<detail::CompactBuffer> dispatcher( in Compact()
121 detail::CompactBuffer(buffer.NumChannels)); in Compact()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rdd/
H A DCoGroupedRDD.scala29 import org.apache.spark.util.collection.{CompactBuffer, ExternalAppendOnlyMap}
87 private type CoGroup = CompactBuffer[Any]
H A DPairRDDFunctions.scala48 import org.apache.spark.util.collection.CompactBuffer
507 val createCombiner = (v: V) => CompactBuffer(v)
508 val mergeValue = (buf: CompactBuffer[V], v: V) => buf += v
509 val mergeCombiners = (c1: CompactBuffer[V], c2: CompactBuffer[V]) => c1 ++= c2
510 val bufs = combineByKeyWithClassTag[CompactBuffer[V]](
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/joins/
H A DHashedRelationSuite.scala33 import org.apache.spark.util.collection.CompactBuffer
60 val data2 = CompactBuffer[InternalRow](unsafeData(2).copy())
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.IO.Ports/src/System/IO/Ports/
H A DSerialPort.cs1219 private void CompactBuffer() in CompactBuffer() method in System.IO.Ports.SerialPort
1241 CompactBuffer(); in MaybeResizeBuffer()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/serializer/
H A DKryoSerializer.scala43 import org.apache.spark.util.collection.CompactBuffer
385 classOf[CompactBuffer[_]],
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/sys/system/IO/ports/
H A DSerialPort.cs1451 private void CompactBuffer() in CompactBuffer() method in System.IO.Ports.SerialPort
1473 CompactBuffer(); in MaybeResizeBuffer()
/dports/devel/grcov/grcov-0.8.2/test/
H A Dnegative_counts.gcov10977 file:/home/marco/Documenti/FD/mozilla-central/js/src/jit/CompactBuffer.h