| /dports/devel/py-dask/dask-2021.11.2/dask/dataframe/tests/ |
| H A D | test_arithmetics_reduction.py | 929 x.sum(split_every=split_every)._name == x.sum(split_every=split_every)._name
932 x.prod(split_every=split_every)._name
933 == x.prod(split_every=split_every)._name
936 x.product(split_every=split_every)._name
940 x.min(split_every=split_every)._name == x.min(split_every=split_every)._name
943 x.max(split_every=split_every)._name == x.max(split_every=split_every)._name
946 x.count(split_every=split_every)._name
950 x.std(split_every=split_every)._name == x.std(split_every=split_every)._name
953 x.var(split_every=split_every)._name == x.var(split_every=split_every)._name
956 x.sem(split_every=split_every)._name == x.sem(split_every=split_every)._name
[all …]
|
| H A D | test_hyperloglog.py | 76 def test_split_every(split_every, npartitions): argument
80 approx = ddf.nunique_approx(split_every=split_every).compute(scheduler="sync")
|
| H A D | test_dataframe.py | 2595 split_every=n,
2618 split_every=3,
2635 split_every=3,
2693 split_every=n,
2727 split_every=3,
3023 res2 = ddf.cov(split_every=2)
3065 res2 = ddf.corr(split_every=2)
3960 dropped = ds.unique(split_every=split_every, split_out=split_out)
3987 subset=subset, keep=keep, split_every=split_every, split_out=10
3998 assert ddf.x.value_counts(split_out=10, split_every=split_every).npartitions == 10
[all …]
|
| H A D | test_categorical.py | 178 ddf2 = ddf.categorize(index=index, split_every=2)
209 ddf.categorize(split_every=1)
212 ddf.categorize(split_every="foo")
|
| /dports/devel/py-dask/dask-2021.11.2/dask/array/tests/ |
| H A D | test_reductions.py | 65 if split_every:
126 if split_every:
585 assert_eq(npfunc(npa)[-k:][::-1], daskfunc(a, k, split_every=split_every))
587 assert_eq(npfunc(npa)[:k], daskfunc(a, -k, split_every=split_every))
594 daskfunc(b, k, axis=0, split_every=split_every),
598 daskfunc(b, k, axis=1, split_every=split_every),
602 daskfunc(b, k, axis=-1, split_every=split_every),
605 daskfunc(b, k, axis=3, split_every=split_every)
616 daskfunc(b, -k, axis=-1, split_every=split_every),
619 daskfunc(b, -k, axis=3, split_every=split_every)
[all …]
|
| H A D | test_cupy_reductions.py | 32 with dask.config.set(split_every=2):
45 assert_eq(dfunc(a2, 0, split_every=2), func(x2, 0))
|
| H A D | test_masked.py | 254 assert_eq_ma(dfunc(mdx, keepdims=True, split_every=4), func(mx, keepdims=True))
255 assert_eq_ma(dfunc(mdx, axis=0, split_every=2), func(mx, axis=0))
257 dfunc(mdx, axis=0, keepdims=True, split_every=2),
260 assert_eq_ma(dfunc(mdx, axis=1, split_every=2), func(mx, axis=1))
262 dfunc(mdx, axis=1, keepdims=True, split_every=2),
|
| /dports/devel/py-dask/dask-2021.11.2/dask/array/ |
| H A D | reductions.py | 346 split_every=split_every,
365 split_every=split_every,
380 split_every=split_every,
395 split_every=split_every,
409 split_every=split_every,
423 split_every=split_every,
441 split_every=split_every,
459 split_every=split_every,
525 split_every=split_every,
539 split_every=split_every,
[all …]
|
| H A D | core.py | 2008 return topk(self, k, axis=axis, split_every=split_every)
2018 return argtopk(self, k, axis=axis, split_every=split_every)
2252 return argmin(self, axis=axis, split_every=split_every, out=out)
2258 return argmax(self, axis=axis, split_every=split_every, out=out)
2269 split_every=split_every,
2288 split_every=split_every,
2301 split_every=split_every,
2317 split_every=split_every,
2333 split_every=split_every,
2344 split_every=None, argument
[all …]
|
| H A D | einsumfuncs.py | 197 def einsum(*operands, dtype=None, optimize=False, split_every=None, **kwargs): argument
252 axis=list(range(size, size + ncontract_inds)), split_every=split_every
|
| /dports/devel/py-dask/dask-2021.11.2/dask/ |
| H A D | graph_manipulation.py | 65 if split_every is None:
67 split_every = 8 # type: ignore
68 elif split_every is not False:
69 split_every = int(split_every) # type: ignore
70 if split_every < 2: # type: ignore
82 def _checkpoint_one(collection, split_every) -> Delayed: argument
116 while split_every and len(map_keys) > split_every:
119 map_keys = map_keys[split_every:] + [k]
222 split_every: SplitEvery = None,
296 checkpoint(parents, split_every=split_every) if parents is not None else None
[all …]
|
| /dports/devel/py-dask/dask-2021.11.2/dask/dataframe/ |
| H A D | groupby.py | 1179 split_every=split_every,
1384 split_every=split_every,
1395 split_every=split_every,
1406 split_every=split_every,
1424 split_every=split_every,
1441 split_every=split_every,
1500 split_every=split_every,
1628 split_every=split_every,
1971 split_every=split_every,
1998 split_every=split_every,
[all …]
|
| H A D | categorical.py | 76 def categorize(df, columns=None, index=None, split_every=None, **kwargs): argument
119 if split_every is None:
120 split_every = 16
121 elif split_every is False:
122 split_every = df.npartitions
123 elif not isinstance(split_every, Integral) or split_every < 2:
126 token = tokenize(df, columns, index, split_every)
136 while k > split_every:
138 for part_i, inds in enumerate(partition_all(split_every, range(k))):
|
| H A D | core.py | 577 split_every=split_every,
1005 split_every=split_every,
1927 split_every=split_every,
3051 split_every=split_every,
3445 split_every=split_every,
3491 split_every=split_every,
3506 split_every=split_every,
3518 split_every=split_every,
3856 split_every=split_every,
3865 split_every=split_every,
[all …]
|
| /dports/devel/py-dask/dask-2021.11.2/dask/bag/ |
| H A D | core.py | 893 split_every=split_every,
902 split_every=split_every,
918 split_every=split_every,
948 split_every=split_every,
1051 return self.reduction(sum, sum, split_every=split_every)
1055 return self.reduction(max, max, split_every=split_every)
1059 return self.reduction(min, min, split_every=split_every)
1071 return self.reduction(any, any, split_every=split_every)
1083 return self.reduction(all, all, split_every=split_every)
1095 return self.reduction(count, sum, split_every=split_every)
[all …]
|
| /dports/devel/py-dask/dask-2021.11.2/dask/tests/ |
| H A D | test_graph_manipulation.py | 375 def test_split_every(split_every, nkeys): argument
378 c = checkpoint(t1, split_every=split_every)
382 t2 = wait_on(t1, split_every=split_every)
388 t4 = bind(t3, t1, split_every=split_every, assume_layers=False)
396 checkpoint(t, split_every=1)
398 checkpoint(t, split_every=1.9)
400 checkpoint(t, split_every=0) # Not to be confused with False or None
402 checkpoint(t, split_every=-2)
404 checkpoint(t, split_every={0: 2}) # This is legal for dask.array but not here
|
| /dports/misc/mxnet/incubator-mxnet-1.9.0/example/speech_recognition/ |
| H A D | stt_bi_graphemes_util.py | 22 def split_every(n, label): function
39 for pair in split_every(2, item):
50 for pair in split_every(2, i):
|
| /dports/misc/py-mxnet/incubator-mxnet-1.9.0/example/speech_recognition/ |
| H A D | stt_bi_graphemes_util.py | 22 def split_every(n, label): function
39 for pair in split_every(2, item):
50 for pair in split_every(2, i):
|
| /dports/devel/py-dask/dask-2021.11.2/dask/bag/tests/ |
| H A D | test_bag.py | 282 c2 = b.frequencies(split_every=2)
306 c2 = b.topk(4, key=lambda x: -x, split_every=2)
351 c = b.reduction(sum, sum, split_every=2)
352 d = b.reduction(sum, sum, split_every=6)
353 e = b.reduction(sum, sum, split_every=5)
359 c = b.sum(split_every=2)
360 d = b.sum(split_every=5)
366 assert c.key == b.sum(split_every=2).key
427 d = b.foldby(iseven, add, split_every=m)
1352 assert_eq(b.min(split_every=2), 1)
[all …]
|
| /dports/textproc/py-ocrmypdf/ocrmypdf-12.7.2/src/ocrmypdf/extra_plugins/ |
| H A D | semfree.py | 45 def split_every(n: int, iterable: Iterable) -> Iterator: function
126 zip_longest(*list(split_every(max_workers, task_arguments)))
|
| /dports/misc/frugally-deep/frugally-deep-0.15.13-p0/include/fdeep/layers/ |
| H A D | dense_layer.hpp | 56 const auto input_parts = fplus::split_every( in apply_impl()
|
| /dports/misc/frugally-deep/frugally-deep-0.15.13-p0/include/fdeep/ |
| H A D | filter.hpp | 83 fplus::split_every(filter_param_cnt, weights); in generate_filters()
|
| H A D | tensor.hpp | 905 fplus::split_every(t.shape().size_dim_4_, in show_tensor()
906 fplus::split_every(t.shape().height_, in show_tensor()
907 fplus::split_every(t.shape().width_, in show_tensor()
908 fplus::split_every(t.shape().depth_, strs))))); in show_tensor()
993 fplus::split_every(depth * height * width, values)); in reshape_tensor_vectors()
995 return fplus::split_every(vector_size, ts); in reshape_tensor_vectors()
|
| /dports/devel/py-dask/dask-2021.11.2/dask/dataframe/io/parquet/ |
| H A D | core.py | 788 split_every=32, argument
887 parts = math.ceil(parts / split_every)
893 lstart = split_every * group
894 lstop = min(lstart + split_every, p_max)
|
| /dports/finance/odoo/odoo-19d77c2a03335eb95a686bd69a1b56b38e87d609/odoo/addons/sms/models/ |
| H A D | sms_sms.py | 92 for sms_batch in tools.split_every(batch_size, self.ids):
|