Uses of Class
com.pervasive.datarush.ports.record.RecordPort

Packages that use RecordPort

Package	Description
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.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.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.learner	Provides an implementation of an SVM learner.
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.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.jdbc	Provides operators for reading from JDBC sources and writing to JDBC targets.
com.pervasive.datarush.operators.io.paraccel
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.record	Provides operators for manipulating record structure.
com.pervasive.datarush.operators.scripting	Provides the RunScript operator 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 the LogRows operator 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.ports.record	Provides implementations of port objects related to the flow of record sets between operators.

Uses of RecordPort in com.pervasive.datarush.analytics.arm

Methods in com.pervasive.datarush.analytics.arm that return RecordPort

Modifier and Type	Method and Description
RecordPort	FrequentItems.getInput() Get the input port of this operator.
RecordPort	FrequentItems.getOutput() Get the output port of this operator.

Uses of RecordPort in com.pervasive.datarush.analytics.arm.fpgrowth

Methods in com.pervasive.datarush.analytics.arm.fpgrowth that return RecordPort

Modifier and Type	Method and Description
RecordPort	FPGrowth.getInput() Get the input port that should contain transactions.
RecordPort	FPGrowth.getItemSets() Get the output port containing the frequent item sets.

Uses of RecordPort in com.pervasive.datarush.analytics.cleansing

Methods in com.pervasive.datarush.analytics.cleansing that return RecordPort

Modifier and Type	Method and Description
RecordPort	ReplaceMissingValues.getInput() Gets the record port providing the input data to the operation.
RecordPort	ReplaceMissingValues.getOutput() Gets the record port providing the output from the operation.

Uses of RecordPort in com.pervasive.datarush.analytics.cluster

Methods in com.pervasive.datarush.analytics.cluster that return RecordPort

Modifier and Type	Method and Description
RecordPort	ClusterPredictor.getOutput() Returns a record port consisting of the input plus the assigned cluster IDs.

Uses of RecordPort in com.pervasive.datarush.analytics.cluster.kmeans

Methods in com.pervasive.datarush.analytics.cluster.kmeans that return RecordPort

Modifier and Type	Method and Description
RecordPort	KMeans.getInput() Returns the input port.

Uses of RecordPort in com.pervasive.datarush.analytics.decisiontree.learner

Methods in com.pervasive.datarush.analytics.decisiontree.learner that return RecordPort

Modifier and Type	Method and Description
RecordPort	DecisionTreeLearner.getInput() Returns the input port for the training data that is used to build the model.

Uses of RecordPort in com.pervasive.datarush.analytics.decisiontree.predictor

Methods in com.pervasive.datarush.analytics.decisiontree.predictor that return RecordPort

Modifier and Type	Method and Description
RecordPort	DecisionTreePredictor.getOutput() Returns a record port consisting of the original input plus predicted values.

Uses of RecordPort in com.pervasive.datarush.analytics.knn

Methods in com.pervasive.datarush.analytics.knn that return RecordPort

Modifier and Type	Method and Description
RecordPort	KNNClassifier.getOutput() Gets the record port providing the output from the operation.
RecordPort	KNNClassifier.getQuery() Gets the record port providing the query data to the operations.
RecordPort	KNNClassifier.getTraining() Gets the record port providing the training data to the operations.

Uses of RecordPort in com.pervasive.datarush.analytics.naivebayes.learner

Methods in com.pervasive.datarush.analytics.naivebayes.learner that return RecordPort

Modifier and Type	Method and Description
RecordPort	NaiveBayesLearner.getInput() The input data.

Uses of RecordPort in com.pervasive.datarush.analytics.naivebayes.predictor

Methods in com.pervasive.datarush.analytics.naivebayes.predictor that return RecordPort

Modifier and Type	Method and Description
RecordPort	NaiveBayesPredictor.getOutput() Returns a record port consisting of the input plus predicted values appended.

Uses of RecordPort in com.pervasive.datarush.analytics.r

Methods in com.pervasive.datarush.analytics.r that return RecordPort

Modifier and Type	Method and Description
RecordPort	RunRScript.getInput()
RecordPort	RunRScript.getOutput()

Uses of RecordPort in com.pervasive.datarush.analytics.regression

Methods in com.pervasive.datarush.analytics.regression that return RecordPort

Modifier and Type	Method and Description
RecordPort	SumOfSquares.getInput() Get the input port for this operator.
RecordPort	LogisticRegressionLearner.getInput()
RecordPort	LinearRegressionLearner.getInput() Get the input port of this operator.

Uses of RecordPort in com.pervasive.datarush.analytics.stats

Methods in com.pervasive.datarush.analytics.stats that return RecordPort

Modifier and Type	Method and Description
RecordPort	DataQualityAnalyzer.getClean() Returns a port that will output the "clean" rows.
RecordPort	DataQualityAnalyzer.getDirty() Returns a port that will output the "dirty" rows.
RecordPort	SummaryStatistics.getInput() Returns an input port for the input dataset.
RecordPort	Rank.getInput()
RecordPort	NormalizeValues.getInput()
RecordPort	DistinctValues.getInput()
RecordPort	DataQualityAnalyzer.getInput() Returns a port for the input dataset to be tested.
RecordPort	Rank.getOutput()
RecordPort	NormalizeValues.getOutput()
RecordPort	DistinctValues.getOutput()

Uses of RecordPort in com.pervasive.datarush.analytics.svm.learner

Methods in com.pervasive.datarush.analytics.svm.learner that return RecordPort

Modifier and Type	Method and Description
RecordPort	SVMLearner.getInput() The input data.

Uses of RecordPort in com.pervasive.datarush.analytics.text

Methods in com.pervasive.datarush.analytics.text that return RecordPort

Modifier and Type	Method and Description
RecordPort	DictionaryFilter.getDictionaryInput() Get the optional dictionary input port of this operator.
RecordPort	TextTokenizer.getInput() Get the input port of this operator.
RecordPort	TextStemmer.getInput() Get the input port of this operator.
RecordPort	TextFrequencyFilter.getInput() Get the input port of this operator.
RecordPort	GenerateBagOfWords.getInput() Get the input port of this operator.
RecordPort	FilterText.getInput() Get the input port of this operator.
RecordPort	ExpandTextTokens.getInput() Get the input port of this operator.
RecordPort	ExpandTextFrequency.getInput() Get the input port of this operator.
RecordPort	DictionaryFilter.getInput() Get the input port of this operator.
RecordPort	CountTokens.getInput() Get the input port of this operator.
RecordPort	ConvertTextCase.getInput() Get the input port of this operator.
RecordPort	CalculateWordFrequency.getInput() Get the input port of this operator.
RecordPort	CalculateNGramFrequency.getInput() Get the input port of this operator.
RecordPort	TextTokenizer.getOutput() Get the output port of this operator.
RecordPort	TextStemmer.getOutput() Get the output port of this operator.
RecordPort	TextFrequencyFilter.getOutput() Get the output port of this operator.
RecordPort	GenerateBagOfWords.getOutput() Get the output port of this operator.
RecordPort	FilterText.getOutput() Get the output port of this operator.
RecordPort	ExpandTextTokens.getOutput() Get the output port of this operator.
RecordPort	ExpandTextFrequency.getOutput() Get the output port of this operator.
RecordPort	DictionaryFilter.getOutput() Get the output port of this operator.
RecordPort	CountTokens.getOutput() Get the output port of this operator.
RecordPort	ConvertTextCase.getOutput() Get the output port of this operator.
RecordPort	CalculateWordFrequency.getOutput() Get the output port of this operator.
RecordPort	CalculateNGramFrequency.getOutput() Get the output port of this operator.

Uses of RecordPort in com.pervasive.datarush.analytics.util

Methods in com.pervasive.datarush.analytics.util that return RecordPort

Modifier and Type	Method and Description
RecordPort	AbstractPredictor.getInput() The input data.
RecordPort	AbstractPredictor.getOutput() The original data with prediction appended

Methods in com.pervasive.datarush.analytics.util with parameters of type RecordPort

Modifier and Type	Method and Description
static MixedTypeMetadataHelper	MixedTypeMetadataHelper.ensureHelper(IterativeExecutionContext ctx, RecordPort input, List<String> includedColumns, String targetColumn, int maxDistinctNominalValues) Discovers the metadata helper within an iterative context

Uses of RecordPort in com.pervasive.datarush.analytics.viz

Methods in com.pervasive.datarush.analytics.viz that return RecordPort

Modifier and Type	Method and Description
RecordPort	DrawDiagnosticsChart.getInput(int idx) Returns the input port for the given index.
RecordPort	DrawDiagnosticsChart.getOutput() Returns the output port.

Uses of RecordPort in com.pervasive.datarush.hbase

Methods in com.pervasive.datarush.hbase that return RecordPort

Modifier and Type	Method and Description
RecordPort	WriteHBase.getInput()
RecordPort	DeleteHBase.getInput()
RecordPort	ReadHBase.getOutput()

Methods in com.pervasive.datarush.hbase with parameters of type RecordPort

Modifier and Type	Method and Description
protected void	KeyValueOperator.mapToHCatalog(MetadataContext ctx, RecordPort input) Write a mapping to a new HCatalog table.

Uses of RecordPort in com.pervasive.datarush.matching

Methods in com.pervasive.datarush.matching that return RecordPort

Modifier and Type	Method and Description
RecordPort	DiscoverDuplicates.getInput() Gets the record port providing input to the operation.
RecordPort	DiscoverLinks.getLeft() Gets the record port providing the left-hand input to the operation.
RecordPort	DiscoverLinks.getRight() Gets the record port providing the right-hand input to the operation.

Uses of RecordPort in com.pervasive.datarush.matching.block

Methods in com.pervasive.datarush.matching.block that return RecordPort

Modifier and Type	Method and Description
RecordPort	BlockSelf.getInput() Gets the record port providing the input to the pair generation.
RecordPort	BlockRecords.getLeftInput() Gets the record port providing the left hand input to the pair generation.
RecordPort	BlockCartesian.getLeftInput() Gets the record port providing the left hand input to the pair generation.
RecordPort	GroupPairsSortedRows.getOutput() Gets the record port providing the results of the pair generation.
RecordPort	BlockSelf.getOutput() Gets the record port providing the results of the pair generation.
RecordPort	BlockRecords.getOutput() Gets the record port providing the results of the pair generation.
RecordPort	BlockCartesian.getOutput() Gets the record port providing the results of the pair generation.
RecordPort	BlockRecords.getRightInput() Gets the record port providing the right hand input to the pair generation.
RecordPort	BlockCartesian.getRightInput() Gets the record port providing the right hand input to the pair generation.

Uses of RecordPort in com.pervasive.datarush.matching.cluster

Methods in com.pervasive.datarush.matching.cluster that return RecordPort

Modifier and Type	Method and Description
RecordPort	ClusterLinks.getInput() Gets the record port providing the input to the clustering operation.
RecordPort	ClusterDuplicates.getInput() Gets the record port providing the input to the clustering operation.
RecordPort	ClusterLinks.getOutput() Gets the record port providing the results of the clustering operation.
RecordPort	ClusterDuplicates.getOutput() Gets the record port providing the results of the clustering operation.

Uses of RecordPort in com.pervasive.datarush.matching.tune

Methods in com.pervasive.datarush.matching.tune that return RecordPort

Modifier and Type	Method and Description
RecordPort	AnalyzeDuplicateKeys.getInput() Gets the record port providing the input data to analyze.
RecordPort	AnalyzeLinkKeys.getLeft() Gets the record port providing the input data to analyze for the left side.
RecordPort	AnalyzeLinkKeys.getRight() Gets the record port providing the input data to analyze for the right side.

Uses of RecordPort in com.pervasive.datarush.operators

Fields in com.pervasive.datarush.operators declared as RecordPort

Modifier and Type	Field and Description
protected RecordPort	AbstractRecordCompositeOperator.input The input port
protected RecordPort	AbstractExecutableRecordPipeline.input The record port for input to the operator
protected RecordPort	AbstractDeferredRecordOperator.input The input port
protected RecordPort	AbstractRecordCompositeOperator.output The output port
protected RecordPort	AbstractExecutableRecordPipeline.output The record port for output from the operator
protected RecordPort	AbstractDeferredRecordOperator.output The output port

Methods in com.pervasive.datarush.operators that return RecordPort

Modifier and Type	Method and Description
RecordPort	RecordSinkOperator.getInput() Gets the record port providing the input data to the sink.
RecordPort	OpenRecordSink.getInput()
RecordPort	AbstractRecordCompositeOperator.getInput()
RecordPort	AbstractExecutableRecordPipeline.getInput() Gets the record port providing the input data to the operation.
RecordPort	AbstractDeferredRecordOperator.getInput()
RecordPort	RecordSourceOperator.getOutput() Gets the record port providing the output data from the source.
RecordPort	OpenRecordSource.getOutput()
RecordPort	AbstractRecordCompositeOperator.getOutput()
RecordPort	AbstractExecutableRecordPipeline.getOutput() Gets the record port providing the output from the operation.
RecordPort	AbstractDeferredRecordOperator.getOutput()
protected RecordPort	AbstractLogicalOperator.newRecordInput(String name) Creates a new record input port.
protected RecordPort	AbstractLogicalOperator.newRecordInput(String name, boolean optional) Creates a new record input port.
protected RecordPort	AbstractLogicalOperator.newRecordOutput(String name) Creates a new record output port.

Methods in com.pervasive.datarush.operators that return types with arguments of type RecordPort

Modifier and Type	Method and Description
List<RecordPort>	OpenMultiRecordSink.getInputs()
List<RecordPort>	OpenMultiRecordSource.getOutputs()

Methods in com.pervasive.datarush.operators with parameters of type RecordPort

Modifier and Type	Method and Description
void	OpenMultiRecordSink.connectInput(int index, RecordPort to)
void	OpenRecordSink.connectInput(RecordPort to)
void	OpenRecordSource.connectOutput(RecordPort from)
void	OpenMultiRecordSource.connectOutput(RecordPort from, int index)

Uses of RecordPort in com.pervasive.datarush.operators.assertion

Methods in com.pervasive.datarush.operators.assertion that return RecordPort

Modifier and Type	Method and Description
RecordPort	AssertEqualTypes.getActualInput() Get the actual value input port.
RecordPort	AssertEqualHash.getActualInput() Get the actual data input port.
RecordPort	AssertEqual.getActualInput() Get the actual input data port.
RecordPort	AssertEqualTypes.getExpectedInput() Get the optional expected value input port.
RecordPort	AssertEqualHash.getExpectedInput() Get the expected data input port.
RecordPort	AssertEqual.getExpectedInput() Get the expected input data port.
RecordPort	AssertSorted.getInput() Get the input data port.
RecordPort	AssertRowCount.getInput()
RecordPort	AssertPredicate.getInput() Get the input port of this operator.
RecordPort	AssertMetadata.getInput() Get the input data port to assert the metadata on.
RecordPort	AssertSorted.getOutput() Output port containing the input data verified to be sorted correctly.

Uses of RecordPort in com.pervasive.datarush.operators.group

Fields in com.pervasive.datarush.operators.group declared as RecordPort

Modifier and Type	Field and Description
protected RecordPort	SortedGroupHandler.inputPort
protected RecordPort	SortedGroupHandler.outputPort

Methods in com.pervasive.datarush.operators.group that return RecordPort

Modifier and Type	Method and Description
RecordPort	SortedGroupHandler.getInput()
RecordPort	RemoveDuplicates.getInput() Returns the data to be de-duplicated
RecordPort	Group.getInput()
RecordPort	SortedGroupHandler.getOutput()
RecordPort	RemoveDuplicates.getOutput() Returns the de-duplicated data
RecordPort	Group.getOutput()

Uses of RecordPort in com.pervasive.datarush.operators.io

Fields in com.pervasive.datarush.operators.io declared as RecordPort

Modifier and Type	Field and Description
protected RecordPort	AbstractWriter.input The input port of the read operator
protected RecordPort	AbstractReader.output The output port of the read operator

Methods in com.pervasive.datarush.operators.io that return RecordPort

Modifier and Type	Method and Description
RecordPort	WriteSink.getInput() Gets the record port providing the records to write to the target sink.
RecordPort	AbstractWriter.getInput() Gets the record port providing the records to write to the target sink.
RecordPort	ReadSource.getOutput() Gets the record port providing the records read from the data source.
RecordPort	AbstractReader.getOutput() Gets the record port providing the records read from the data source.

Uses of RecordPort in com.pervasive.datarush.operators.io.jdbc

Fields in com.pervasive.datarush.operators.io.jdbc declared as RecordPort

Modifier and Type	Field and Description
protected RecordPort	AbstractWriteToJDBC.input

Methods in com.pervasive.datarush.operators.io.jdbc that return RecordPort

Modifier and Type	Method and Description
RecordPort	ReadFromJDBC.getInput() Get the optional input port that contains parameter values to apply to a parameterized data query.
RecordPort	AbstractWriteToJDBC.getInput() Returns the input port.
RecordPort	AbstractWriteToJDBC.AbstractWriteToJDBCWorker.getInput()
RecordPort	UpdateInJDBC.getOutput() Get the output port containing the statuses received from the database.
RecordPort	ReadFromJDBC.getOutput() Get the output port containing the data retrieved from the source database.
RecordPort	DeleteFromJDBC.getOutput() Get the output port containing the statues received from the database.
abstract RecordPort	AbstractWriteToJDBC.AbstractWriteToJDBCWorker.getOutput()

Methods in com.pervasive.datarush.operators.io.jdbc with parameters of type RecordPort

Modifier and Type	Method and Description
protected abstract AbstractWriteToJDBC.AbstractWriteHelper	AbstractWriteToJDBC.AbstractWriteToJDBCWorker.createWriteHelper(JDBCConnector connector, RecordPort input, RecordPort output, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties)

Constructors in com.pervasive.datarush.operators.io.jdbc with parameters of type RecordPort

Constructor and Description
AbstractWriteHelper(JDBCConnector connector, RecordPort input, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties properties)

Uses of RecordPort in com.pervasive.datarush.operators.io.paraccel

Methods in com.pervasive.datarush.operators.io.paraccel that return RecordPort

Modifier and Type	Method and Description
RecordPort	MatrixOperatorBase.getInput()

Uses of RecordPort in com.pervasive.datarush.operators.io.textfile

Methods in com.pervasive.datarush.operators.io.textfile that return RecordPort

Modifier and Type	Method and Description
RecordPort	ParseTextFields.getInput()
RecordPort	ParseTextFields.getOutput()
RecordPort	ParseTextFields.getRejects() Gets the port providing records which failed parsing.

Uses of RecordPort in com.pervasive.datarush.operators.io.vectorwise

Methods in com.pervasive.datarush.operators.io.vectorwise that return RecordPort

Modifier and Type	Method and Description
RecordPort	LoadVectorOnHadoop.getInput() Deprecated.
RecordPort	LoadActianVector.getInputPort()
RecordPort	LoadActianVector.getRejectPort() Gets the port providing records which failed the load.

Uses of RecordPort in com.pervasive.datarush.operators.io.vectorwise.dl

Methods in com.pervasive.datarush.operators.io.vectorwise.dl that return RecordPort

Modifier and Type	Method and Description
RecordPort	LoadVectorOnHadoopDirect.getInputPort() Deprecated.
RecordPort	LoadVectorOnHadoopDirect.getRejectPort() Deprecated. Gets the port providing records which failed the load.

Uses of RecordPort in com.pervasive.datarush.operators.join

Methods in com.pervasive.datarush.operators.join that return RecordPort

Modifier and Type	Method and Description
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)
RecordPort	FilterExistJoinProcess.getAntioutput()
RecordPort	UnionAll.getLeft() Returns the left input port.
RecordPort	FilterExistJoinProcess.getLeft()
RecordPort	AbstractRelationalJoin.getLeft() Returns the left input port.
RecordPort	CrossJoin.getLeftInput() Returns the left input port
RecordPort	UnionAll.getOutput() Returns the output port.
RecordPort	FilterExistJoinProcess.getOutput()
RecordPort	CrossJoin.getOutput() Returns the input port
RecordPort	AbstractRelationalJoin.getOutput() Returns the output port.
RecordPort	FilterExistingRows.getRejects() Returns the port providing the data from the left which failed to match any record on the right.
RecordPort	UnionAll.getRight() Returns the right input port.
RecordPort	FilterExistJoinProcess.getRight()
RecordPort	AbstractRelationalJoin.getRight() Returns the right input port.
RecordPort	CrossJoin.getRightInput() Returns the right input port

Methods in com.pervasive.datarush.operators.join with parameters of type RecordPort

Modifier and Type	Method and Description
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)

Uses of RecordPort in com.pervasive.datarush.operators.record

Methods in com.pervasive.datarush.operators.record that return RecordPort

Modifier and Type	Method and Description
RecordPort	SelectFields.getInput()
RecordPort	RowsToColumns.getInput()
RecordPort	RetainFields.getInput()
RecordPort	RemoveFields.getInput()
RecordPort	RemapFields.getInput()
RecordPort	DiscoverDomain.getInput() Returns the input port containing the string fields to convert
RecordPort	DeriveFields.getInput()
RecordPort	MergeFields.getLeftInput() Gets the record port providing the "left" input for the merge.
RecordPort	SelectFields.getOutput()
RecordPort	RowsToColumns.getOutput()
RecordPort	RetainFields.getOutput()
RecordPort	RemoveFields.getOutput()
RecordPort	RemapFields.getOutput()
RecordPort	MergeFields.getOutput() Gets the record port providing the resulting merged records.
RecordPort	DeriveFields.getOutput()
RecordPort	MergeFields.getRightInput() Gets the record port providing the "right" input for the merge.

Uses of RecordPort in com.pervasive.datarush.operators.scripting

Methods in com.pervasive.datarush.operators.scripting that return RecordPort

Modifier and Type	Method and Description
RecordPort	RunScript.getInput() Get the input port to the run script operator.
RecordPort	RunScript.getOutput() Get the output port of the run script operator.

Uses of RecordPort in com.pervasive.datarush.operators.select

Methods in com.pervasive.datarush.operators.select that return RecordPort

Modifier and Type	Method and Description
RecordPort	SampleRandomRows.getInput()
RecordPort	LimitRows.getInput()
RecordPort	FilterRows.getInput()
RecordPort	SampleRandomRows.getOutput()
RecordPort	LimitRows.getOutput()
RecordPort	FilterRows.getOutput()
RecordPort	FilterRows.getRejects() Gets the port providing records which failed the predicate test.

Uses of RecordPort in com.pervasive.datarush.operators.sink

Methods in com.pervasive.datarush.operators.sink that return RecordPort

Modifier and Type	Method and Description
RecordPort	LogRows.getInput()
RecordPort	CollectRecords.getInput()

Uses of RecordPort in com.pervasive.datarush.operators.sort

Methods in com.pervasive.datarush.operators.sort that return RecordPort

Modifier and Type	Method and Description
RecordPort	Sort.getInput()
RecordPort	Sort.getOutput()

Uses of RecordPort in com.pervasive.datarush.operators.source

Methods in com.pervasive.datarush.operators.source that return RecordPort

Modifier and Type	Method and Description
RecordPort	GenerateRepeatingCycle.getInput() The flow of data to be repeated cyclically.
RecordPort	GenerateRepeatingCycle.getOutput() Gets the flow of generated values.
RecordPort	GenerateRandom.getOutput()
RecordPort	GenerateConstant.getOutput()
RecordPort	GenerateArithmeticSequence.getOutput() Returns the output port whose values are equal to the sequence of values.
RecordPort	EmitRecords.getOutput()

Uses of RecordPort in com.pervasive.datarush.operators.string

Methods in com.pervasive.datarush.operators.string that return RecordPort

Modifier and Type	Method and Description
RecordPort	SplitField.getInput()
RecordPort	SplitField.getOutput()

Uses of RecordPort in com.pervasive.datarush.ports.record

Fields in com.pervasive.datarush.ports.record with type parameters of type RecordPort

Modifier and Type	Field and Description
static LogicalPortFactory<RecordPort>	RecordPort.FACTORY The singleton for creating record ports.

Methods in com.pervasive.datarush.ports.record that return RecordPort

Modifier and Type	Method and Description
RecordPort	RecordPort.filtered(LogicalSubgraph subgraph, RecordPortOptions options) Returns a new record port that is a filtered view of this record port.
RecordPort	ExternalRecordSink.getInput()
RecordPort	ExternalRecordSource.getOutput()

Methods in com.pervasive.datarush.ports.record with parameters of type RecordPort

Modifier and Type	Method and Description
static KeyDrivenDataDistribution	MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx, RecordPort port, SortKey... keys) Negotiates the required data distribution on the specified port using the given grouping fields with sort ordering.
static KeyDrivenDataDistribution	MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx, RecordPort port, String... keys) Negotiates the required data ordering and distribution on the specified port using the given grouping fields.
static DataOrdering	MetadataUtil.negotiateOrdering(MetadataCalculationContext ctx, RecordPort port, String... keys) Negotiates the required data ordering on the specified port using the given key fields.