Package | Description |
---|---|
com.actian.dataflow.operators.io.orc | |
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.learner |
Provides an implementation of an SVM learner.
|
com.pervasive.datarush.analytics.text |
Provides various unstructured text processing operators.
|
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.cluster |
Provides operators for clustering the results of duplicate or
linkage discovery.
|
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.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 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.
|
Modifier and Type | Method and Description |
---|---|
void |
WriteORC.setCompression(com.actian.dataflow.hive.shims.ORCCompression compression)
Sets the compression mode to use within the ORC file.
|
Modifier and Type | Method and Description |
---|---|
void |
ConvertARMModel.setConversionType(ConversionType conversionType)
Set the conversion type.
|
void |
FrequentItems.setItemFieldName(String itemFieldName)
Set the item field name property.
|
void |
FrequentItems.setLabelFieldName(String labelFieldName)
Set the optional label field name property.
|
void |
FrequentItems.setMinSupport(double minSupport)
Set the minimum support property.
|
void |
ConvertARMModel.setTarget(String targetPath)
Set the path for the target file of the conversion.
|
void |
FrequentItems.setTxnFieldName(String txnFieldName)
Set the transaction field name property.
|
Modifier and Type | Method and Description |
---|---|
void |
FPGrowth.setAnnotationText(String annotationText)
The text provided will be added as an annotation to the
output PMML model.
|
void |
FPGrowth.setItemFieldName(String itemFieldName)
Set the item field name property.
|
void |
FPGrowth.setK(int k)
Set the largest item-set cardinality wanted.
|
void |
FPGrowth.setLabelFieldName(String labelFieldName)
Set the optional label field name property.
|
void |
FPGrowth.setMinConfidence(double minConfidence)
Set the minimum confidence threshold.
|
void |
FPGrowth.setMinSupport(double minSupport)
Set the minimum support property.
|
void |
FPGrowth.setTxnFieldName(String txnFieldName)
Set the transaction identifier field name property.
|
Modifier and Type | Method and Description |
---|---|
void |
ReplaceMissingValues.setReplaceSpecifications(List<ReplaceSpecification> specifications)
Sets the replacement specifications to apply to the input data.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterPredictor.setWinnerFieldName(String winnerFieldName)
Sets the name of the winner field in the output.
|
Modifier and Type | Method and Description |
---|---|
void |
KMeans.setDistanceMeasure(DistanceMeasure distanceMeasure)
Sets the distance measure used to measure the distance between two points
when building the model.
|
void |
KMeans.setIncludedColumns(List<String> includedColumns)
Sets the list of columns to include for k-Means.
|
void |
KMeans.setK(int k)
Sets the "k" value, where k is the number of centroids to compute.
|
void |
KMeans.setMaxIterations(int max)
Sets the maximum number of iterations.
|
Modifier and Type | Method and Description |
---|---|
void |
DecisionTreeLearner.setBinaryNominalSplits(boolean binaryNominalSplits)
Sets whether we use subsets of nominal values for splitting.
|
void |
DecisionTreeLearner.setIncludedFields(List<String> includedFields)
Sets the list of columns to include for learning.
|
void |
DecisionTreeLearner.setInMemoryDataset(boolean inMemoryDataset)
Sets whether the dataset is to be kept in memory while the decision tree is
being build.
|
void |
DecisionTreeLearner.setMaxDistinctNominalValues(int maxDistinctNominalValues)
Sets the maximum number of distinct nominal values to allow.
|
void |
DecisionTreeLearner.setMaxTreeNodes(int maxTreeNodes)
Sets the maximum total nodes to allow in the tree.
|
void |
DecisionTreeLearner.setMinRecordsPerNode(int minRecordsPerNode)
Sets the minimum number of records per-node to allow in the tree.
|
void |
DecisionTreeLearner.setQualityMeasure(QualityMeasure qualityMeasure)
Sets the measure of quality to be used when determining the best split.
|
void |
DecisionTreeLearner.setStagingBlockSize(int stagingBlockSize)
Configures the
blockSize that is used when staging
the original dataset prior to redistributing the data for training. |
void |
DecisionTreeLearner.setTargetColumn(String targetColumn)
Sets the name of the column to predict.
|
Modifier and Type | Method and Description |
---|---|
void |
DecisionTreePredictor.setAppendConfidence(boolean appendConfidence)
Sets whether to append confidence information.
|
void |
DecisionTreePredictor.setAppendRecordCount(boolean appendRecordCount)
Sets whether to append record count information.
|
void |
DecisionTreePredictor.setConfidencePrefix(String confidencePrefix)
Sets the field name prefix to use for confidence.
|
void |
DecisionTreePredictor.setRecordCountPrefix(String recordCountPrefix)
Sets the field name prefix to use for record counts.
|
void |
DecisionTreePredictor.setWinnerField(String winnerField)
Sets the name of the winner field to output.
|
Modifier and Type | Method and Description |
---|---|
void |
DecisionTreePruner.setConfiguration(PruneConfiguration configuration)
Sets the configuration that controls how pruning is performed.
|
Modifier and Type | Method and Description |
---|---|
void |
KNNClassifier.setClassificationScheme(ClassificationScheme scheme)
Specifies how to determine the classification of a record
in the query data from the classifications of its nearest neighbors
in the example data.
|
void |
KNNClassifier.setK(int k)
Sets the size of the nearest neighbor set.
|
void |
KNNClassifier.setNearnessMeasure(NearnessMeasure measure)
Specifies how to determine the nearest neighbors of a record in
the query data.
|
void |
KNNClassifier.setSelectedFeatures(List<String> features)
Specifies the fields to use when determining the nearest
neighbors.
|
void |
KNNClassifier.setSelectedFeatures(String... features)
Specifies the fields to use when determining the nearest
neighbors.
|
void |
KNNClassifier.setTargetFeature(String feature)
Specifies the field in the example data which contains
classification data.
|
void |
KNNClassifier.setTrainingBuffer(long size)
Specifies the amount of memory, in bytes, to use for
buffering the example data.
|
void |
KNNClassifier.setTrainingBuffer(String sizeSpecifier)
Specifies the amount of memory to use for
buffering the example data.
|
Modifier and Type | Method and Description |
---|---|
void |
NaiveBayesLearner.setLearningColumns(List<String> learningColumns)
Sets the list of columns to be used to predict the output value.
|
void |
NaiveBayesLearner.setTargetColumn(String targetColumn)
Sets the column to be predicted.
|
Modifier and Type | Method and Description |
---|---|
void |
NaiveBayesPredictor.setAppendProbabilities(boolean appendProbabilities)
Sets whether to include probabilities in the prediction.
|
void |
NaiveBayesPredictor.setIgnoreMissingValues(boolean ignoreMissingValues)
Sets whether to ignore missing values.
|
void |
NaiveBayesPredictor.setLaplaceCorrector(double laplaceCorrector)
Sets the Laplace corrector to be used.
|
void |
NaiveBayesPredictor.setProbabilityPrefix(String probabilityPrefix)
Sets the field name prefix to use for probabilities.
|
void |
NaiveBayesPredictor.setWinnerField(String winnerField)
Sets the name of the winner field to output.
|
Modifier and Type | Method and Description |
---|---|
void |
ReadPMML.setFilePath(String filePath)
Sets the file to read from
|
void |
WritePMML.setTargetPathName(String targetPathName)
Sets the path to write to
|
Modifier and Type | Method and Description |
---|---|
DataDistribution |
RunRScript.getRequiredDataDistribution()
Get the value set for the required data distribution of the input port of this
operator.
|
void |
RunRScript.setCharset(String charsetName)
Set character set value which is used to format input and output data for R.
|
void |
RunRScript.setOutputType(RecordTokenType outputType)
Configure the output token type.
|
void |
RunRScript.setPathToRScript(String pathToRScript)
Set the path to the Rscript binary within the local R installation.
|
void |
RunRScript.setScriptSnippet(String scriptSnippet)
Set the R script to execute.
|
Modifier and Type | Method and Description |
---|---|
void |
LinearRegressionLearner.setDependentVariable(String dependentVariable)
Set the field name of the dependent variable.
|
void |
SumOfSquares.setFieldNames(List<String> fieldNames)
Set the list of fields to apply sum of squares.
|
void |
LinearRegressionLearner.setIndependentVariables(String... independentVariables)
Set the field names of the independent variables.
|
void |
LogisticRegressionLearner.setMaxDistinctNominalValues(int maxDistinctNominalValues)
Sets the maximum number of distinct nominal values to allow.
|
void |
RegressionPredictor.setPredictedFieldSuffix(String predictedFieldSuffix)
Set the suffix to be added to the target field name.
|
void |
LinearRegressionLearner.setReferenceValues(Map<String,String> referenceValues)
Set reference values for the independent categorical variables.
|
void |
LinearRegressionLearner.setSingularityThreshold(Double singularityThresholdValue)
Set singularityThreshold value against which a matrix is
considered singular or non singular.
|
Modifier and Type | Method and Description |
---|---|
void |
SummaryStatistics.setDetailLevel(DetailLevel detailLevel)
Sets the detail level that we use to compute statistics.
|
void |
SummaryStatistics.setFewDistinctValuesHint(boolean fewDistinctValuesHint)
Sets a hint as to whether there are expected to be a small number of distinct values.
|
void |
DistinctValues.setFewDistinctValuesHint(boolean fewDistinctValuesHint)
Sets a hint as to whether there are expected to be a small number of distinct values.
|
void |
SummaryStatistics.setIncludedFields(List<String> includedFields)
Sets the fields from the input dataset for which we are collecting statistics.
|
void |
NormalizeValues.setIncludeInputFields(boolean includeInputFields)
Set the indicator of whether or not to include the input fields
in the output data.
|
void |
DistinctValues.setInputField(String inputField)
Sets the input field for which we calculate distinct values
|
void |
NormalizeValues.setMethod(StatsFunctions.NormalizeMethod method)
Set the normalization method to use.
|
void |
Rank.setMode(Rank.RankMode mode)
Set the ranking mode.
|
void |
Rank.setOutputField(String outputField)
Set the name of the output field that will contain the ranking
order for each record.
|
void |
Rank.setPartitionBy(List<String> partitionKeys)
Set the fields used for partitioning the input data.
|
void |
Rank.setPartitionBy(String... partitionKeys)
Set the fields used for partitioning the input data.
|
void |
SummaryStatistics.setQuantilesToCalculate(List<BigDecimal> quantilesToCalculate)
Sets the
quantiles to calculate for each numeric field. |
void |
SummaryStatistics.setRangeCount(int rangeCount)
Sets the number of
intervalCounts to
calculate for each numeric field. |
void |
Rank.setRankBy(List<SortKey> rankBy)
Set the list of fields to use for ranking.
|
void |
Rank.setRankBy(SortKey... rankBy)
Set the list of fields to use for ranking.
|
void |
Rank.setRankBy(String... rankBy)
Set the list of fields to use for ranking.
|
void |
NormalizeValues.setScoreFields(List<String> scoreFields)
Set the names of the input fields to normalize.
|
void |
NormalizeValues.setScoreFields(String... scoreFields)
Set the names of the input fields to normalize.
|
void |
SummaryStatistics.setShowTopHowMany(int showTopHowMany)
Sets a cap on the number of
valueCounts to calculate. |
void |
DistinctValues.setSortByCount(boolean sortByCount)
Sets whether to sort by value count.
|
void |
DataQualityAnalyzer.setTests(List<DataQualityAnalyzer.QualityTest> tests)
Sets the set of tests to apply to the input dataset
|
Modifier and Type | Method and Description |
---|---|
void |
SVMLearner.setEpsilon(double epsilon)
Sets the tolerance for termination criteria.
|
void |
SVMLearner.setIncludedColumns(List<String> includedColumns)
Sets the list of columns to include.
|
void |
SVMLearner.setKernelType(KernelType kernelType)
Sets the kernel and associated parameters to use.
|
static void |
SVMLearner.setSilent(boolean quiet)
Our default SVM library will send regular status reports to System.out.
|
void |
SVMLearner.setSvmCacheSizeMB(double svmCacheSizeMB)
Sets the cache size.
|
void |
SVMLearner.setType(SVMType type)
Sets the type of SVM model to build.
|
Modifier and Type | Method and Description |
---|---|
void |
ConvertTextCase.setCaseFormat(ConvertTextCase.Case caseFormat)
Set the case format for the conversions.
|
void |
DictionaryFilter.setDictionaryField(String dictionaryField)
Set the dictionary field in the dictionary input.
|
void |
ExpandTextFrequency.setFreqOutputField(String freqOutputField)
Set the output field to expand the frequency list into.
|
void |
TextTokenizer.setInputField(String textField)
Set the string field to tokenize.
|
void |
TextStemmer.setInputField(String textField)
Set the field to stem.
|
void |
TextFrequencyFilter.setInputField(String inputField)
Set the frequency map field to filter.
|
void |
GenerateBagOfWords.setInputField(String textField)
Set the field for which to generate the bag of words.
|
void |
FilterText.setInputField(String textField)
Set the field to filter.
|
void |
ExpandTextTokens.setInputField(String textField)
Set the tokenized text field to expand.
|
void |
ExpandTextFrequency.setInputField(String inputField)
Set the frequency map field to expand.
|
void |
DictionaryFilter.setInputField(String textField)
Set the field to filter.
|
void |
CountTokens.setInputField(String textField)
Set the field with tokens to count.
|
void |
ConvertTextCase.setInputField(String inputField)
Set the field to convert to lower or upper case.
|
void |
CalculateWordFrequency.setInputField(String textField)
Set the field to calculate the word frequencies for.
|
void |
CalculateNGramFrequency.setInputField(String textField)
Set the field to calculate the n-gram frequencies for.
|
void |
TextFrequencyFilter.setMaxThreshold(int maxThreshold)
Set the maximum threshold for absolute frequencies when filtering.
|
void |
TextFrequencyFilter.setMinThreshold(int minThreshold)
Set the minimum threshold for absolute frequencies when filtering.
|
void |
CalculateNGramFrequency.setNgramFreqOutputField(String ngramFreqOutputField)
Set the field that will contain the n-gram frequency map.
|
void |
TextTokenizer.setOutputField(String tokenField)
Set the tokenized output field.
|
void |
TextStemmer.setOutputField(String tokenField)
Set the stemmed output field.
|
void |
TextFrequencyFilter.setOutputField(String outputField)
Set the output field that will contain the filtered frequency map.
|
void |
GenerateBagOfWords.setOutputField(String outputField)
Set the field that will contain the bag of words.
|
void |
FilterText.setOutputField(String tokenField)
Set the filtered output field
|
void |
ExpandTextTokens.setOutputField(String tokenField)
Set the string output field.
|
void |
DictionaryFilter.setOutputField(String tokenField)
Set the name of the filtered output field.
|
void |
CountTokens.setOutputField(String countField)
Set the output field for the counts.
|
void |
ConvertTextCase.setOutputField(String outputField)
Set the converted output field.
|
void |
ExpandTextFrequency.setRelative(boolean relative)
Set whether absolute or relative frequencies will be expanded.
|
void |
FilterText.setTextFilters(TextFilter... textFilters)
Set the filters that will be used.
|
void |
ExpandTextFrequency.setTextOutputField(String textOutputField)
Set the output field to expand the text list into.
|
void |
ExpandTextTokens.setTokenType(TextElementType tokenType)
Set the type of text token to expand.
|
void |
CountTokens.setTokenType(TextElementType tokenType)
Set the type of token to count.
|
void |
TextFrequencyFilter.setTotalNumber(int totalNumber)
Set the total number of top frequencies to keep.
|
void |
CalculateWordFrequency.setWordFreqOutputField(String wordFreqOutputField)
Set the field that will contain the word frequency map.
|
void |
TextTokenizer.setWordPatterns(List<String> wordPatterns)
Set the list of custom word patterns that will be recognized.
|
Modifier and Type | Method and Description |
---|---|
void |
DrawDiagnosticsChart.setChartNames(List<String> chartNames)
Sets the predictor names for each input port
to be displayed as the chart legend (null entries
for disconnected input ports).
|
void |
DrawDiagnosticsChart.setChartType(ChartType chartType)
Sets the desired chart type (ROC, Gains, Lift).
|
void |
DrawDiagnosticsChart.setConfidenceFieldNames(List<String> confidenceFieldNames)
Sets the confidence field names for each input port
(null entries for disconnected ports).
|
void |
DrawDiagnosticsChart.setOutputPath(String outputPath)
Sets the path of the .png output file (null
means no output file will be generated).
|
void |
DrawDiagnosticsChart.setResultSize(int resultSize)
Sets the number of results.
|
void |
DrawDiagnosticsChart.setTargetFieldNames(List<String> targetFieldNames)
Sets the actual target field names for all input ports (null entries
for disconnected ports).
|
void |
DrawDiagnosticsChart.setTargetValue(String targetValue)
Sets the target value ("true class")
|
Modifier and Type | Method and Description |
---|---|
void |
KeyValueOperator.setCellFieldMap(Map<String,Map<String,Map<String,String>>> cellFieldMap)
Set the HBase cell to field mapping.
|
void |
DeleteHBase.setCellMarkerMap(Map<String,Map<String,DeleteHBase.DeleteMarker>> cellMarkerMap) |
void |
KeyOperator.setConfiguration(HadoopConfiguration configuration)
Set the configuration.
|
void |
ReadHBase.setEndTime(Date endTime)
Set time range filter end time
|
void |
KeyOperator.setFamilies(Set<String> families)
Set families.
|
void |
KeyValueOperator.setFamilyFieldMap(Map<String,Map<String,String>> familyFieldMap)
Set the column family to field mapping.
|
void |
DeleteHBase.setFamilyMarkerMap(Map<String,DeleteHBase.DeleteMarker> familyMarkerMap) |
void |
KeyOperator.setFilesystem(String filesystem)
Set default filesystem.
|
void |
KeyOperator.setHiveMetastore(String metastore)
Set Hive metastore.
|
void |
ReadHBase.setOmitHBaseScan(boolean omitHBaseScan)
Set omit HBase Scan state.
|
void |
ReadHBase.setOmitHFileReader(boolean omitHFileReader)
Set omit HFile Reader state.
|
void |
WriteHBase.setOutputPath(String outputPath)
Set the output path.
|
void |
DeleteHBase.setOutputPath(String outputPath)
Set the output path.
|
void |
KeyOperator.setQualifierFieldMap(LinkedHashMap<String,String> qualifierFieldMap) |
void |
KeyOperator.setRootDirectory(String directory)
Set HBase root directory.
|
void |
KeyOperator.setRowFieldMap(LinkedHashMap<String,String> rowFieldMap) |
void |
ReadHBase.setStartTime(Date startTime)
Set time range filter start time
|
void |
KeyOperator.setTableName(String tableName)
Set HBase table name.
|
void |
KeyOperator.setTimeFieldName(String timeFieldName)
Set version timestamp field name.
|
void |
ReadHBase.setVersionCount(long versionCount)
Set cell version count
|
void |
KeyOperator.setZookeeperParentZNode(String znode)
Set Zookeeper parent znode.
|
void |
KeyOperator.setZookeeperPort(String port)
Set Zookeeper client port.
|
void |
KeyOperator.setZookeeperQuorum(String quorum)
Set Zookeeper quorum.
|
Modifier and Type | Method and Description |
---|---|
void |
DiscoverLinks.setPhases(List<Phase> phases) |
void |
DiscoverDuplicates.setPhases(List<Phase> phases) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterLinks.setDataIdField(String name)
Sets the name of the field uniquely identifying records on the both sides
of the pairs.
|
void |
ClusterDuplicates.setDataIdField(String name)
Sets the name of the field uniquely identifying records in the original source.
|
void |
ClusterLinks.setLeftDataIdField(String name)
Sets the name of the field uniquely identifying records on the left hand side
of the pairs.
|
void |
ClusterLinks.setLeftFieldPattern(String pattern)
Sets the naming pattern used for fields from the left hand side record.
|
void |
ClusterLinks.setRightDataIdField(String name)
Sets the name of the field uniquely identifying records on the right hand side
of the pairs.
|
void |
ClusterLinks.setRightFieldPattern(String pattern)
Sets the naming pattern used for fields from the right hand side record.
|
Modifier and Type | Method and Description |
---|---|
void |
AssertMetadata.setDataDistribution(DataDistribution dataDistribution)
Set the DataDistribution to assert.
|
void |
AssertMetadata.setDataOrdering(DataOrdering dataOrdering)
Set the DataOrdering metadata to assert.
|
void |
AssertEqual.setErrorTolerance(FloatingPointTolerance errorTolerance)
Set the error tolerance for floating point values.
|
void |
AssertEqualTypes.setExpectedType(RecordTokenType expectedType)
Set the expected type of the actual value input port.
|
void |
AssertSorted.setLogFrequency(int logFrequency)
Sets the frequency with with to log.
|
void |
AssertRowCount.setLogFrequency(int logFrequency)
Sets the frequency with which to log row count
|
void |
AssertEqual.setLogFrequency(int logFrequency)
Set the logging frequency property.
|
void |
AssertSorted.setOrdering(SortKey... ordering)
Set the expected ordering of the input keys.
|
void |
AssertSorted.setOrdering(String... ordering)
Set the expected ordering of the input keys.
|
void |
AssertPredicate.setPredicate(ScalarValuedFunction predicate)
Set the predicate function to assert.
|
void |
AssertPredicate.setPredicate(String predicateExpression)
Sets the predicate(s) to use for assertion based on an expression similar to a where clause of a SQL query.
|
void |
AssertRowCount.setRowCount(long rowCount)
Sets the expected number of rows
|
Modifier and Type | Method and Description |
---|---|
void |
Group.setAggregations(Aggregation[] aggregations)
Sets the aggregations to apply to the data.
|
void |
Group.setAggregations(String aggregationExpression)
Sets the aggregations to apply to the data.
|
void |
Group.setFewGroupsHint(boolean fewGroupsHint)
Sets a hint as to whether the number of groups is expected to be small.
|
void |
RemoveDuplicates.setGroupKeys(String[] groupKeys)
Sets the keys by which to de-duplicate.
|
void |
Group.setInitialGroupCapacity(int initialGroupCapacity)
Sets a hint as to the number of groups that are expected to be processed.
|
void |
Group.setKeyFieldPrefix(String keyFieldPrefix)
Sets the prefix to add to key fields.
|
void |
Group.setKeys(String[] keys)
Sets the names of the key fields.
|
void |
Group.setMaxGroupCapacity(int maxGroupCapacity)
Sets the max number of groups to fit into internal memory buffers.
|
void |
RemoveDuplicates.setSortKeys(SortKey[] sortKeys)
Sets the additional keys by which to sort the data to determine
which row to output in the event of a duplicate.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractReader.setExtraFieldAction(ParseErrorAction action)
Sets how to handle fields found when parsing the record,
but not declared in the schema.
|
void |
AbstractReader.setFieldErrorAction(ParseErrorAction action)
Sets how to handle fields which cannot be parsed.
|
void |
AbstractReader.setFieldLengthThreshold(int limit)
Configures the maximum length allowed for a field
value before it is considered an error.
|
void |
WriteSink.setFormat(DataFormat format)
Sets the data format for the configured target.
|
void |
ReadSource.setFormat(DataFormat format)
Sets the data format for the configured source.
|
void |
WriteSink.setFormatOptions(FormattingOptions options)
Sets the formatting options used by the writer.
|
void |
AbstractWriter.setFormatOptions(FormattingOptions options)
Sets the formatting options used by the reader.
|
void |
AbstractWriter.setIgnoreSortOrder(boolean ignoreSortOrder)
If set to true, the writer will write in any order.
|
void |
ReadSource.setIncludeSourceInfo(boolean enabled)
Controls whether parsed records will be tagged with additional
fields indicating how to locate them in their original source.
|
void |
AbstractReader.setIncludeSourceInfo(boolean enabled)
Controls whether parsed records will be tagged with additional
fields indicating how to locate them in their original source.
|
void |
AbstractReader.setMissingFieldAction(ParseErrorAction action)
Sets how to handle fields declared in the schema, but
not found when parsing the record.
|
void |
WriteSink.setMode(WriteMode mode)
Sets how the writer should handle an existing
target.
|
void |
AbstractWriter.setMode(WriteMode mode)
Sets how the writer should handle an existing
target.
|
void |
AbstractReader.setParseErrorAction(ParseErrorAction action)
Sets how to handle all parsing errors.
|
void |
ReadSource.setParseOptions(ParsingOptions options)
Sets the parsing options used by the reader.
|
void |
AbstractReader.setParseOptions(ParsingOptions options)
Sets the parsing options used by the reader.
|
void |
ReadSource.setPessimisticSplitting(boolean enabled)
Configures whether pessimistic file splitting
must be used.
|
void |
AbstractReader.setPessimisticSplitting(boolean enabled)
Configures whether pessimistic file splitting
must be used.
|
void |
AbstractReader.setReadBuffer(int size)
Sets the size of the I/O buffer, in bytes,
to use for reads.
|
void |
ReadSource.setReadOnClient(boolean enabled)
Sets whether reads are performed by the client or
in the cluster.
|
void |
AbstractReader.setReadOnClient(boolean enabled)
Sets whether reads are performed by the client or
in the cluster.
|
void |
AbstractReader.setRecordWarningThreshold(int limit)
Configures the maximum number of records which can have
parse warnings before failing.
|
void |
AbstractWriter.setSaveMetadata(boolean saveMetadata)
If set to true, the writer will attempt to save the metadata with the data
if the implementation supports it.
|
void |
AbstractReader.setSelectedFields(List<String> fields)
Sets the list of record fields to read.
|
void |
AbstractReader.setSelectedFields(String... fields)
Sets the list of record fields to read.
|
void |
ReadSource.setSource(ByteSource source)
Sets the data source for the reader.
|
void |
AbstractReader.setSource(ByteSource source)
Sets the data source to the specified source.
|
void |
AbstractReader.setSource(Path path)
Sets the data source to the specified path.
|
void |
AbstractReader.setSource(String pattern)
Sets the data source to all paths matching the
specified pattern.
|
void |
ReadSource.setSplitOptions(SplitOptions options)
Sets the split options used by the reader.
|
void |
AbstractReader.setSplitOptions(SplitOptions options)
Sets the configuration used in determining how
to break the source into splits.
|
void |
WriteSink.setTarget(ByteSink target)
Sets the target sink for the reader.
|
void |
AbstractWriter.setTarget(ByteSink sink)
Sets the data sink for the writer.
|
void |
AbstractWriter.setTarget(Path path)
Sets the data sink for the writer.
|
void |
AbstractWriter.setTarget(String path)
Sets the data sink for the writer.
|
void |
AbstractReader.setUseMetadata(boolean useMetadata)
Sets whether discovered metadata should be
used to override the graph settings.
|
void |
AbstractWriter.setWriteBuffer(int size)
Sets the size of the I/O buffer, in bytes,
to use for writes.
|
void |
AbstractWriter.setWriteOnClient(boolean enabled)
Set whether the writer should write a file on the client.
|
void |
WriteSink.setWriteSingleSink(boolean enabled)
Set whether the writer should produce a single output
file or multiple ones.
|
void |
AbstractWriter.setWriteSingleSink(boolean enabled)
Set whether the writer should produce a single output
file or multiple ones.
|
Modifier and Type | Method and Description |
---|---|
void |
WriteAvro.setCompression(Compression codec)
Sets the compression method to use on data blocks.
|
void |
WriteAvro.setSchema(org.apache.avro.Schema schema)
Sets the schema to use to encode the output.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractWriteToJDBC.setCommitInterval(int commitInterval)
Sets the commit interval used by the JDBC driver.
|
void |
JDBCOperator.setConnectionFactory(ConnectionFactory connectionFactory)
Sets the connection factory to be used for creating connections.
|
void |
ReadFromJDBC.setDataQuery(String dataQuery)
Sets the
SELECT statement to use to query data from the source database. |
void |
ReadFromJDBC.setDiscoverOutputAtRuntime(boolean discoverOutputAtRuntime)
Set whether the output type should be automatically discovered at runtime.
|
void |
JDBCOperator.setDriverName(String driverName)
Sets the class name of the JDBC driver to use, for example:
"sun.jdbc.odbc.JdbcOdbcDriver" . |
void |
JDBCOperator.setErrorAction(ErrorAction errorAction)
Sets the action to take if a SQL error occurs while reading data from the database.
|
void |
ReadFromJDBC.setFetchSize(int fetchSize)
Sets the number of rows in each fetch from the database.
|
void |
AbstractWriteToJDBC.setFinalizeTableSQL(String finalizeTableSQL)
Sets the SQL statement to execute after processing all the records.
|
void |
JDBCOperator.setHostNames(List<String> hostNames)
Set the list of database host names that can be used to execute queries.
|
void |
AbstractWriteToJDBC.setInitializeTableSQL(String initializeTableSQL)
Sets the SQL statement to execute before processing any records.
|
void |
AbstractWriteToJDBC.setIsolationLevel(int level)
Sets the isolation level to use for the transactions.
|
void |
AbstractWriteToJDBC.setKeyNames(String[] keyNames)
Sets the field names (JDBC column names) to use as keys.
|
void |
ReadFromJDBC.setOutputType(RecordTokenType outputType)
Set the record type of the output port of this operator.
|
void |
ReadFromJDBC.setParameterQuery(String parameterQuery)
Set the database query used to gather parameters from the source database.
|
void |
ReadFromJDBC.setParameters(Object[][] parameters)
Set the parameter values to use when the data query specified with
ReadFromJDBC.setDataQuery(String)
is parameterized. |
void |
JDBCOperator.setPassword(String password)
Sets the password for connecting to the database.
|
void |
AbstractWriteToJDBC.setRenameMapping(Map<String,String> renameMapping)
Sets a rename mapping.
|
void |
ReadFromJDBC.setSelectStatement(String selectStatement)
Deprecated.
Use the
ReadFromJDBC.setDataQuery(String) method instead. |
void |
JDBCOperator.setSqlWarningLimit(int sqlWarningLimit)
Set the maximum number of warnings regarding SQL errors that an operator can emit.
|
void |
JDBCOperator.setTableName(String tableName)
Sets the name of the database table to access.
|
void |
JDBCOperator.setUrl(String url)
Sets the URL for connecting to the database, for example:
jdbc:odbc:SampleTest . |
void |
JDBCOperator.setUser(String user)
Sets the user name for connecting to the database.
|
Modifier and Type | Method and Description |
---|---|
void |
LoadMatrix.setDatabase(String databaseName)
Set the database name.
|
void |
MatrixSink.setEndPort(String endPort)
End of the IP port range to be used for the slice registration server socket.
|
void |
LoadMatrix.setEndPortRange(int endPortRange)
Set the end of the IP port range to use for network connections to and from the
target Matrix database.
|
void |
LoadMatrix.setFinalizeTableSQL(String finalizeTableSQL)
Sets the SQL statement to execute after processing all the records.
|
void |
MatrixOperatorBase.setHost(String hostName)
Set the host name property.
|
void |
LoadMatrix.setInitializeTableSQL(String initializeTableSQL)
Sets the SQL statement to execute before processing any records.
|
void |
LoadMatrix.setLogFrequency(int logFrequency)
Set the frequency in units of rows of data that progress is reported.
|
void |
MatrixSink.setMatrixPort(String matrixPort)
Sets the server port on the Matrix instance listening for messages from this operator.
|
void |
MatrixOperatorBase.setMaxConnections(int maxConnections)
Set the max connections property.
|
void |
LoadMatrix.setPassword(String password)
Set the user's password.
|
void |
LoadMatrix.setPort(int port)
Set the Matrix leader node port number.
|
void |
LoadMatrix.setRenameMapping(Map<String,String> renameMapping)
Set the source to target field name mapping.
|
void |
LoadMatrix.setRetryCount(int retryCount)
Set the number of times communication requests to the MPP database system are retried before
being considered an error.
|
void |
MatrixSink.setSliceInfo(String sliceInfo)
Takes a comma separated list of Matrix slice specs in the form
|
void |
MatrixSink.setStartPort(String startPort)
Sets the start of the IP port range to be used for the slice registration server socket.
|
void |
LoadMatrix.setStartPortRange(int startPortRange)
Set the start of the IP port range to use for network connections to and from the
Matrix database.
|
void |
LoadMatrix.setTable(String tableName)
Set the name of the table to load.
|
void |
MatrixSink.setTableSchema(String tableSchema)
Takes a comma separated list of column specs in the form
|
void |
LoadMatrix.setTimeoutInterval(int timeoutInterval)
Set the timeout interval (in seconds) for communication requests the target MPP database system.
|
void |
LoadMatrix.setTraceLevel(int traceLevel)
Set the trace level used by the query UDF function invoked to load the data in the
target database.
|
void |
LoadMatrix.setUser(String userName)
Set the user name.
|
Modifier and Type | Method and Description |
---|---|
void |
WriteStagingDataset.setBlockSize(int blockSize)
Sets the block size, in rows, used for encoding data.
|
void |
WriteStagingDataset.setFormat(DatasetStorageFormat format)
Sets the data set format used to store data.
|
Modifier and Type | Method and Description |
---|---|
void |
ReadDelimitedText.setAnalysisDepth(int count)
Sets the number of characters to read for performing
schema discovery and structural analysis.
|
void |
ReadDelimitedText.setAutoDiscoverNewline(boolean enabled)
Configures whether the reader attempts to discover the
newline style (UNIX or DOS) used in the source.
|
void |
AbstractTextWriter.setCharset(Charset charset)
Sets the character set used by the data sink.
|
void |
AbstractTextReader.setCharset(Charset charset)
Sets the character set used by the data source.
|
void |
AbstractTextWriter.setCharsetName(String charsetName)
Sets the character set used by the data sink.
|
void |
AbstractTextReader.setCharsetName(String charsetName)
Sets the character set used by the data source.
|
void |
WriteARFF.setComments(List<String> comments)
Set the comments lines to write to the ARFF meta-data section of the file.
|
void |
AbstractTextReader.setDecodeBuffer(int size)
Sets the size of the buffer, in bytes, used to decode
character data.
|
void |
WriteDelimitedText.setDelimiters(FieldDelimiterSettings settings)
Sets the field delimiter settings for the writer.
|
void |
ReadDelimitedText.setDelimiters(FieldDelimiterSettings settings)
Sets the field delimiter settings for the reader.
|
void |
ReadDelimitedText.setDiscoveryNullIndicator(String value)
Sets the text value used to represent null values
by default in discovered schemas.
|
void |
ReadDelimitedText.setDiscoveryStringHandling(TextTypes.StringConversion behavior)
Sets the default behavior for processing string-valued types
in discovered schemas.
|
void |
AbstractTextWriter.setEncodeBuffer(int size)
Sets the size of the buffer, in bytes, used to encode
character data.
|
void |
AbstractTextWriter.setEncoding(CharsetEncoding settings)
Set the properties that control character
set encoding.
|
void |
AbstractTextReader.setEncoding(CharsetEncoding settings)
Set the properties that control character
set encoding.
|
void |
AbstractTextWriter.setErrorAction(CodingErrorAction errorAction)
Set the encoding error action.
|
void |
AbstractTextReader.setErrorAction(CodingErrorAction errorAction)
Set the encoding error action.
|
void |
WriteARFF.setFieldDelimiter(char delimiter)
Set the field delimiter to use when writing the file contents.
|
void |
ReadARFF.setFieldDelimiter(char fieldDelimiter)
Set the field delimiter to use when reading the file contents.
|
void |
WriteDelimitedText.setFieldDelimiter(String delimiter)
Sets the delimiter used to denote the boundaries of a data field.
|
void |
ReadDelimitedText.setFieldDelimiter(String delimiter)
Sets the delimiter used to denote the boundaries of a data field.
|
void |
WriteDelimitedText.setFieldEndDelimiter(String delimiter)
Sets the delimiter used to denote the end of a data field.
|
void |
ReadDelimitedText.setFieldEndDelimiter(String delimiter)
Sets the delimiter used to denote the end of a data field.
|
void |
WriteDelimitedText.setFieldSeparator(String separator)
Sets the delimiter used to define the boundary between data fields.
|
void |
ReadDelimitedText.setFieldSeparator(String separator)
Sets the delimiter used to define the boundary between data fields.
|
void |
WriteDelimitedText.setFieldStartDelimiter(String delimiter)
Sets the delimiter used to denote the beginning of a data field.
|
void |
ReadDelimitedText.setFieldStartDelimiter(String delimiter)
Sets the delimiter used to denote the beginning of a data field.
|
void |
WriteARFF.setFormatMode(ARFFMode mode)
Set the mode with which to write the file.
|
void |
WriteDelimitedText.setHeader(boolean header)
Configures whether to write a header row in the target.
|
void |
ReadDelimitedText.setHeader(boolean header)
Configures whether to expect a header row in the source.
|
void |
ReadDelimitedText.setHeaderSkipCount(int count)
Sets the number of lines to skip at the beginning of the file
before reading.
|
void |
WriteDelimitedText.setLineComment(String lineComment)
Sets the character sequence indicating a line comment.
|
void |
ReadFixedText.setLineComment(String lineComment)
Set the text that represents that a line of input data is a comment.
|
void |
ReadDelimitedText.setLineComment(String lineComment)
Sets the character sequence indicating a line comment.
|
void |
ReadDelimitedText.setMaxRowLength(int maxRowLength)
Deprecated.
Use
ReadDelimitedText.setValidateRecordSeparator(boolean) in
conjunction with ReadDelimitedText.setAnalysisDepth(int) instead. |
void |
WriteDelimitedText.setNullIndicator(String value)
Sets the text value used to represent null values
by default in generated schemas.
|
void |
WriteFixedText.setRecordSeparator(String separator)
Set the record separator.
|
void |
WriteDelimitedText.setRecordSeparator(String separator)
Sets the value to use as a record separator.
|
void |
WriteARFF.setRecordSeparator(String separator)
Set the record separator.
|
void |
ReadFixedText.setRecordSeparator(String separator)
Set the string that represents the separator between records in the
input file.
|
void |
ReadDelimitedText.setRecordSeparator(String separator)
Sets the value to use as a record separator.
|
void |
WriteARFF.setRelationName(String relationName)
Set the relation name attribute.
|
void |
AbstractTextWriter.setReplacement(String replacement)
Sets the error policy to be replacement with the specified string.
|
void |
AbstractTextReader.setReplacement(String replacement)
Sets the error policy to be replacement with the specified string.
|
void |
WriteFixedText.setSchema(FixedWidthTextRecord schema)
Set the schema to use for formatting output records.
|
void |
ReadFixedText.setSchema(FixedWidthTextRecord schema)
Set the schema of the input data to read.
|
void |
WriteDelimitedText.setSchema(RecordTextSchema<?> schema)
Sets the record schema for the delimited text source.
|
void |
ReadDelimitedText.setSchema(RecordTextSchema<?> schema)
Sets the record schema expected in the delimited text source.
|
void |
ParseTextFields.setSchema(RecordTextSchema<?> schema)
Sets the record schema to use for parsing.
|
void |
WriteARFF.setSchema(TextRecord schema)
Set the schema to use for the provided data.
|
void |
WriteDelimitedText.setSchemaDiscovery(TextRecordDiscoverer discoverer)
Sets the schema discoverer to use for the delimited text.
|
void |
ReadDelimitedText.setSchemaDiscovery(TextRecordDiscoverer discoverer)
Sets the schema discoverer to use against the delimited text source.
|
void |
ReadDelimitedText.setValidateRecordSeparator(boolean enabled)
Sets whether the configured record separator should be validated.
|
Modifier and Type | Method and Description |
---|---|
void |
LoadVectorwise.setBufferSize(int bufferSize)
Sets the size of the data buffer (in rows) used to cache data before sending to the Vectorwise engine.
|
void |
LoadVectorwise.setCharset(String charsetName)
Set the character set used for data staging and loading for vwload load method.
|
void |
LoadVectorOnHadoop.setCharset(String charsetName)
Set the character set used for data staging and loading for vwload load method.
|
void |
LoadVectorOnHadoop.setDatabase(String database)
Set the database name.
|
void |
LoadVectorwise.setDatabaseName(String databaseName)
Set the database name.
|
void |
LoadVectorwise.setFinalizeTableSQL(String finalizeTableSQL)
Sets the SQL statement to execute after processing all the records.
|
void |
LoadVectorOnHadoop.setFinalizeTableSQL(String finalizeTableSQL)
Sets the SQL statement to execute after processing all the records.
|
void |
LoadVectorwise.setHost(String hostName)
Set the host name property.
|
void |
LoadVectorOnHadoop.setHost(String hostName)
Set the host name property.
|
void |
LoadVectorwise.setInitializeTableSQL(String initializeTableSQL)
Sets the SQL statement to execute before processing any records.
|
void |
LoadVectorOnHadoop.setInitializeTableSQL(String initializeTableSQL)
Sets the SQL statement to execute before processing any records.
|
void |
LoadVectorwise.setInstance(String instance)
Set the Vectorwise instance name.
|
void |
LoadVectorOnHadoop.setInstance(String instance)
Set the Vectorwise instance name.
|
void |
LoadVectorwise.setMaxErrors(int maxErrors)
Set the maximum number of errors allowed before rolling back the data load operation.
|
void |
LoadVectorOnHadoop.setMaxErrors(int maxErrors)
Set the maximum number of errors allowed before rolling back the data load operation.
|
void |
LoadVectorwise.setMethod(LoadMethod method)
Set the load method to use.
|
void |
LoadVectorwise.setPassword(String password)
Set the user's password.
|
void |
LoadVectorOnHadoop.setPassword(String password)
Set the user's password.
|
void |
LoadVectorwise.setRejectsPath(String rejectsPath)
Set the rejects path.
|
void |
LoadVectorwise.setRenameMapping(Map<String,String> renameMapping)
Set a rename mapping.
|
void |
LoadVectorOnHadoop.setRenameMapping(Map<String,String> renameMapping)
Set a rename mapping.
|
void |
LoadVectorwise.setRollback(boolean enabled)
Enable or disable rollback processing.
|
void |
LoadVectorOnHadoop.setRollback(boolean enabled)
Enable or disable rollback processing.
|
void |
LoadVectorwise.setSchema(String schema)
Set the schema for the target table.
|
void |
LoadVectorOnHadoop.setSshPassword(String passwd)
Set the password for SSH user id
|
void |
LoadVectorOnHadoop.setSshUser(String user)
Set the OS User Id used for authenticating SSH connection to Master Node of Vector on Hadoop
|
void |
LoadVectorwise.setStringTruncationError(boolean enableStringTruncationError)
Set whether errors on string truncation is enabled or disabled.
|
void |
LoadVectorOnHadoop.setTable(String table)
Set the name of the table to load.
|
void |
LoadVectorwise.setTableName(String tableName)
Set the name of the table to load.
|
void |
LoadVectorOnHadoop.setTmpDirectory(String tmpDirectory)
Set the temporary directory that is to be used for storing the intermediate loader files.
|
void |
LoadVectorwise.setUser(String userName)
Set the user name.
|
void |
LoadVectorOnHadoop.setUser(String userName)
Set the user name.
|
Modifier and Type | Method and Description |
---|---|
void |
LoadVectorOnHadoopDirect.setDatabase(String database)
Set the database name.
|
void |
LoadVectorOnHadoopDirect.setHost(String host)
Set the host name of the server where the leader node is running.
|
void |
LoadVectorOnHadoopDirect.setInsertMode(String insertMode)
Set insert mode statement applies for Insert and Merge operation.
|
void |
LoadVectorOnHadoopDirect.setInstance(String instance)
Set the Vector instance name.
|
void |
LoadVectorOnHadoopDirect.setMaxErrors(int maxErrors)
Set the maximum number of errors allowed per stream before rolling back the data load operation.
|
void |
LoadVectorOnHadoopDirect.setPassword(String password)
Set user's password.
|
void |
LoadVectorOnHadoopDirect.setRenameMapping(Map<String,String> renameMapping)
Set a rename mapping.
|
void |
LoadVectorOnHadoopDirect.setRollback(boolean enabled)
Enable or disable rollback processing.
|
void |
LoadVectorOnHadoopDirect.setTable(String table)
Set the name of the table to load.
|
void |
LoadVectorOnHadoopDirect.setUser(String user)
Set the user account name.
|
void |
LoadVectorOnHadoopDirect.setVectorSize(int vectorSize)
Set the size of the buffer (in rows)
used to cache data before sending to
the Vector engine.
|
Modifier and Type | Method and Description |
---|---|
void |
CrossJoin.setBufferRows(int rows)
Sets the size (in rows) of the memory buffer used to generate
output record.
|
void |
UnionAll.setIncludeExtraFields(boolean includeExtraFields)
Set to true if the generated schema should include unmapped field from either side.
|
void |
AbstractRelationalJoin.setJoinCondition(ScalarValuedFunction joinCondition)
Sets the join condition.
|
void |
AbstractRelationalJoin.setJoinCondition(String joinCondition)
Sets the join condition.
|
void |
AbstractRelationalJoin.setJoinKeys(JoinKey[] joinKeys)
Sets the join keys to use when performing the join.
|
void |
AbstractRelationalJoin.setJoinKeys(String[] keyFieldNames)
Sets the join keys to use when performing the join.
|
void |
Join.setJoinMode(JoinMode joinMode)
Sets the join mode to use when performing a join.
|
void |
SemiJoin.setJoinMode(SemiJoinMode joinMode)
Deprecated.
Sets the join mode to use when performing a join.
|
void |
Join.setMergeLeftAndRightKeys(boolean mergeLeftAndRightKeys)
Sets whether to merge the left and right key fields into a single field for output.
|
void |
UnionAll.setOutputMapping(UnionAll.UnionMode outputMapping)
Set how the output type should be determined.
|
void |
UnionAll.setSchema(RecordTextSchema<?> schema)
Sets the optional target output schema.
|
void |
AbstractRelationalJoin.setUseHashJoinHint(boolean useHashJoinHint)
Sets whether to perform the join as a hash join.
|
Modifier and Type | Method and Description |
---|---|
void |
GetModel.setMergeHandler(ModelMergeHandler<T> mergeHandler)
Sets the merge handler to be used to merge model fragments into a single model.
|
void |
PutModel.setModel(T model)
Sets the model to be injected
|
void |
PutModel.setModelReference(Reference<T> reference)
For advanced use only; sets the reference location where the model is to be obtained.
|
void |
GetModel.setModelReference(Reference<T> reference)
For advanced use only; specifies a reference location where the model is to be set.
|
Modifier and Type | Method and Description |
---|---|
void |
PartitionHint.setDataOrdering(DataOrdering dataOrdering)
Sets the data ordering of the output.
|
void |
GatherHint.setDataOrdering(DataOrdering dataOrdering)
Sets the data ordering of the output.
|
void |
PartitionHint.setForceStaging(boolean forceStaging)
Sets whether data must be staged to disk.
|
void |
GatherHint.setForceStaging(boolean forceStaging)
Sets whether data must be staged to disk.
|
void |
PartitionHint.setPartitioning(DataDistribution partitioning)
Sets the data distribution of the output.
|
void |
PartitionHint.setPreserveSortOrder(boolean preserveSortOrder)
Sets whether data order will be preserved ( provided that the data order is known ).
|
Modifier and Type | Method and Description |
---|---|
void |
RowsToColumns.setAggregations(Aggregation... aggregations)
Set the aggregation(s) to apply to each pivot grouping.
|
void |
RowsToColumns.setAggregations(List<Aggregation> aggregations)
Set the aggregation(s) to apply to each pivot grouping.
|
void |
RowsToColumns.setAggregations(String aggregationExpression)
Set the aggregation(s) to apply to each pivot grouping using an aggregation expression.
|
void |
DeriveFields.setDerivedFields(FieldDerivation... derivations)
Set the list of field derivations to apply.
|
void |
DeriveFields.setDerivedFields(List<FieldDerivation> derivations)
Set the list of field derivations to apply.
|
void |
DeriveFields.setDerivedFields(String derivationExpression)
Set the list of field derivations to apply, using
a field derivation expression.
|
void |
DeriveFields.setDropUnderivedFields(boolean dropUnderived)
Set whether input fields are dropped from the output.
|
void |
FilterFields.setFieldNames(List<String> fields)
Sets the names of fields to which the filtering operation is
applied.
|
void |
FilterFields.setFieldNames(String... fields)
Sets the names of fields to which the filtering operation is
applied.
|
void |
RemapFields.setFieldRemapping(FieldRemapping remapping)
Defines how input fields are to be mapped to output
fields.
|
void |
RowsToColumns.setGroupKeys(List<String> groupKeys)
Set the list of fields used to segment the input data into groups for pivoting.
|
void |
RowsToColumns.setGroupKeys(String... groupKeys)
Set the list of fields used to segment the input data into groups for pivoting.
|
void |
RowsToColumns.setPivotColumnPattern(String pattern)
Sets the naming pattern used for new pivot columns.
|
void |
RowsToColumns.setPivotKey(String pivotKey)
Set the name of the field used as the pivot key.
|
void |
RowsToColumns.setPivotKeyValues(List<String> pivotValues)
Set the list of distinct pivot key values.
|
void |
RowsToColumns.setPivotKeyValues(String... pivotValues)
Set the list of distinct pivot key values.
|
Modifier and Type | Method and Description |
---|---|
void |
RunScript.setAfterLastRecordScript(String script)
Set the script to use for clean up processing.
|
void |
RunScript.setBeforeFirstRecordScript(String script)
Set the script to use for initialization processing.
|
void |
RunScript.setEngineName(String engineName)
Set the name of the script engine to use.
|
void |
RunScript.setEngineVersion(String engineVersion)
Set the version of the script engine to use.
|
void |
RunScript.setLanguageName(String languageName)
Set the name of the scripting language to use.
|
void |
RunScript.setLanguageVersion(String languageVersion)
Set the version of the script language to use.
|
void |
RunScript.setOnEveryRecordScript(String script)
Set the script to use for processing every input record.
|
void |
RunScript.setOutputType(RecordTokenType outputType)
Set the output type.
|
void |
RunScript.setStderrFileName(String stderrFileName)
Set the pathname of the file that will capture the standard error
output of the script execution environment.
|
void |
RunScript.setStdoutFileName(String stdoutFileName)
Set the pathname of the file that will capture the standard output
of the script execution environment.
|
void |
RunScript.setVariables(Map<String,Object> variables)
Set the collection of variables to be incorporated into the script
environment before executing any of the given script source.
|
Modifier and Type | Method and Description |
---|---|
void |
LimitRows.setCount(long count)
Sets the maximum number of records
which will be output.
|
void |
SampleRandomRows.setMode(SampleMode mode)
Set the sample mode.
|
void |
SampleRandomRows.setPercent(double percent)
Set the percentage of input data wanted.
|
void |
FilterRows.setPredicate(ScalarValuedFunction p)
Sets the predicate for the filter operation.
|
void |
FilterRows.setPredicate(String predicateExpression)
Sets the predicate(s) to use for filtering based on an expression similar to a where clause of a SQL query.
|
void |
SampleRandomRows.setSampleSize(long sampleSize)
Set the wanted sample size in rows.
|
void |
SampleRandomRows.setSeed(Long seed)
Set the random number generator seed value.
|
void |
LimitRows.setSkip(long skip)
Sets the number of input records to skip
before outputting records.
|
Modifier and Type | Method and Description |
---|---|
void |
LogRows.setFormat(String format)
Set the format to use when logging rows.
|
void |
CollectRecords.setInitialBufferSize(int size)
Sets the initial size, in tokens, to use for the list
collecting input data.
|
void |
LogRows.setLogFrequency(int logFrequency)
Set the frequency of rows to log.
|
Modifier and Type | Method and Description |
---|---|
void |
Sort.setIOBuffer(String sizeSpecifier)
Sets the size of the memory buffers used to for I/O operations on run
files during sorting.
|
void |
Sort.setIOBufferSize(long size)
sets the buffer size, in bytes, used for I/O operations on run files.
|
void |
Sort.setMaxMerge(int maxMerge)
Sets the maximum number of run files to merge at one time.
|
void |
Sort.setSortBuffer(String sizeSpecifier)
Sets an approximate cap on the amount of memory used by the sort.
|
void |
Sort.setSortBufferSize(long size)
Sets the size of the memory usage target, in bytes, for a sort.
|
void |
Sort.setSortKeys(List<SortKey> keys)
Sets the list of sort keys by which we are to sort.
|
void |
Sort.setSortKeys(SortKey... keys)
Sets the list of sort keys by which we are to sort.
|
void |
Sort.setSortKeys(String... keys)
Sets the list of sort keys by which we are to sort.
|
Modifier and Type | Method and Description |
---|---|
void |
GenerateConstant.setConstant(RecordToken constant)
Sets the value to generate
|
void |
EmitRecords.setInput(RecordTokenList data)
Sets the list of records which will be produced.
|
void |
GenerateRandom.setNullProbability(double nullProbability)
Sets the probability any given generated token will be null valued.
|
void |
GenerateRandom.setOutputType(RecordTokenType outputType)
Sets the data type of the generated values
|
void |
GenerateArithmeticSequence.setOutputType(RecordTokenType outputType)
Sets the output type.
|
void |
GenerateRepeatingCycle.setRowCount(long rowCount)
Sets the number of values to generate
|
void |
GenerateRandom.setRowCount(long rowCount)
Sets the number of values to generate
|
void |
GenerateConstant.setRowCount(long rowCount)
Sets the number of values to generate
|
void |
GenerateArithmeticSequence.setRowCount(long rowCount)
Sets the number of rows to output.
|
void |
GenerateRandom.setSeed(long seed)
Sets the seed for the random number generator.
|
void |
GenerateArithmeticSequence.setStartValue(BigDecimal startValue)
Sets the value of the first token in the sequence.
|
void |
GenerateArithmeticSequence.setStepSize(BigDecimal stepSize)
Sets the difference between consecutive tokens in the generated sequence.
|
Modifier and Type | Method and Description |
---|---|
Map<Integer,String> |
SplitField.getResultMapping()
Get the mapping of split indices to output field names.
|
void |
SplitField.setSplitField(String splitField)
Set the string field to be split.
|
void |
SplitField.setSplitPattern(String splitPattern)
Set the splitting pattern.
|
Copyright © 2016 Actian Corporation. All rights reserved.