public final class OperatorSettings extends Object
Modifier and Type | Field and Description |
---|---|
static OperatorSettings |
DEFAULT
Default operator settings: unspecified name
|
static OperatorSettings |
PARALLELISM_DISABLED
Operator settings with
maxParallelism set to 1 |
Modifier and Type | Method and Description |
---|---|
OperatorSettings |
disableParallelism()
Can be called to forcible disable parallelism for the given
operator (and children if this is a
CompositeOperator ). |
boolean |
equals(Object o)
Equals is implemeted by comparing each of the properties of OperatorSettings.
|
Integer |
getMaxParallelism()
Returns the maximum parallelism to allow for the operator.
|
Map<String,Object> |
getMetadata()
Returns metadata associated with the operator.
|
String |
getName()
Returns the name of the operator
|
GraphPath |
getRelativePath()
Returns the relative path of the operator.
|
int |
hashCode()
Hashcode is implemented in a way that is consistent with equals.
|
OperatorSettings |
hiddenPath(boolean hidden)
Returns an operator settings object, equivalent to this, but with
hiddenPath set to the specified value. |
boolean |
isHiddenPath()
Returns whether the path to this operator is hidden.
|
static OperatorSettings |
MAX_PARALLELISM(int maxParallelism)
Operator settings with
maxParallelism set to the specified value. |
OperatorSettings |
maxParallelism(int maxParallelism)
Can be used to restrict the parallelism of an operator.
|
OperatorSettings |
metadata(String key,
Object value)
Returns an operator settings object, equivalent to this, but with
its metadata modified.
|
static OperatorSettings |
NAME(String name)
Operator settings with
name set to the specified value. |
static OperatorSettings |
RELATIVE_PATH(GraphPath path)
Operator settings with
relativePath set to the specified value. |
OperatorSettings |
rename(GraphPath path)
Returns an operator settings object, equivalent to this, but with
relativePath and name set to
the specified value. |
OperatorSettings |
rename(String name)
Returns an operator settings object, equivalent to this, but with
relativePath set to a path consisting of a single
element equal to the specified name and name set to
the specified value. |
String |
toString()
Returns a display string
|
public static OperatorSettings DEFAULT
public static OperatorSettings PARALLELISM_DISABLED
maxParallelism
set to 1public static OperatorSettings NAME(String name)
name
set to the specified value.name
- the name of the operatorpublic static OperatorSettings MAX_PARALLELISM(int maxParallelism)
maxParallelism
set to the specified value.name
- the name of the operatorpublic static OperatorSettings RELATIVE_PATH(GraphPath path)
relativePath
set to the specified value.path
- the relative path of the operatorpublic String getName()
public GraphPath getRelativePath()
public Integer getMaxParallelism()
EngineConfig#getParallelism()
and that specified here.null
if unspecifiedpublic boolean isHiddenPath()
public Map<String,Object> getMetadata()
OperatorInstance
.public int hashCode()
public boolean equals(Object o)
public String toString()
public OperatorSettings disableParallelism()
CompositeOperator
).
This method should be used sparingly since it will degrade performance significantly; but is needed in certain cases.
For example:
RunScript
operator that contains a non-parallelizable scriptDeriveFields
operator that contains a non-parallelizable functionpublic OperatorSettings maxParallelism(int maxParallelism)
maxParallelism
- the max parallelism to allowpublic OperatorSettings rename(GraphPath path)
relativePath
and name
set to
the specified value.path
- the relative pathpublic OperatorSettings rename(String name)
relativePath
set to a path consisting of a single
element equal to the specified name and name
set to
the specified value.name
- the namepublic OperatorSettings hiddenPath(boolean hidden)
hiddenPath
set to the specified value.hidden
- whether this path is hiddenpublic OperatorSettings metadata(String key, Object value)
key
- the metadata key to setvalue
- the value to set it toCopyright © 2019 Actian Corporation. All rights reserved.