Uses of Interface
com.pervasive.datarush.operators.LogicalOperator
-
Packages that use LogicalOperator 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.cluster Provides base PMML for clustering models.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.decisiontree.predictor Provides the decision tree predictor operator and associated classes.com.pervasive.datarush.analytics.decisiontree.pruner Provides the decision tree pruner operator and associated classes.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.naivebayes.predictor Provides an implementation of a Naive Bayes predictor.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.svm.predictor Provides an implementation of an SVM predictor.com.pervasive.datarush.analytics.text Provides various unstructured text processing operators.com.pervasive.datarush.analytics.util Provides some (internal) utility classes for Analytics.com.pervasive.datarush.analytics.viz Provides operators for classifier performance visualization.com.pervasive.datarush.graphs Provides classes and interfaces for the construction of executable dataflow graphs.com.pervasive.datarush.hbase com.pervasive.datarush.matching Provides operators for performing discovering duplicates or links between records.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.binary com.pervasive.datarush.operators.io.jdbc Provides operators for reading from JDBC sources and writing to JDBC targets.com.pervasive.datarush.operators.io.mdf 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.model Provides operators for handling models.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.scripting Provides theRunScriptoperator for running user-defined scripts on the rows of an input record flow.com.pervasive.datarush.operators.select Provides operators for selecting a subset of the data set.com.pervasive.datarush.operators.sink Provides theLogRowsoperator for writing debugging information about a flow to the logging API.com.pervasive.datarush.operators.sort Provides operators for sorting and manipulating sorted flows.com.pervasive.datarush.operators.source Provides operators for generating data tokens in various ways.com.pervasive.datarush.operators.string Provides operators for operating on string values in records.com.pervasive.datarush.operators.testutils com.pervasive.datarush.ports Provides classes and interfaces related to receiving and sending data in a dataflow graph.com.pervasive.datarush.ports.model Provides implementations of port objects dealing with the flow of single objects between operators.com.pervasive.datarush.ports.record Provides implementations of port objects related to the flow of record sets between operators.com.pervasive.datarush.script com.pervasive.datarush.script.operators.group -
-
Uses of LogicalOperator in com.actian.dataflow.operators.io.orc
Classes in com.actian.dataflow.operators.io.orc that implement LogicalOperator Modifier and Type Class Description classReadORCclassWriteORCWrite data in the Apache Hive ORC format. -
Uses of LogicalOperator in com.actian.dataflow.operators.io.parquet
Classes in com.actian.dataflow.operators.io.parquet that implement LogicalOperator Modifier and Type Class Description classReadParquetReads data previously written using Apache Parquet format by Apache Hive. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.arm
Classes in com.pervasive.datarush.analytics.arm that implement LogicalOperator Modifier and Type Class Description classConvertARMModelAn operator that converts an association model in PMML into a target format.classFrequentItemsCompute the frequent items within the given transactions. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.arm.fpgrowth
Classes in com.pervasive.datarush.analytics.arm.fpgrowth that implement LogicalOperator Modifier and Type Class Description classFPGrowthAn operator that implements the FP-growth algorithm, outputting a PMML model containing generated items sets and association rules. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.cleansing
Classes in com.pervasive.datarush.analytics.cleansing that implement LogicalOperator Modifier and Type Class Description classReplaceMissingValuesReplace missing values in the input data according to the given replacement specifications. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.cluster
Classes in com.pervasive.datarush.analytics.cluster that implement LogicalOperator Modifier and Type Class Description classClusterPredictorAssigns input data to clusters based on the provided PMML Clustering Model. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.cluster.kmeans
Classes in com.pervasive.datarush.analytics.cluster.kmeans that implement LogicalOperator Modifier and Type Class Description classKMeansComputes clustering model for the given input based on the k-Means algorithm. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.decisiontree.learner
Classes in com.pervasive.datarush.analytics.decisiontree.learner that implement LogicalOperator Modifier and Type Class Description classDecisionTreeLearnerOperator responsible for constructing a Decision Tree. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.decisiontree.predictor
Classes in com.pervasive.datarush.analytics.decisiontree.predictor that implement LogicalOperator Modifier and Type Class Description classDecisionTreePredictorOperator responsible for predicting outcomes based on a Decision Tree PMML model. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.decisiontree.pruner
Classes in com.pervasive.datarush.analytics.decisiontree.pruner that implement LogicalOperator Modifier and Type Class Description classDecisionTreePrunerPerforms pruning of the provided input model. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.knn
Classes in com.pervasive.datarush.analytics.knn that implement LogicalOperator Modifier and Type Class Description classKNNClassifierApplies the K-nearest neighbor algorithm to classify input data against an already classified set of example data. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.naivebayes.learner
Classes in com.pervasive.datarush.analytics.naivebayes.learner that implement LogicalOperator Modifier and Type Class Description classNaiveBayesLearnerOperator responsible for building a Naive Bayes PMML model from input data. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.naivebayes.predictor
Classes in com.pervasive.datarush.analytics.naivebayes.predictor that implement LogicalOperator Modifier and Type Class Description classNaiveBayesPredictorOperator responsible for predicting outcomes based on a Naive Bayes PMML model. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.pmml
Classes in com.pervasive.datarush.analytics.pmml that implement LogicalOperator Modifier and Type Class Description classGetPMMLclassPutPMMLclassReadPMMLReads a PMML model object from a file.classWritePMMLWrite a PMML object representation to a file at the given path. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.r
Classes in com.pervasive.datarush.analytics.r that implement LogicalOperator Modifier and Type Class Description classRunRScriptExecute an R script in flow. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.regression
Classes in com.pervasive.datarush.analytics.regression that implement LogicalOperator Modifier and Type Class Description classLinearRegressionLearnerPerforms a multivariate linear regression on the given training data.classLogisticRegressionLearnerFits a multinomial logistic regression model to the training data.classLogisticRegressionPredictorclassRegressionPredictorApply a regression model to the input data.classSumOfSquaresCompute the sum of squares for the given fields of the input data. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.stats
Classes in com.pervasive.datarush.analytics.stats that implement LogicalOperator Modifier and Type Class Description classCountRangesDetermines which range each value in a field falls within and counts the totals.classDataQualityAnalyzerEvaluates a set of quality tests on an input dataset.classDistinctValuesCalculates distinct values of the given input field.classMostFrequentValuesCompute the most frequent values within the given fields.classNormalizeValuesApply normalization methods to fields within an input data flow.classRankRank data using the given rank mode.classSummaryStatisticsDiscovers various metrics of an input dataset, based on the configured detail level. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.svm.predictor
Classes in com.pervasive.datarush.analytics.svm.predictor that implement LogicalOperator Modifier and Type Class Description classSVMPredictorOperator responsible for classification based on a SVM PMML model. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.text
Classes in com.pervasive.datarush.analytics.text that implement LogicalOperator Modifier and Type Class Description classCalculateNGramFrequencyCalculates the n-gram frequencies for a tokenized text field.classCalculateWordFrequencyCalculates the word frequencies for a tokenized text field.classConvertTextCaseConverts the case on a TokenizedText field.classCountTokensCounts the number of tokens in a tokenized text field.classDictionaryFilterFilters a tokenized text field using a dictionary.classExpandTextFrequencyExpands text frequency field.classExpandTextTokensExpands a TokenizedText field.classFilterTextFilters a tokenized text field.classGenerateBagOfWordsCalculates the bag of words for a tokenized text field.classTextFrequencyFilterFilters a frequency map field.classTextStemmerStems a TokenizedText field.classTextTokenizerTokenizes a string field as a TokenizedText object. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.util
Classes in com.pervasive.datarush.analytics.util that implement LogicalOperator Modifier and Type Class Description classAbstractPredictorCommon base class for "predictor" processes. -
Uses of LogicalOperator in com.pervasive.datarush.analytics.viz
Classes in com.pervasive.datarush.analytics.viz that implement LogicalOperator Modifier and Type Class Description classDrawDiagnosticsChartThis operator takes the output of one or multiple predictors and uses the confidence values produced by these predictors along with the actual target values ("true class") to produce diagnostic charts. -
Uses of LogicalOperator in com.pervasive.datarush.graphs
Methods in com.pervasive.datarush.graphs with parameters of type LogicalOperator Modifier and Type Method Description static List<Throwable>LogicalGraphInstances. getExceptions(LogicalGraphInstance instance, LogicalOperator operator)Returns the exceptions associated with the given operator.OperatorInstanceLogicalGraphInstance. getOperatorInstance(LogicalOperator operator)Looks up an operator instance by theLogicalOperatoradded to the graph.static OperatorStateLogicalGraphInstances. getOperatorState(LogicalGraphInstance instance, LogicalOperator operator)Returns the operator state associated with the given operator.static List<LogicalStatistic>LogicalGraphInstances. getOperatorStatistics(LogicalGraphInstance instance, LogicalOperator operator)Returns the operator statistics associated with the given operator.voidGraphCompilationListener. preCompile(MetadataContext ctx, GraphPath path, LogicalOperator operator)Invoked just prior to compiling an operator. -
Uses of LogicalOperator in com.pervasive.datarush.hbase
Classes in com.pervasive.datarush.hbase that implement LogicalOperator Modifier and Type Class Description classDeleteHBaseWrite delete markers to HBaseclassKeyOperatorSpecifies key field mapping when accessing HBase.classKeyValueOperatorSpecifies data field mapping when accessing HBase.classReadHBaseRead a result set from HBase.classWriteHBaseWrite a result set to HBase. -
Uses of LogicalOperator in com.pervasive.datarush.matching
Classes in com.pervasive.datarush.matching that implement LogicalOperator Modifier and Type Class Description classDiscoverDuplicatesDiscover duplicate records within a single source using fuzzy matching operators.classDiscoverLinksUse fuzzy matching operators to discover linked records from two data sources. -
Uses of LogicalOperator in com.pervasive.datarush.matching.block
Classes in com.pervasive.datarush.matching.block that implement LogicalOperator Modifier and Type Class Description classBlockCartesianBlock the input data by creating a cartesian product of the data.classBlockRecordsBlock records into groups of like records based on a set of key fields and generate record pairs from these groups.classBlockSelfBlock records from a single source into groups of like records based on a set of key fields and generate record pairs from these groups.classGroupPairsSortedRowsFinds key groupings within the input key fields and, for each key group, generates all pairwise combinations of distinct rows in that group.classLargeGroupDetectorAn operator that issues warnings if a dataflow contains an unusually large number of distinct key values. -
Uses of LogicalOperator in com.pervasive.datarush.matching.cluster
Classes in com.pervasive.datarush.matching.cluster that implement LogicalOperator Modifier and Type Class Description classClusterDuplicatesTransform record pairs into clusters of like records, where the two sides of the pair are from the same source.classClusterLinksTransform record pairs into clusters of like records. -
Uses of LogicalOperator in com.pervasive.datarush.matching.tune
Classes in com.pervasive.datarush.matching.tune that implement LogicalOperator Modifier and Type Class Description classAnalyzeDuplicateKeysProvides an analysis of the quality of a set of blocking keys over data to be deduplicated.classAnalyzeLinkKeysProvides an analysis of the quality of a set of blocking keys over two data sets to be linked. -
Uses of LogicalOperator in com.pervasive.datarush.operators
Subinterfaces of LogicalOperator in com.pervasive.datarush.operators Modifier and Type Interface Description interfaceMultiSinkOperator<T extends LogicalPort>Mix-in interface to be implemented by some operators.interfaceMultiSourceOperator<T extends LogicalPort>Mix-in interface to be implemented by some operators.interfacePipelineOperator<T extends LogicalPort>Mix-in interface to be implemented by some operators.interfaceRecordPipelineOperatorRefinement ofPipelineOperator, specific to RecortPort's.interfaceRecordSinkOperatorRefinement ofSinkOperator, specific to RecortPort's.interfaceRecordSourceOperatorRefinement ofSourceOperator, specific to RecortPort's.interfaceSinkOperator<T extends LogicalPort>Mix-in interface to be implemented by some operators.interfaceSourceOperator<T extends LogicalPort>Mix-in interface to be implemented by some operators.Classes in com.pervasive.datarush.operators that implement LogicalOperator Modifier and Type Class Description classAbstractDeferredRecordOperatorConvenient base class forDeferredCompositeOperator's that are alsoRecordPipelineOperator's.classAbstractExecutableRecordPipelineA base class for simple record-to-record operators, providing common functions.classAbstractLogicalOperatorBase class for all LogicalOperators.classAbstractRecordCompositeOperatorConvenient base class forCompositeOperator's that are alsoRecordPipelineOperator's.classCompositeOperatorTo be implemented by operators that can be defined by chaining together other operations.classDeferredCompositeOperatorFor rare use cases; implementors should useCompositeOperatorwhenever possible!classExecutableOperatorExecutableOperators are the most commonly used operators.classIterativeOperatorTo be implemented by operations that must make multiple passes over the input data.classOpenCompositeA composite operator that can be externally composed.classOpenModelSink<T>A model sink that can be externally composed.classOpenModelSource<T>A model source that can be externally composed.classOpenMultiModelSink<T>A model sink that can be externally composed.classOpenMultiModelSource<T>A model source that can be externally composed.classOpenMultiRecordSinkA record sink that can be externally composed.classOpenMultiRecordSourceA record source that can be externally composed.classOpenRecordSinkA record sink that can be externally composed.classOpenRecordSourceA record source that can be externally composed.classStreamingOperatorBase class for LogicalOperators that are a potentially streaming operation.Methods in com.pervasive.datarush.operators with type parameters of type LogicalOperator Modifier and Type Method Description <O extends LogicalOperator>
OOperatorComposable. add(O op)Add a LogicalOperator to this graph, using the short class name as the name of the operator.<O extends LogicalOperator>
OOperatorComposable. add(O op, OperatorSettings settings)Add a LogicalOperator to this graph, specifying advanced operator settings.<O extends LogicalOperator>
OOperatorComposable. add(O op, String name)Add a LogicalOperator to this graph, specifying a name of the operator.Methods in com.pervasive.datarush.operators that return LogicalOperator Modifier and Type Method Description LogicalOperatorMetadataCalculationContext. getOperator()Returns the operator bound to this context.Methods in com.pervasive.datarush.operators with parameters of type LogicalOperator Modifier and Type Method Description static OperatorTypeOperatorType. of(LogicalOperator op)Returns the operator type that corresponds to the given operator. -
Uses of LogicalOperator in com.pervasive.datarush.operators.assertion
Classes in com.pervasive.datarush.operators.assertion that implement LogicalOperator Modifier and Type Class Description classAssertEqualVerifies that actual rows are equal to expected rows.classAssertEqualHashVerifies that actual rows are equal to expected rows without regard to order.classAssertEqualRecordTypeAssert that the given type and the type of the input port are equal.classAssertEqualTypesAsserts that two input flows have identical types.classAssertMetadataAssert that the metadata on the input port is set correctly.classAssertPredicateAssert that the given predicate is true for all input values.classAssertRowCountVerifies that the input flow contains the specified row count.classAssertSortedVerifies that the input data is sorted by the given set of keys. -
Uses of LogicalOperator in com.pervasive.datarush.operators.group
Classes in com.pervasive.datarush.operators.group that implement LogicalOperator Modifier and Type Class Description classGroupPerforms grouping (aggregation) of sorted input data.classRemoveDuplicatesRemoves duplicate rows based on a specified set of group keys.classSortedGroupHandlerCommon base class for all processes that need to detect group boundaries -
Uses of LogicalOperator in com.pervasive.datarush.operators.io
Classes in com.pervasive.datarush.operators.io that implement LogicalOperator Modifier and Type Class Description classAbstractReaderA generic reader of byte data representing a stream of records.classAbstractWriterA generic writer of byte data representing a stream of records.classReadSourceReads a data source as a stream of records.classWriteSinkWrites a stream of records to a data sink. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.avro
Classes in com.pervasive.datarush.operators.io.avro that implement LogicalOperator Modifier and Type Class Description classReadAvroReads data previously written using Apache Avro format.classWriteAvroWrites data using Apache Avro format. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.binary
Classes in com.pervasive.datarush.operators.io.binary that implement LogicalOperator Modifier and Type Class Description classBinaryWriterWrites raw binary data to a filesystem. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.jdbc
Classes in com.pervasive.datarush.operators.io.jdbc that implement LogicalOperator Modifier and Type Class Description classAbstractWriteToJDBCAbstract implementation of a JDBC writer.protected static classAbstractWriteToJDBC.AbstractWriteToJDBCWorkerclassDeleteFromJDBCThis operator deletes data in the target table in a database by applying SQL delete statements.classFinalizeSQLWorkerclassInitializeSQLWorkerclassJDBCOperatorCommon base class forReadFromJDBCandAbstractWriteToJDBC.classReadFromJDBCTheReadFromJDBCoperator is used to access relational database systems using a supplied JDBC driver.classUpdateInJDBCThis operator updates the target table in a database by applying SQL update statements.classWriteToJDBCIn its simplest form, writes records from an input port to a JDBC target table using insert statements. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.mdf
Classes in com.pervasive.datarush.operators.io.mdf that implement LogicalOperator Modifier and Type Class Description classReadMDFReads data previously written using MDF format. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.staging
Classes in com.pervasive.datarush.operators.io.staging that implement LogicalOperator Modifier and Type Class Description classForceRecordStagingForces staging of record ports.classForceStaging<P extends LogicalPort>Forces the operators on the input and output sides to execute sequentially, instead of concurrently.classReadStagingDatasetReads a sequence of records previously staged to disk.classWriteStagingDatasetWrites a sequence of records to disk in an internal format for staged data. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.textfile
Classes in com.pervasive.datarush.operators.io.textfile that implement LogicalOperator Modifier and Type Class Description classAbstractTextReaderA generic reader of text data representing a stream of records.classAbstractTextWriterA generic writer of text data representing a stream of records.classParseTextFieldsParses input text records according to a specified text schema.classReadARFFRead files in the Attribute-Relation File Format (ARFF).classReadDelimitedTextReads a text file of delimited records as record tokens.classReadFixedTextReads a text file of fixed-width records as record tokens.classReadJSONThe ReadJSON operator reads a JSON file of key-value pairs or array of objects as record tokens.classReadLogReads a log file as record tokens.classWriteARFFWrite files using the Attribute-Relation File Format (ARFF).classWriteDelimitedTextWrites a stream of records as delimited text.classWriteFixedTextWrites a record dataflow as a text file of fixed-width records. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.vectorwise
Classes in com.pervasive.datarush.operators.io.vectorwise that implement LogicalOperator Modifier and Type Class Description classLoadActianVectorBulk load data into the Actian Vector database.classLoadVectorOnHadoopDeprecated.this operator has been replaced withLoadActianVector; use that operator instead. -
Uses of LogicalOperator in com.pervasive.datarush.operators.io.vectorwise.dl
Classes in com.pervasive.datarush.operators.io.vectorwise.dl that implement LogicalOperator Modifier and Type Class Description classLoadVectorOnHadoopDirectDeprecated.this operator has been replaced withLoadActianVector; use that operator instead. -
Uses of LogicalOperator in com.pervasive.datarush.operators.join
Classes in com.pervasive.datarush.operators.join that implement LogicalOperator Modifier and Type Class Description classAbstractRelationalJoinCommon base class for the various types of join that we support.classCrossJoinProduce the cartesian product of two sets of records.classFilterExistingRowsFilters records on the left based on the presence of matching records on the right.classFilterExistJoinProcessclassJoinPerforms a relational equi-join on two input datasets by a specified set of keys.classSemiJoinDeprecated.this operator has been replaced withFilterExistingRows; use that operator instead, linking to the appropriate output port.classUnionAllProvides a union of two data sources. -
Uses of LogicalOperator in com.pervasive.datarush.operators.model
Classes in com.pervasive.datarush.operators.model that implement LogicalOperator Modifier and Type Class Description classGetModel<T>Provides a way to update an in-memory reference to a model object.classMergeModel<T>This operator is uses to force a merge of a partitioned model into a single model.classPutModel<T>Provides a way to inject an in-memory reference to a model object into a graph. -
Uses of LogicalOperator in com.pervasive.datarush.operators.partition
Classes in com.pervasive.datarush.operators.partition that implement LogicalOperator Modifier and Type Class Description classGatherHintForces parallel streams of data to be gathered into a single non-parallel stream.classPartitionHintForces the input data to be partitioned into parallel streams of data for subsequent parallel operations.classRandomizeOperator that re-orders its input in a random fashion. -
Uses of LogicalOperator in com.pervasive.datarush.operators.record
Classes in com.pervasive.datarush.operators.record that implement LogicalOperator Modifier and Type Class Description classColumnsToRowsNormalize records by transposing values from row columns into multiple rows.classDeriveFieldsApplies one or more functions to the input record data.classDiscoverDomainUtility operator for discovering the domain of string fields.classFilterFieldsBase class for operators which filter fields in the input records.classMergeFieldsMerges two streams of data with an equivalent number of rows into one.classRemapFieldsRearranges and renames fields in a record.classRemoveFieldsRemoves a subset of fields from the input records.classRetainFieldsPreserves a subset of fields from the input records.classRowsToColumnsThe RowsToColumns operator is used to pivot data from a narrow representation (rows) into a wider representation (columns).classSelectFieldsPreserves a subset of fields from the input records. -
Uses of LogicalOperator in com.pervasive.datarush.operators.scripting
Classes in com.pervasive.datarush.operators.scripting that implement LogicalOperator Modifier and Type Class Description classRunJavaScriptProcesses rows using user-defined scripts written in JavaScript.classRunScriptProcesses rows using user-defined scripts. -
Uses of LogicalOperator in com.pervasive.datarush.operators.select
Classes in com.pervasive.datarush.operators.select that implement LogicalOperator Modifier and Type Class Description classFilterRowsFilters records based on a specified predicate.classLimitRowsTruncates a flow to a fixed number of records.classSampleRandomRowsApply random sampling to the input data. -
Uses of LogicalOperator in com.pervasive.datarush.operators.sink
Classes in com.pervasive.datarush.operators.sink that implement LogicalOperator Modifier and Type Class Description classCollectRecordsCollects input data into an in-memory token list.classLogRowsLog information about the input data from a flow. -
Uses of LogicalOperator in com.pervasive.datarush.operators.sort
Classes in com.pervasive.datarush.operators.sort that implement LogicalOperator Modifier and Type Class Description classSortSorts the input data. -
Uses of LogicalOperator in com.pervasive.datarush.operators.source
Classes in com.pervasive.datarush.operators.source that implement LogicalOperator Modifier and Type Class Description classEmitRecordsEmits an in-memory token list as output.classGenerateArithmeticSequenceGenerates a sequence of numerical values, with a constant difference between consecutive values.classGenerateConstantGenerates copies of a constant value.classGenerateRandomGenerates rows of random data.classGenerateRepeatingCycleGenerates a cycle of repeating values. -
Uses of LogicalOperator in com.pervasive.datarush.operators.string
Classes in com.pervasive.datarush.operators.string that implement LogicalOperator Modifier and Type Class Description classSplitFieldSplits a string field into multiple fields, based on a specified pattern. -
Uses of LogicalOperator in com.pervasive.datarush.operators.testutils
Classes in com.pervasive.datarush.operators.testutils that implement LogicalOperator Modifier and Type Class Description classDumpPartitionsFor test purposes--sorts inputs and writes to a fileclassErrorSinkA record source sink throws an error either at composition time or execution time.classErrorSourceA record source that throws an error either at composition time or execution time.classSimulatePartitionsFor tests that wish to simulate a partitioned read. -
Uses of LogicalOperator in com.pervasive.datarush.ports
Methods in com.pervasive.datarush.ports that return LogicalOperator Modifier and Type Method Description LogicalOperatorLogicalPort. getOwner()Returns a reference to the operator that declared this portMethods in com.pervasive.datarush.ports with parameters of type LogicalOperator Modifier and Type Method Description abstract TLogicalPortFactory. newPort(LogicalOperator owner, String name, LogicalPort.Direction direction, boolean optional)Public only as a matter of implementation; clients should not use this method directly.Constructors in com.pervasive.datarush.ports with parameters of type LogicalOperator Constructor Description LogicalPort(LogicalOperator owner, String name, LogicalPort.Direction direction, boolean optional)Create a new LogicalPort -
Uses of LogicalOperator in com.pervasive.datarush.ports.model
Methods in com.pervasive.datarush.ports.model with parameters of type LogicalOperator Modifier and Type Method Description static DoneSignalPortDoneSignalPort. getOutput(LogicalOperator op)Returns the done signal port from the given operator if it defines one, throwing an exception if none foundSimpleModelPort<T>SimpleModelPort.Factory. newPort(LogicalOperator owner, String name, LogicalPort.Direction direction, boolean optional)Constructors in com.pervasive.datarush.ports.model with parameters of type LogicalOperator Constructor Description AbstractModelPort(LogicalOperator owner, String name, LogicalPort.Direction direction, boolean optional, ModelStorageHandler<T> storageHandler)Subclasses must invoke this constructor -
Uses of LogicalOperator in com.pervasive.datarush.ports.record
Classes in com.pervasive.datarush.ports.record that implement LogicalOperator Modifier and Type Class Description classExternalRecordSinkDefines an external sink of record data.classExternalRecordSourceDefines an external source of record data. -
Uses of LogicalOperator in com.pervasive.datarush.script
Methods in com.pervasive.datarush.script that return LogicalOperator Modifier and Type Method Description LogicalOperatorOperatorDescriptor. createInstance()Create an instance of the operator.Methods in com.pervasive.datarush.script that return types with arguments of type LogicalOperator Modifier and Type Method Description Class<? extends LogicalOperator>OperatorDescriptor. getOpClass()Get the class of the operator.Constructor parameters in com.pervasive.datarush.script with type arguments of type LogicalOperator Constructor Description OperatorDescriptor(Class<? extends LogicalOperator> opClass)Construct an operator definition with the default name of the operator.OperatorDescriptor(Class<? extends LogicalOperator> opClass, String opName)Construct an operator descriptor. -
Uses of LogicalOperator in com.pervasive.datarush.script.operators.group
Classes in com.pervasive.datarush.script.operators.group that implement LogicalOperator Modifier and Type Class Description classProcessByGroupExecutes an application graph for each distinct key group of data within the input data set.
-