Home
last modified time | relevance | path

Searched defs:numPartitions (Results 1 – 25 of 212) sorted by relevance

123456789

/dports/devel/spark/spark-2.1.1/python/pyspark/mllib/
H A Drandom.py49 def uniformRDD(sc, size, numPartitions=None, seed=None): argument
80 def normalRDD(sc, size, numPartitions=None, seed=None): argument
109 def logNormalRDD(sc, mean, std, size, numPartitions=None, seed=None): argument
142 def poissonRDD(sc, mean, size, numPartitions=None, seed=None): argument
169 def exponentialRDD(sc, mean, size, numPartitions=None, seed=None): argument
196 def gammaRDD(sc, shape, scale, size, numPartitions=None, seed=None): argument
229 def uniformVectorRDD(sc, numRows, numCols, numPartitions=None, seed=None): argument
255 def normalVectorRDD(sc, numRows, numCols, numPartitions=None, seed=None): argument
316 def poissonVectorRDD(sc, mean, numRows, numCols, numPartitions=None, seed=None): argument
347 def exponentialVectorRDD(sc, mean, numRows, numCols, numPartitions=None, seed=None): argument
[all …]
/dports/devel/spark/spark-2.1.1/python/pyspark/
H A Djoin.py38 def _do_python_join(rdd, other, numPartitions, dispatch): argument
44 def python_join(rdd, other, numPartitions): argument
56 def python_right_outer_join(rdd, other, numPartitions): argument
70 def python_left_outer_join(rdd, other, numPartitions): argument
84 def python_full_outer_join(rdd, other, numPartitions): argument
100 def python_cogroup(rdds, numPartitions): argument
H A Drdd.py159 def __init__(self, numPartitions, partitionFunc): argument
398 def distinct(self, numPartitions=None): argument
1645 def join(self, other, numPartitions=None): argument
1662 def leftOuterJoin(self, other, numPartitions=None): argument
1679 def rightOuterJoin(self, other, numPartitions=None): argument
1696 def fullOuterJoin(self, other, numPartitions=None): argument
1967 def cogroup(self, other, numPartitions=None): argument
2001 def subtractByKey(self, other, numPartitions=None): argument
2016 def subtract(self, other, numPartitions=None): argument
2040 def repartition(self, numPartitions): argument
[all …]
/dports/math/ensmallen/ensmallen-2.17.0/include/ensmallen_bits/moead/weight_init_policies/
H A Duniform_init.hpp56 size_t numPartitions = FindNumParitions(numObjectives, numPoints); in Generate() local
82 const size_t numPartitions) in FindNumUniformPoints()
115 size_t numPartitions {1}; in FindNumParitions() local
137 const size_t numPartitions, in DasDennisHelper()
181 const size_t numPartitions, in DasDennis()
/dports/devel/spark/spark-2.1.1/R/pkg/R/
H A DpairRDD.R209 function(x, numPartitions, partitionFunc = hashCode) { argument
271 signature(x = "RDD", numPartitions = "numeric"), argument
272 function(x, numPartitions) { argument
332 function(x, combineFunc, numPartitions) { argument
506 combOp = "ANY", numPartitions = "numeric"), argument
540 func = "ANY", numPartitions = "numeric"), argument
541 function(x, zeroValue, func, numPartitions) { argument
574 function(x, y, numPartitions) { argument
615 function(x, y, numPartitions) { argument
655 function(x, y, numPartitions) { argument
[all …]
/dports/devel/spark/spark-2.1.1/python/pyspark/streaming/
H A Ddstream.py126 def reduceByKey(self, func, numPartitions=None): argument
135 numPartitions=None): argument
146 def partitionBy(self, numPartitions, partitionFunc=portable_hash): argument
237 def groupByKey(self, numPartitions=None): argument
317 def repartition(self, numPartitions): argument
341 def cogroup(self, other, numPartitions=None): argument
352 def join(self, other, numPartitions=None): argument
364 def leftOuterJoin(self, other, numPartitions=None): argument
376 def rightOuterJoin(self, other, numPartitions=None): argument
388 def fullOuterJoin(self, other, numPartitions=None): argument
[all …]
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/
H A DInternalAccumulatorSuite.scala50 val numPartitions = 10 constant
83 val numPartitions = 10 constant
122 val numPartitions = 10 constant
/dports/math/vtk8/VTK-8.2.0/Filters/ParallelMPI/Testing/Cxx/
H A DTestImplicitConnectivity.cxx127 const int numPartitions, in GetDataSet()
271 const int numPartitions, in GetRectGridDataSet()
555 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DYZ() local
643 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DXZ() local
733 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DXY() local
823 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity3D() local
910 int numPartitions = NumberOfProcessors; in TestRectGridImplicitConnectivity3D() local
/dports/math/vtk9/VTK-9.1.0/Filters/ParallelMPI/Testing/Cxx/
H A DTestImplicitConnectivity.cxx121 const int numPartitions, double origin[3], double h[3], int wholeExtent[6]) in GetDataSet()
254 const int numPartitions, double origin[3], int wholeExtent[6]) in GetRectGridDataSet()
499 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DYZ() local
584 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DXZ() local
669 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DXY() local
754 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity3D() local
838 int numPartitions = NumberOfProcessors; in TestRectGridImplicitConnectivity3D() local
/dports/math/vtk6/VTK-6.2.0/Filters/ParallelMPI/Testing/Cxx/
H A DTestImplicitConnectivity.cxx127 const int numPartitions, in GetDataSet()
272 const int numPartitions, in GetRectGridDataSet()
556 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DYZ() local
644 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DXZ() local
734 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity2DXY() local
824 int numPartitions = NumberOfProcessors; in TestImplicitGridConnectivity3D() local
911 int numPartitions = NumberOfProcessors; in TestRectGridImplicitConnectivity3D() local
/dports/math/vtk8/VTK-8.2.0/Filters/ParallelGeometry/Testing/Cxx/
H A DTestPStructuredGridConnectivity.cxx132 vtkMultiBlockDataSet* GetDataSet( const int numPartitions ) in GetDataSet()
252 int numPartitions = factor * NumberOfProcessors; in TestPStructuredGridConnectivity() local
367 int numPartitions = factor * NumberOfProcessors; in TestAverage() local
452 int numPartitions = factor * NumberOfProcessors; in TestGhostLayerCreation() local
/dports/math/vtk9/VTK-9.1.0/Filters/ParallelGeometry/Testing/Cxx/
H A DTestPStructuredGridConnectivity.cxx129 vtkMultiBlockDataSet* GetDataSet(const int numPartitions) in GetDataSet()
236 int numPartitions = factor * NumberOfProcessors; in TestPStructuredGridConnectivity() local
349 int numPartitions = factor * NumberOfProcessors; in TestAverage() local
431 int numPartitions = factor * NumberOfProcessors; in TestGhostLayerCreation() local
/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/
H A Dpartitioning.scala117 val numPartitions: Int constant
220 val numPartitions = 1 constant
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/
H A DPartitioner.scala37 def numPartitions: Int method
83 def numPartitions: Int = partitions method
161 def numPartitions: Int = rangeBounds.length + 1 method
/dports/math/vtk6/VTK-6.2.0/Filters/ParallelGeometry/Testing/Cxx/
H A DTestPStructuredGridConnectivity.cxx136 vtkMultiBlockDataSet* GetDataSet( const int numPartitions ) in GetDataSet()
256 int numPartitions = factor * NumberOfProcessors; in TestPStructuredGridConnectivity() local
373 int numPartitions = factor * NumberOfProcessors; in TestAverage() local
458 int numPartitions = factor * NumberOfProcessors; in TestGhostLayerCreation() local
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/
H A DPartitioner.java51 int getPartition(K2 key, V2 value, int numPartitions); in getPartition()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DPartitioner.java46 int getPartition(K2 key, V2 value, int numPartitions); in getPartition()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/
H A DPartitioner.java46 public abstract int getPartition(KEY key, VALUE value, int numPartitions); in getPartition()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/
H A DPartitioner.java55 public abstract int getPartition(KEY key, VALUE value, int numPartitions); in getPartition()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/shuffle/sort/
H A DSortShuffleManager.scala186 val numPartitions = dependency.partitioner.numPartitions constant
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rdd/
H A Dcoalesce-public.scala51 def numPartitions: Int = partitions.size method
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/rdd/
H A DLocalCheckpointSuite.scala50 val numPartitions = 4 constant
157 val numPartitions = rdd.partitions.size constant
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/slive/
H A DSlivePartitioner.java34 public int getPartition(Text key, Text value, int numPartitions) { in getPartition()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/fs/slive/
H A DSlivePartitioner.java35 public int getPartition(Text key, Text value, int numPartitions) { in getPartition()
/dports/devel/spark/spark-2.1.1/core/src/main/java/org/apache/spark/shuffle/sort/
H A DSpillInfo.java32 SpillInfo(int numPartitions, File file, TempShuffleBlockId blockId) { in SpillInfo()

123456789