/dports/devel/spark/spark-2.1.1/python/pyspark/mllib/ |
H A D | random.py | 49 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 D | join.py | 38 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 D | rdd.py | 159 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 D | uniform_init.hpp | 56 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 D | pairRDD.R | 209 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 D | dstream.py | 126 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 D | InternalAccumulatorSuite.scala | 50 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 D | TestImplicitConnectivity.cxx | 127 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 D | TestImplicitConnectivity.cxx | 121 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 D | TestImplicitConnectivity.cxx | 127 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 D | TestPStructuredGridConnectivity.cxx | 132 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 D | TestPStructuredGridConnectivity.cxx | 129 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 D | partitioning.scala | 117 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 D | Partitioner.scala | 37 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 D | TestPStructuredGridConnectivity.cxx | 136 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 D | Partitioner.java | 51 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 D | Partitioner.java | 46 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 D | Partitioner.java | 46 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 D | Partitioner.java | 55 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 D | SortShuffleManager.scala | 186 val numPartitions = dependency.partitioner.numPartitions constant
|
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rdd/ |
H A D | coalesce-public.scala | 51 def numPartitions: Int = partitions.size method
|
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/rdd/ |
H A D | LocalCheckpointSuite.scala | 50 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 D | SlivePartitioner.java | 34 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 D | SlivePartitioner.java | 35 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 D | SpillInfo.java | 32 SpillInfo(int numPartitions, File file, TempShuffleBlockId blockId) { in SpillInfo()
|