Skip to content
Snippets Groups Projects
Commit 1997c19f authored by Yannick DAYER's avatar Yannick DAYER
Browse files

Merge branch 'fix-kinit-chunks' into 'master'

[fix] Specify the chunk size of arrays for k_init.

Closes #49

See merge request !71
parents b4027905 20eedc46
No related branches found
No related tags found
1 merge request!71[fix] Specify the chunk size of arrays for k_init.
Pipeline #66667 passed
...@@ -308,6 +308,7 @@ class KMeansMachine(BaseEstimator): ...@@ -308,6 +308,7 @@ class KMeansMachine(BaseEstimator):
# k_init requires da.Array as input. # k_init requires da.Array as input.
logger.debug("Transform k-means data to dask array") logger.debug("Transform k-means data to dask array")
data = da.array(data) data = da.array(data)
data.rechunk(1, data.shape[-1]) # Prevents issue with large arrays.
logger.debug("Get k-means centroids") logger.debug("Get k-means centroids")
self.centroids_ = k_init( self.centroids_ = k_init(
X=data, X=data,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment