Package | Description |
---|---|
com.pervasive.datarush.analytics.cluster.kmeans |
Provides the KMeans algorithm.
|
com.pervasive.datarush.analytics.decisiontree.learner |
Provides the PMML learner operator and associated classes.
|
com.pervasive.datarush.analytics.pmml |
Provides shared and base classes for PMML model representation of Analytics algorithms.
|
com.pervasive.datarush.analytics.regression |
Provides utility, PMML and other classes for shared use by regression related entities.
|
com.pervasive.datarush.graphs |
Provides classes and interfaces for the construction of executable
dataflow graphs.
|
com.pervasive.datarush.hbase | |
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
Modifier and Type | Method and Description |
---|---|
protected CompositionIterator |
KMeans.createIterator(MetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected CompositionIterator |
DecisionTreeLearner.createIterator(MetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
PMMLModelSpec |
PMMLPort.getPMMLModelSpec(MetadataContext ctx)
Getter to be used to set the PMMLModelSpec for a PMMLPort
|
Modifier and Type | Method and Description |
---|---|
protected CompositionIterator |
LinearRegressionLearner.createIterator(MetadataContext context) |
Modifier and Type | Method and Description |
---|---|
void |
GraphCompilationListener.preCompile(MetadataContext ctx,
GraphPath path,
LogicalOperator operator)
Invoked just prior to compiling an operator.
|
Modifier and Type | Method and Description |
---|---|
protected com.pervasive.datarush.hadoop.shims.hbase.TableSchema |
KeyValueOperator.mapFromHCatalog(MetadataContext ctx)
Load a mapping from an existing HCatalog table.
|
protected void |
KeyValueOperator.mapToHCatalog(MetadataContext ctx,
RecordPort input)
Write a mapping to a new HCatalog table.
|
protected boolean |
KeyValueOperator.schemaSupportedByHCatalog(MetadataContext ctx)
Determines if the current schema can be written to HCatalog.
|
protected boolean |
KeyValueOperator.tableExistsInHCatalog(MetadataContext ctx)
Determines if the currently selected HCatalog table already exists.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CompositionContext
Composition context used by
CompositeOperator 's. |
interface |
DeferredCompositionContext
Composition context passed to
DeferredCompositeOperator.compose(DeferredCompositionContext) . |
interface |
ExecutionContext
Execution context passed to
ExecutableOperator.execute(ExecutionContext) . |
interface |
IterativeExecutionContext
Context passed to
CompositionIterator.execute(IterativeExecutionContext) . |
interface |
IterativeMetadataContext
Context used by
IterativeOperator.computeMetadata(IterativeMetadataContext) . |
interface |
MetadataCalculationContext
Base interface for all contexts in which metadata is being computed.
|
interface |
StreamingMetadataContext
Context used when computing metadata via
StreamingOperator.computeMetadata(StreamingMetadataContext) . |
Modifier and Type | Method and Description |
---|---|
CompositionIterator |
OperatorProxies.IterativeOperatorProxy.createIterator(MetadataContext ctx)
Public only as a matter of implementation; not intended for external use
|
protected abstract CompositionIterator |
IterativeOperator.createIterator(MetadataContext ctx)
Invoked at the start of execution.
|
Modifier and Type | Method and Description |
---|---|
DataDistribution |
RecordPort.getCombinedDataDistribution(MetadataContext ctx)
Gets the required data distribution of this port
|
DataOrdering |
RecordPort.getCombinedDataOrdering(MetadataContext ctx)
Gets the required data ordering of this port
|
RecordMetadata |
RecordPort.getCombinedMetadata(MetadataContext ctx)
Returns the actual metadata that the operator will see given its current
requirements and parallelism setting.
|
DataDistribution |
RecordPort.getRequiredDataDistribution(MetadataContext ctx)
Gets the required data distribution of this port
|
DataOrdering |
RecordPort.getRequiredDataOrdering(MetadataContext ctx)
Gets the required data ordering of this port
|
RecordMetadata |
RecordPort.getRequiredMetadata(MetadataContext ctx)
Returns the required metadata associated with this port
|
DataDistribution |
RecordPort.getSourceDataDistribution(MetadataContext ctx)
Returns source data distribution associated with this input port.
|
DataOrdering |
RecordPort.getSourceDataOrdering(MetadataContext ctx)
Returns source data ordering associated with this input port.
|
RecordMetadata |
RecordPort.getSourceMetadata(MetadataContext ctx)
Returns the metadata associated with this port
|
RecordTokenType |
RecordPort.getType(MetadataContext ctx)
Returns the record type of this port.
|
Copyright © 2016 Actian Corporation. All rights reserved.