Package | Description |
---|---|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.config |
Jet's configuration data objects.
|
Modifier and Type | Method and Description |
---|---|
JetConfig |
Config.getJetConfig()
Returns the Jet config
|
Modifier and Type | Method and Description |
---|---|
Config |
Config.setJetConfig(JetConfig jetConfig)
Sets the Jet config
|
Modifier and Type | Method and Description |
---|---|
JetConfig |
JetService.getConfig()
Returns the configuration for this Jet member.
|
Modifier and Type | Method and Description |
---|---|
static JetInstance |
Jet.newJetInstance(JetConfig config)
Deprecated.
since 5.0
Use
Hazelcast.newHazelcastInstance(Config) and then get
JetService from the created HazelcastInstance by
using HazelcastInstance.getJet() }. |
Modifier and Type | Method and Description |
---|---|
JetConfig |
JetConfig.setBackupCount(int newBackupCount)
Sets the number of backups that Jet will maintain for the job metadata
and snapshots.
|
JetConfig |
JetConfig.setCooperativeThreadCount(int size)
Sets the number of threads each cluster member will use to execute Jet
jobs.
|
JetConfig |
JetConfig.setDefaultEdgeConfig(EdgeConfig defaultEdgeConfig)
Sets the configuration object that specifies the defaults to use
for a DAG edge configuration.
|
JetConfig |
JetConfig.setEnabled(boolean enabled)
Sets if Jet is enabled
|
JetConfig |
JetConfig.setFlowControlPeriodMs(int flowControlPeriodMs)
While executing a Jet job there is the issue of regulating the rate
at which one member of the cluster sends data to another member.
|
JetConfig |
JetConfig.setInstanceConfig(InstanceConfig instanceConfig)
Deprecated.
The fields from
InstanceConfig class were
moved to JetConfig class. Set the fields directly on
JetConfig . |
JetConfig |
JetConfig.setLosslessRestartEnabled(boolean enabled)
Sets whether lossless job restart is enabled for the node.
|
JetConfig |
JetConfig.setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords)
Sets the maximum number of records that can be accumulated by any single
Processor instance. |
JetConfig |
JetConfig.setResourceUploadEnabled(boolean resourceUploadEnabled)
Sets if uploading resources when submitting the job enabled
|
JetConfig |
JetConfig.setScaleUpDelayMillis(long millis)
Sets the delay after which auto-scaled jobs will restart if a new member
is added to the cluster.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.