Home
last modified time | relevance | path

Searched defs:newPartitions (Results 1 – 5 of 5) sorted by relevance

/dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/
H A Dpartitions.go32 func newPartitions(partitionCount int, replicaCount int, cpMode bool) *Partitions { func
/dports/devel/spark/spark-2.1.1/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/
H A DKafkaSource.scala234 val newPartitions = untilPartitionOffsets.keySet.diff(fromPartitionOffsets.keySet) constant
/dports/devel/spark/spark-2.1.1/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/
H A DDirectKafkaInputDStream.scala191 val newPartitions = parts.diff(currentOffsets.keySet) constant
/dports/science/libgeodecomp/libgeodecomp-0.4.0/src/parallelization/
H A Dstripingsimulator.h433 CoordBox<DIM> adaptDimensions(const WeightVec& newPartitions) in adaptDimensions()
538 const WeightVec& newPartitions) in redistributeGrid()
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/
H A DDataSourceStrategy.scala217 val newPartitions = updatedPartitions.toSet -- initialMatchingPartitions constant