See: Description
Interface | Description |
---|---|
CompositionContext |
Composition context used by
CompositeOperator 's. |
CompositionIterator |
Interface to be implemented by iterative operators.
|
DeferredCompositionContext |
Composition context passed to
DeferredCompositeOperator.compose(DeferredCompositionContext) . |
ExecutionContext |
Execution context passed to
ExecutableOperator.execute(ExecutionContext) . |
IterativeExecutionContext |
Context passed to
CompositionIterator.execute(IterativeExecutionContext) . |
IterativeMetadataContext |
Context used by
IterativeOperator.computeMetadata(IterativeMetadataContext) . |
LogicalOperator |
A logical operator is the fundamental unit of composition which may be added
to a
LogicalGraph . |
MetadataCalculationContext |
Base interface for all contexts in which metadata is being computed.
|
MetadataContext |
Base interface for various contexts in which port metadata can be resolved.
|
MultiSinkOperator<T extends LogicalPort> |
Mix-in interface to be implemented by some operators.
|
MultiSourceOperator<T extends LogicalPort> |
Mix-in interface to be implemented by some operators.
|
OperatorComposable |
Base interface for any context/graph that allows operators to be added
and ports to be connected.
|
PipelineOperator<T extends LogicalPort> |
Mix-in interface to be implemented by some operators.
|
RecordPipelineOperator |
Refinement of
PipelineOperator , specific to RecortPort's. |
RecordSinkOperator |
Refinement of
SinkOperator , specific to RecortPort's. |
RecordSourceOperator |
Refinement of
SourceOperator , specific to RecortPort's. |
SinkOperator<T extends LogicalPort> |
Mix-in interface to be implemented by some operators.
|
SourceOperator<T extends LogicalPort> |
Mix-in interface to be implemented by some operators.
|
StagedSource<F extends LogicalPort> |
A handle by which one can access the staged data associated with
an iterative port.
|
StreamingMetadataContext |
Context used when computing metadata via
StreamingOperator.computeMetadata(StreamingMetadataContext) . |
Class | Description |
---|---|
AbstractDeferredRecordOperator |
Convenient base class for
DeferredCompositeOperator 's that are
also RecordPipelineOperator 's. |
AbstractExecutableRecordPipeline |
A base class for simple record-to-record operators, providing
common functions.
|
AbstractLogicalOperator |
Base class for all LogicalOperators.
|
AbstractRecordCompositeOperator |
Convenient base class for
CompositeOperator 's that are
also RecordPipelineOperator 's. |
CompositeOperator |
To be implemented by operators that can be defined by chaining together
other operations.
|
CoreTypeResolutionProvider |
Public only as a matter of implementation; for internal use only.
|
DeferredCompositeOperator |
For rare use cases; implementors should use
CompositeOperator whenever possible!
Similar to CompositeOperator in that this is composed of sub-operators. |
ExecutableOperator |
ExecutableOperators are the most commonly used operators.
|
IterativeOperator |
To be implemented by operations that must make multiple passes over the input
data.
|
OpenComposite |
A composite operator that can be externally composed.
|
OpenModelSink<T> |
A model sink that can be externally composed.
|
OpenModelSource<T> |
A model source that can be externally composed.
|
OpenMultiModelSink<T> |
A model sink that can be externally composed.
|
OpenMultiModelSource<T> |
A model source that can be externally composed.
|
OpenMultiRecordSink |
A record sink that can be externally composed.
|
OpenMultiRecordSource |
A record source that can be externally composed.
|
OpenRecordSink |
A record sink that can be externally composed.
|
OpenRecordSource |
A record source that can be externally composed.
|
OperatorProxies |
Public only as a matter of implementation; not intended for external use
|
OperatorProxies.CompositeOperatorProxy |
Public only as a matter of implementation; not intended for external use
|
OperatorProxies.DeferredCompositeOperatorProxy |
Public only as a matter of implementation; not intended for external use
|
OperatorProxies.ExecutableOperatorProxy |
Public only as a matter of implementation; not intended for external use
|
OperatorProxies.IterativeOperatorProxy |
Public only as a matter of implementation; not intended for external use
|
OperatorProxies.OperatorProxy |
Public only as a matter of implementation; not intended for external use
|
OperatorProxies.StreamingOperatorProxy |
Public only as a matter of implementation; not intended for external use
|
OperatorSettings |
Advanced operator settings that can be specified for an operator.
|
ParaccelTypeResolutionProvider |
Public only as a matter of implementation; for internal use only.
|
ParallelismStrategy |
A
ParallelismStrategy is responsible for determining parallelization of an operator based on
configured parallelism and source parallelism. |
StagedSourceOptions |
Various options that can be passed to
StagedSource.getSource(StagedSourceOptions) . |
StreamingOperator |
Base class for LogicalOperators that are a potentially streaming operation.
|
Enum | Description |
---|---|
CompilationLevel |
Enumeration of compilation levels.
|
OperatorType |
Enumeration of possible operator types
|
Copyright © 2021 Actian Corporation. All rights reserved.