Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
Starting the H2O cluster to train the data in the distributed way
log_info('Initializing H2O')
host = "localhost"
host_port = 54321
cpus = -1
memory_size = "7g"
log_debug('H2O Cluster host: {host}')
log_debug('H2O Cluster host port: {host_port}')
log_debug('H2O Cluster Number CPUs: {cpus}')
log_debug('H2O Cluster Memory Size allocated: {memory_size}')
h2o.init(
ip = host,
port = host_port,
nthreads = cpus,
max_mem_size = memory_size
)
cluster_status <- h2o.clusterStatus()
log_debug('H2O Cluster Status Info: {cluster_status}')
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.