Package | Description |
---|---|
com.actian.dataflow.operators.io.orc | |
com.actian.dataflow.operators.io.parquet | |
com.pervasive.datarush.analytics.arm |
Provides common classes for Association Rule Mining (ARM).
|
com.pervasive.datarush.analytics.arm.fpgrowth |
Provides the operator to perform the FP-growth ARM algorithm.
|
com.pervasive.datarush.analytics.cleansing |
Provides operators related to data cleansing.
|
com.pervasive.datarush.analytics.knn |
Provides an implementation of the KNN algorithm using DataRush's sparse data API.
|
com.pervasive.datarush.analytics.naivebayes.learner |
Provides an implementation of the Naive Bayes learner.
|
com.pervasive.datarush.analytics.pmml |
Provides shared and base classes for PMML model representation of Analytics algorithms.
|
com.pervasive.datarush.analytics.r | |
com.pervasive.datarush.analytics.regression |
Provides utility, PMML and other classes for shared use by regression related entities.
|
com.pervasive.datarush.analytics.stats |
Provides various statistics, Data Summarizer, and Data Quality Analyzer.
|
com.pervasive.datarush.analytics.viz |
Provides operators for classifier performance visualization.
|
com.pervasive.datarush.hbase | |
com.pervasive.datarush.matching.block |
Provides operators for generating possible candidate pairs.
|
com.pervasive.datarush.matching.cluster |
Provides operators for clustering the results of duplicate or
linkage discovery.
|
com.pervasive.datarush.matching.tune |
Provides operators for analyzing data for approximate matching.
|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
com.pervasive.datarush.operators.assertion |
Provides operators for making assertions on flows and files.
|
com.pervasive.datarush.operators.group |
Provides data aggregation components.
|
com.pervasive.datarush.operators.io |
Provides base file I/O components including encoders and decoders.
|
com.pervasive.datarush.operators.io.avro |
Provides operators for reading and writing files in Avro format.
|
com.pervasive.datarush.operators.io.jdbc |
Provides operators for reading from JDBC sources and writing to JDBC targets.
|
com.pervasive.datarush.operators.io.paraccel | |
com.pervasive.datarush.operators.io.staging |
Provides operators for reading and writing DataRush staging datasets.
|
com.pervasive.datarush.operators.io.textfile |
Provides operators for reading and writing text data.
|
com.pervasive.datarush.operators.io.vectorwise | |
com.pervasive.datarush.operators.io.vectorwise.dl | |
com.pervasive.datarush.operators.join |
Provides operators for joining together two data sets into a single one.
|
com.pervasive.datarush.operators.partition |
Provides operators for partitioning and unpartitioning flows of data.
|
com.pervasive.datarush.operators.record |
Provides operators for manipulating record structure.
|
com.pervasive.datarush.operators.select |
Provides operators for selecting a subset of the data set.
|
Modifier and Type | Method and Description |
---|---|
protected DataFormat |
WriteORC.computeFormat(CompositionContext ctx) |
protected DataFormat |
ReadORC.computeFormat(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected DataFormat |
ReadParquet.computeFormat(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
FrequentItems.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
FPGrowth.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReplaceMissingValues.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
KNNClassifier.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
NaiveBayesLearner.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReadPMML.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
RunRScript.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
LogisticRegressionLearner.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
SummaryStatistics.compose(CompositionContext ctx) |
protected void |
NormalizeValues.compose(CompositionContext ctx) |
protected void |
DistinctValues.compose(CompositionContext ctx) |
protected void |
DataQualityAnalyzer.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
DrawDiagnosticsChart.compose(CompositionContext context) |
Modifier and Type | Method and Description |
---|---|
void |
WriteHBase.compose(CompositionContext ctx) |
void |
ReadHBase.compose(CompositionContext ctx) |
void |
DeleteHBase.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
BlockSelf.compose(CompositionContext ctx) |
protected void |
BlockRecords.compose(CompositionContext ctx) |
protected void |
BlockCartesian.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterLinks.compose(CompositionContext ctx) |
protected void |
ClusterDuplicates.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
AnalyzeLinkKeys.compose(CompositionContext ctx) |
protected void |
AnalyzeDuplicateKeys.compose(CompositionContext ctx) |
Modifier and Type | Interface and Description |
---|---|
interface |
DeferredCompositionContext
Composition context passed to
DeferredCompositeOperator.compose(DeferredCompositionContext) . |
Modifier and Type | Method and Description |
---|---|
void |
OperatorProxies.CompositeOperatorProxy.compose(CompositionContext ctx)
Public only as a matter of implementation; not intended for external use
|
protected abstract void |
CompositeOperator.compose(CompositionContext ctx)
Compose the body of this operator.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AssertRowCount.compose(CompositionContext ctx) |
protected void |
AssertEqualTypes.compose(CompositionContext ctx) |
protected void |
AssertEqualHash.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
RemoveDuplicates.compose(CompositionContext ctx) |
protected void |
Group.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReadSource.compose(CompositionContext ctx) |
protected void |
AbstractWriter.compose(CompositionContext ctx)
Composes a writer for the target, using configured options
and a derived format.
|
protected void |
AbstractReader.compose(CompositionContext ctx)
Composes a reader for the source, using configured options
and a derived format.
|
protected abstract DataFormat |
AbstractWriter.computeFormat(CompositionContext ctx)
Determines the data format for the target.
|
protected abstract DataFormat |
AbstractReader.computeFormat(CompositionContext ctx)
Determines the data format for the source.
|
Modifier and Type | Method and Description |
---|---|
protected DataFormat |
WriteAvro.computeFormat(CompositionContext ctx) |
protected DataFormat |
ReadAvro.computeFormat(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
WriteToJDBC.compose(CompositionContext ctx) |
protected void |
UpdateInJDBC.compose(CompositionContext ctx) |
protected void |
ReadFromJDBC.compose(CompositionContext ctx) |
protected void |
DeleteFromJDBC.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
MatrixOperatorBase.compose(CompositionContext ctx) |
protected MatrixOperatorBase.Workers<Void> |
MatrixSink.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
protected abstract MatrixOperatorBase.Workers<ExecState> |
MatrixOperatorBase.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
protected MatrixOperatorBase.Workers<com.pervasive.datarush.operators.io.paraccel.ODIInvoker> |
LoadMatrix.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
Modifier and Type | Method and Description |
---|---|
protected DataFormat |
WriteStagingDataset.computeFormat(CompositionContext ctx) |
protected DataFormat |
ReadStagingDataset.computeFormat(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected DataFormat |
WriteFixedText.computeFormat(CompositionContext ctx) |
protected DataFormat |
WriteDelimitedText.computeFormat(CompositionContext ctx) |
protected DataFormat |
WriteARFF.computeFormat(CompositionContext ctx) |
protected DataFormat |
ReadLog.computeFormat(CompositionContext ctx) |
protected DataFormat |
ReadFixedText.computeFormat(CompositionContext ctx) |
protected DataFormat |
ReadDelimitedText.computeFormat(CompositionContext ctx) |
protected DataFormat |
ReadARFF.computeFormat(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
LoadVectorwise.compose(CompositionContext ctx) |
protected void |
LoadVectorOnHadoop.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
LoadVectorOnHadoopDirect.compose(CompositionContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
FilterExistingRows.compose(CompositionContext ctx) |
protected void |
AbstractRelationalJoin.compose(CompositionContext ctx) |
protected RecordPort |
SemiJoin.composeJoin(CompositionContext ctx,
RecordPort left,
RecordPort right,
JoinKey[] keys)
Deprecated.
|
protected RecordPort |
Join.composeJoin(CompositionContext ctx,
RecordPort left,
RecordPort right,
JoinKey[] keys) |
protected RecordPort |
FilterExistingRows.composeJoin(CompositionContext ctx,
RecordPort left,
RecordPort right,
JoinKey[] keys) |
protected abstract RecordPort |
AbstractRelationalJoin.composeJoin(CompositionContext ctx,
RecordPort left,
RecordPort right,
JoinKey[] keys) |
Modifier and Type | Method and Description |
---|---|
protected void |
Randomize.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
RowsToColumns.compose(CompositionContext ctx) |
protected void |
DiscoverDomain.compose(CompositionContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
SampleRandomRows.compose(CompositionContext ctx) |
protected void |
LimitRows.compose(CompositionContext ctx) |
Copyright © 2016 Actian Corporation. All rights reserved.