public interface StreamingMetadataContext extends MetadataCalculationContext
StreamingOperator.computeMetadata(StreamingMetadataContext)
.
This provides methods for resolving/computing metadata.Modifier and Type | Method and Description |
---|---|
void |
parallelize(ParallelismStrategy strategy)
Controls the parallelism of this operator.
|
void |
setClientExecution(boolean clientExecution)
Sets a flag indicating whether client execution is required.
|
void |
setParallelizable(boolean parallelizable)
Deprecated.
|
getCompilationLevel, getOperator, setOutputMetadata, setOutputMetadataDynamic, setRequiredMetadata, setStagingForced
getCombinedMetadata, getEngineConfig, getFileClient, getMaxParallelism, getPath, getRequiredMetadata, getSourceMaxParallelism, getSourceMetadata, isParallel, isSourceConnected, isSourceParallel
void parallelize(ParallelismStrategy strategy)
ParallelismStrategy.NON_PARALLELIZABLE
by default. If non-parallelizable, all data will be brought to a single processor on the machine/cluster.
In general, most operations must be parallelizable for them to be scalable. Some operations (composites
)
may consist of parallelizable operations that operator on large pieces of data, followed by non-parallelizable
operations that operate on smaller pieces.strategy
- the strategy to use to determine parallelization.ParallelismStrategy
void setParallelizable(boolean parallelizable)
parallelize(ParallelismStrategy)
true
is equivalent to calling
parallelize(ParallelismStrategy.CONFIGURED)
. A value of false is
equivalent to calling parallelize(ParallelismStrategy.NON_PARALLELIZABLE)
parallelizable
- void setClientExecution(boolean clientExecution)
IterativeOperator
, refers to the JVM that composed the subgraph (in the case of clustered
execution, this will be the job master).clientExecution
- whether client execution is required.UnsupportedOperationException
- if the current node is neither a source nor a sink.Copyright © 2021 Actian Corporation. All rights reserved.