Package com.hazelcast.jet.config
Class JobConfigArguments
java.lang.Object
com.hazelcast.jet.config.JobConfigArguments
Some constants for the
JobConfig.getArgument(String)
method.-
Field Summary
Modifier and TypeFieldDescriptionstatic final String
The key under which caller marks analyzed job.static final String
The key under which the SQL engine stores detected partitions to apply member pruning technique.static final String
The key under which the SQL engine stores the SQL query text inJobConfig.getArgument(String)
.static final String
The key under which the SQL engine stores whether the job backing an SQL query is bounded or unbounded (returning infinite rows).static final String
The key under which the associated User Code Namespace for this job is stored. -
Method Summary
-
Field Details
-
KEY_SQL_QUERY_TEXT
The key under which the SQL engine stores the SQL query text inJobConfig.getArgument(String)
. It's set for all jobs backing an SQL query.- See Also:
-
KEY_SQL_UNBOUNDED
The key under which the SQL engine stores whether the job backing an SQL query is bounded or unbounded (returning infinite rows). Use forJobConfig.getArgument(String)
. Contains aBoolean
value.- See Also:
-
KEY_REQUIRED_PARTITIONS
The key under which the SQL engine stores detected partitions to apply member pruning technique.- See Also:
-
KEY_JOB_IS_SUSPENDABLE
The key under which caller marks analyzed job. The reason for not having a separate flag inJobConfig
is that we want to preserve Jet's independence from SQL.The value for that key supposed to have
Boolean
'false' value to prevent job suspension.By default, any normal Jet job is suspendable.
- See Also:
-
KEY_USER_CODE_NAMESPACE
The key under which the associated User Code Namespace for this job is stored.NOTE: The User Code Namespace defined by this key should only be used if there is no
ClassLoader
factory defined atJobConfig.getClassLoaderFactory()
. IfJobConfig.getClassLoaderFactory()
is defined in addition to a User Code Namespace being provided, anInvalidConfigurationException
will be thrown at Job creation.This argument should be set by calling
JobConfig.setUserCodeNamespace(String)
.By default, this key will not exist and a User Code Namespace will not be used.
- See Also:
-