@staticmethod
@mnmg_import
def _func_fit(sessionId, objs, datatype, **kwargs):
    from cuml.cluster.kmeans_mg import KMeansMG as cumlKMeans
    handle = worker_state(sessionId)['handle']
    inp_data = concatenate(objs)
    return cumlKMeans(handle=handle, output_type=datatype, **kwargs).fit(inp_data)
@staticmethod
@mnmg_import
def _func_fit(sessionId, objs, datatype, **kwargs):
    from cuml.cluster.kmeans_mg import KMeansMG as cumlKMeans
    handle = worker_state(sessionId)['handle']
    inp_data = concatenate(objs)
    return cumlKMeans(handle=handle, output_type=datatype, **kwargs).fit(inp_data)