Uses of Interface
com.pervasive.datarush.operators.StreamingMetadataContext
Packages that use StreamingMetadataContext
Package
Description
Provides common classes for Association Rule Mining (ARM).
Provides the decision tree pruner operator and associated classes.
Provides an implementation of a Naive Bayes predictor.
Provides shared and base classes for PMML model representation of Analytics algorithms.
Provides utility, PMML and other classes for shared use by regression related entities.
Provides various statistics, Data Summarizer, and Data Quality Analyzer.
Provides an implementation of an SVM learner.
Provides an implementation of an SVM predictor.
Provides various unstructured text processing operators.
Provides some (internal) utility classes for Analytics.
Provides operators for generating possible candidate pairs.
Provides classes and interfaces for developing dataflow operators.
Provides operators for making assertions on flows and files.
Provides base file I/O components including encoders and decoders.
Provides operators for reading from JDBC sources and writing to JDBC targets.
Provides operators for reading and writing DataRush staging datasets.
Provides operators for reading and writing text data.
Provides operators for joining together two data sets into a single one.
Provides operators for handling models.
Provides operators for partitioning and unpartitioning flows of data.
Provides operators for manipulating record structure.
Provides the
RunScript
operator for running user-defined scripts on the rows of an input record flow.Provides operators for selecting a subset of the data set.
Provides the
LogRows operator
for writing debugging information about a flow to the logging API.Provides operators for sorting and manipulating sorted
flows.
Provides operators for generating data tokens in various ways.
Provides operators for operating on string values in records.
Provides implementations of port objects related to the flow of record sets
between operators.
-
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.arm
Methods in com.pervasive.datarush.analytics.arm with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidConvertARMModel.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.decisiontree.pruner
Methods in com.pervasive.datarush.analytics.decisiontree.pruner with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidDecisionTreePruner.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.naivebayes.predictor
Methods in com.pervasive.datarush.analytics.naivebayes.predictor with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidNaiveBayesPredictor.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.pmml
Methods in com.pervasive.datarush.analytics.pmml with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidWritePMML.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.regression
Methods in com.pervasive.datarush.analytics.regression with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidSumOfSquares.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.stats
Methods in com.pervasive.datarush.analytics.stats with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidRank.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.svm.learner
Methods in com.pervasive.datarush.analytics.svm.learner with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidSVMLearner.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.svm.predictor
Methods in com.pervasive.datarush.analytics.svm.predictor with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidSVMPredictor.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.text
Methods in com.pervasive.datarush.analytics.text with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidCalculateNGramFrequency.computeMetadata(StreamingMetadataContext ctx) protected voidCalculateWordFrequency.computeMetadata(StreamingMetadataContext ctx) protected voidConvertTextCase.computeMetadata(StreamingMetadataContext ctx) protected voidCountTokens.computeMetadata(StreamingMetadataContext ctx) protected voidDictionaryFilter.computeMetadata(StreamingMetadataContext ctx) protected voidExpandTextFrequency.computeMetadata(StreamingMetadataContext ctx) protected voidExpandTextTokens.computeMetadata(StreamingMetadataContext ctx) protected voidFilterText.computeMetadata(StreamingMetadataContext ctx) protected voidGenerateBagOfWords.computeMetadata(StreamingMetadataContext ctx) protected voidTextFrequencyFilter.computeMetadata(StreamingMetadataContext ctx) protected voidTextStemmer.computeMetadata(StreamingMetadataContext ctx) protected voidTextTokenizer.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.analytics.util
Methods in com.pervasive.datarush.analytics.util with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidAbstractPredictor.computeMetadata(StreamingMetadataContext ctx) Default implementation of computeMetadata. -
Uses of StreamingMetadataContext in com.pervasive.datarush.matching.block
Methods in com.pervasive.datarush.matching.block with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidGroupPairsSortedRows.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators
Methods in com.pervasive.datarush.operators with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected abstract voidDeferredCompositeOperator.computeMetadata(StreamingMetadataContext ctx) Implementations must adhere to all of the contracts specified byStreamingOperator.computeMetadata(com.pervasive.datarush.operators.StreamingMetadataContext).final voidOperatorProxies.StreamingOperatorProxy.computeMetadata(StreamingMetadataContext ctx) Public only as a matter of implementation; not intended for external useprotected abstract voidStreamingOperator.computeMetadata(StreamingMetadataContext ctx) Implementations must adhere to the following contractsprotected final voidDeferredCompositeOperator.computeOutputTypes(StreamingMetadataContext ctx) Convenience method that implementations ofcomputeMetadatamay use in order to compute the output types. -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.assertion
Methods in com.pervasive.datarush.operators.assertion with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidAssertEqual.computeMetadata(StreamingMetadataContext ctx) protected voidAssertMetadata.computeMetadata(StreamingMetadataContext ctx) protected voidAssertPredicate.computeMetadata(StreamingMetadataContext ctx) protected voidAssertSorted.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.graph
Methods in com.pervasive.datarush.operators.graph with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidMockableExternalRecordSink.computeMetadata(StreamingMetadataContext ctx) protected voidMockableExternalRecordSource.computeMetadata(StreamingMetadataContext ctx) protected voidSubJobExecutor.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.io
Methods in com.pervasive.datarush.operators.io with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidWriteSink.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.io.jdbc
Methods in com.pervasive.datarush.operators.io.jdbc with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidAbstractWriteToJDBC.AbstractWriteToJDBCWorker.computeMetadata(StreamingMetadataContext ctx) protected voidFinalizeSQLWorker.computeMetadata(StreamingMetadataContext ctx) protected voidInitializeSQLWorker.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.io.staging
Methods in com.pervasive.datarush.operators.io.staging with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected final voidForceStaging.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.io.textfile
Methods in com.pervasive.datarush.operators.io.textfile with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidParseTextFields.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.join
Methods in com.pervasive.datarush.operators.join with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidCrossJoin.computeMetadata(StreamingMetadataContext ctx) protected final voidFilterExistJoinProcess.computeMetadata(StreamingMetadataContext ctx) protected voidUnionAll.computeMetadata(StreamingMetadataContext ctx) This operator can execute in parallel. -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.model
Methods in com.pervasive.datarush.operators.model with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected final voidGetModel.computeMetadata(StreamingMetadataContext ctx) protected final voidMergeModel.computeMetadata(StreamingMetadataContext ctx) protected final voidPutModel.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.partition
Methods in com.pervasive.datarush.operators.partition with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidGatherHint.computeMetadata(StreamingMetadataContext ctx) protected voidPartitionHint.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.record
Methods in com.pervasive.datarush.operators.record with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidColumnsToRows.computeMetadata(StreamingMetadataContext ctx) protected voidDeriveFields.computeMetadata(StreamingMetadataContext ctx) protected final voidFilterFields.computeMetadata(StreamingMetadataContext ctx) protected voidMergeFields.computeMetadata(StreamingMetadataContext ctx) protected voidRemapFields.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.scripting
Methods in com.pervasive.datarush.operators.scripting with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidRunJavaScript.computeMetadata(StreamingMetadataContext ctx) protected voidRunScript.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.select
Methods in com.pervasive.datarush.operators.select with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidFilterRows.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.sink
Methods in com.pervasive.datarush.operators.sink with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidCollectRecords.computeMetadata(StreamingMetadataContext ctx) protected voidLogRows.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.sort
Methods in com.pervasive.datarush.operators.sort with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidSort.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.source
Methods in com.pervasive.datarush.operators.source with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidEmitRecords.computeMetadata(StreamingMetadataContext ctx) protected voidGenerateArithmeticSequence.computeMetadata(StreamingMetadataContext ctx) protected voidGenerateConstant.computeMetadata(StreamingMetadataContext ctx) protected voidGenerateRandom.computeMetadata(StreamingMetadataContext ctx) protected voidGenerateRepeatingCycle.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.string
Methods in com.pervasive.datarush.operators.string with parameters of type StreamingMetadataContext -
Uses of StreamingMetadataContext in com.pervasive.datarush.operators.testutils
Methods in com.pervasive.datarush.operators.testutils with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidErrorSink.computeMetadata(StreamingMetadataContext ctx) protected voidErrorSource.computeMetadata(StreamingMetadataContext ctx) protected voidSimulatePartitions.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.ports.record
Methods in com.pervasive.datarush.ports.record with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidExternalRecordSink.computeMetadata(StreamingMetadataContext ctx) protected voidExternalRecordSource.computeMetadata(StreamingMetadataContext ctx) -
Uses of StreamingMetadataContext in com.pervasive.datarush.script.operators.group
Methods in com.pervasive.datarush.script.operators.group with parameters of type StreamingMetadataContextModifier and TypeMethodDescriptionprotected voidProcessByGroup.computeMetadata(StreamingMetadataContext ctx)