| /dports/databases/tiledb/TileDB-2.5.2/test/src/ |
| H A D | unit-SubarrayPartitioner-dense.cc | 247 const std::vector<SubarrayRanges<T>>& partitions, in test_subarray_partitioner()
276 const std::vector<SubarrayRanges<T>>& partitions, in test_subarray_partitioner()
397 std::vector<SubarrayRanges<uint64_t>> partitions; variable
475 std::vector<SubarrayRanges<uint64_t>> partitions; variable
665 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
699 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
1057 std::vector<SubarrayRanges<uint64_t>> partitions; variable
1300 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
1399 std::vector<SubarrayRanges<uint64_t>> partitions; variable
1569 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
[all …]
|
| H A D | unit-SubarrayPartitioner-sparse.cc | 338 const std::vector<SubarrayRanges<T>>& partitions, in test_subarray_partitioner()
367 const std::vector<SubarrayRanges<T>>& partitions, in test_subarray_partitioner()
398 const std::vector<SubarrayRanges<T>>& partitions, in test_subarray_partitioner()
597 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
721 std::vector<SubarrayRanges<float>> partitions = { variable
842 std::vector<SubarrayRanges<uint64_t>> partitions = {}; variable
902 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
970 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
1004 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
1554 std::vector<SubarrayRanges<uint64_t>> partitions = { variable
[all …]
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/ |
| H A D | KafkaOffsetReader.scala | 109 val partitions = consumer.assignment() constant
125 val partitions = consumer.assignment() constant
154 val partitions = consumer.assignment() constant
173 val partitions = consumer.assignment() constant
197 val partitions = consumer.assignment() constant
|
| H A D | JsonUtils.scala | 36 def partitions(str: String): Array[TopicPartition] = { method
53 def partitions(partitions: Iterable[TopicPartition]): String = { method
89 val partitions = partitionOffsets.keySet.toSeq.sorted // sort for more determinism constant
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_subscription.c | 106 const rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_assign0()
130 const rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_assign()
151 *partitions) { in rd_kafka_incremental_assign()
164 *partitions) { in rd_kafka_incremental_unassign()
214 rd_kafka_topic_partition_list_t **partitions) { in rd_kafka_assignment()
271 rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_pause_partitions()
282 rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_resume_partitions()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_subscription.c | 106 const rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_assign0()
130 const rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_assign()
151 *partitions) { in rd_kafka_incremental_assign()
164 *partitions) { in rd_kafka_incremental_unassign()
214 rd_kafka_topic_partition_list_t **partitions) { in rd_kafka_assignment()
271 rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_pause_partitions()
282 rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_resume_partitions()
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/partitioner/ |
| H A D | hashed.py | 14 def __call__(self, key, partitions=None, available=None): argument
19 def partition(self, key, partitions=None): argument
35 def __init__(self, partitions): argument
38 def partition(self, key, partitions=None): argument
|
| H A D | roundrobin.py | 7 def __init__(self, partitions=None): argument
34 def __init__(self, partitions=None): argument
44 def _index_available(cur_pos, partitions): argument
47 def set_partitions(self, partitions): argument
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rdd/ |
| H A D | ZippedPartitionsRDD.scala | 35 def partitions: Seq[Partition] = partitionValues method
88 val partitions = s.asInstanceOf[ZippedPartitionsPartition].partitions constant
111 val partitions = s.asInstanceOf[ZippedPartitionsPartition].partitions constant
138 val partitions = s.asInstanceOf[ZippedPartitionsPartition].partitions constant
|
| /dports/biology/iqtree/IQ-TREE-2.0.6/pll/ |
| H A D | parsePartition.c | 77 void pllQueuePartitionsDestroy (pllQueue ** partitions) in pllQueuePartitionsDestroy()
101 pllQueue * partitions; in parse_partition() local
295 void pllPartitionDump (pllQueue * partitions) in pllPartitionDump()
341 pllQueue * partitions; in pllPartitionParse() local
376 pllQueue * partitions; in pllPartitionParseString() local
|
| /dports/cad/gmsh/gmsh-4.9.2-source/Geo/ |
| H A D | partitionEdge.h | 19 const std::vector<int> &partitions) in partitionEdge()
24 partitionEdge(GModel *model, int num, const std::vector<int> &partitions) in partitionEdge()
28 partitionEdge(GModel *model, const std::vector<int> &partitions) in partitionEdge()
37 virtual void setPartitions(std::vector<int> &partitions) in setPartitions()
|
| H A D | partitionVertex.h | 18 partitionVertex(GModel *model, int num, const std::vector<int> &partitions) in partitionVertex()
27 partitionVertex(GModel *model, const std::vector<int> &partitions) in partitionVertex()
35 virtual void setPartitions(std::vector<int> &partitions) in setPartitions()
|
| H A D | partitionRegion.h | 18 partitionRegion(GModel *model, int num, const std::vector<int> &partitions) in partitionRegion()
27 partitionRegion(GModel *model, const std::vector<int> &partitions) in partitionRegion()
35 virtual void setPartitions(std::vector<int> &partitions) in setPartitions()
|
| H A D | partitionFace.h | 18 partitionFace(GModel *model, int num, const std::vector<int> &partitions) in partitionFace()
26 partitionFace(GModel *model, const std::vector<int> &partitions) in partitionFace()
35 virtual void setPartitions(std::vector<int> &partitions) in setPartitions()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
| H A D | KafkaConsumerImpl.cpp | 127 RdKafka::KafkaConsumerImpl::assignment (std::vector<RdKafka::TopicPartition*> &partitions) { in assignment()
172 RdKafka::KafkaConsumerImpl::assign (const std::vector<TopicPartition*> &partitions) { in assign()
192 RdKafka::KafkaConsumerImpl::incremental_assign (const std::vector<TopicPartition*> &partitions) { in incremental_assign()
208 RdKafka::KafkaConsumerImpl::incremental_unassign (const std::vector<TopicPartition*> &partitions) { in incremental_unassign()
224 RdKafka::KafkaConsumerImpl::committed (std::vector<RdKafka::TopicPartition*> &partitions, int timeo… in committed()
243 RdKafka::KafkaConsumerImpl::position (std::vector<RdKafka::TopicPartition*> &partitions) { in position()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
| H A D | KafkaConsumerImpl.cpp | 127 RdKafka::KafkaConsumerImpl::assignment (std::vector<RdKafka::TopicPartition*> &partitions) { in assignment()
172 RdKafka::KafkaConsumerImpl::assign (const std::vector<TopicPartition*> &partitions) { in assign()
192 RdKafka::KafkaConsumerImpl::incremental_assign (const std::vector<TopicPartition*> &partitions) { in incremental_assign()
208 RdKafka::KafkaConsumerImpl::incremental_unassign (const std::vector<TopicPartition*> &partitions) { in incremental_unassign()
224 RdKafka::KafkaConsumerImpl::committed (std::vector<RdKafka::TopicPartition*> &partitions, int timeo… in committed()
243 RdKafka::KafkaConsumerImpl::position (std::vector<RdKafka::TopicPartition*> &partitions) { in position()
|
| /dports/misc/elki/elki-release0.7.1-1166-gfb1fffdf3/elki-index-preprocessed/src/main/java/de/lmu/ifi/dbs/elki/index/preprocessed/knn/ |
| H A D | PartitionApproximationMaterializeKNNPreprocessor.java | 69 private final int partitions; field in PartitionApproximationMaterializeKNNPreprocessor
85 …on<O> relation, DistanceFunction<? super O> distanceFunction, int k, int partitions, RandomFactory… in PartitionApproximationMaterializeKNNPreprocessor()
175 int partitions; field in PartitionApproximationMaterializeKNNPreprocessor.Factory
190 …public Factory(int k, DistanceFunction<? super O> distanceFunction, int partitions, RandomFactory … in Factory()
222 protected int partitions = 0; field in PartitionApproximationMaterializeKNNPreprocessor.Factory.Parameterizer
|
| /dports/sysutils/calamares/calamares-3.2.44.2/src/modules/dracutlukscfg/ |
| H A D | DracutLuksCfgJob.cpp | 49 partitions() in partitions() function
58 const QVariantList partitions = ::partitions(); in isRootEncrypted() local
74 const QVariantList partitions = ::partitions(); in hasUnencryptedSeparateBoot() local
90 const QVariantList partitions = ::partitions(); in swapOuterUuid() local
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_subscription.c | 97 const rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_assign()
117 rd_kafka_topic_partition_list_t **partitions) { in rd_kafka_assignment()
174 rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_pause_partitions()
185 rd_kafka_topic_partition_list_t *partitions) { in rd_kafka_resume_partitions()
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/consumer/ |
| H A D | base.py | 44 def __init__(self, client, group, topic, partitions=None, auto_commit=True, argument
97 def fetch_last_known_offsets(self, partitions=None): argument
127 def commit(self, partitions=None): argument
209 def pending(self, partitions=None): argument
|
| H A D | group.py | 384 def assign(self, partitions): argument
702 def pause(self, *partitions):
730 def resume(self, *partitions):
768 def seek_to_beginning(self, *partitions):
792 def seek_to_end(self, *partitions):
959 def beginning_offsets(self, partitions): argument
985 def end_offsets(self, partitions): argument
1022 def _update_fetch_positions(self, partitions): argument
|
| /dports/sysutils/calamares/calamares-3.2.44.2/src/modules/partition/tests/ |
| H A D | ClearMountsJobTests.cpp | 34 const QString partitions = process.readAllStandardOutput().trimmed(); in getPartitionsForDevice_other() local
53 QStringList partitions = getPartitionsForDevice( "sda" ); in testFindPartitions() local
|
| /dports/sysutils/calamares/calamares-3.2.44.2/src/modules/mount/ |
| H A D | main.py | 33 def get_btrfs_subvolumes(partitions): argument
64 def mount_partition(root_mount_point, partition, partitions): argument
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/kafkatest/ |
| H A D | verifiable_consumer.py | 76 def send_assignment(self, evtype, partitions): argument
82 def on_assign(self, consumer, partitions): argument
95 def on_revoke(self, consumer, partitions): argument
105 def on_commit(self, err, partitions): argument
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
| H A D | KafkaConsumerImpl.cpp | 126 RdKafka::KafkaConsumerImpl::assignment (std::vector<RdKafka::TopicPartition*> &partitions) { in assignment()
163 RdKafka::KafkaConsumerImpl::assign (const std::vector<TopicPartition*> &partitions) { in assign()
183 RdKafka::KafkaConsumerImpl::committed (std::vector<RdKafka::TopicPartition*> &partitions, int timeo… in committed()
202 RdKafka::KafkaConsumerImpl::position (std::vector<RdKafka::TopicPartition*> &partitions) { in position()
|