object BuiltInTransforms
The values below are referenced in customer transforms as well as in the documentation. They should not be changed.
- Alphabetic
- By Inheritance
- BuiltInTransforms
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val all: Set[String]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- val compareRows: String
This is a function for comparing two results and reporting their differences.
This is a function for comparing two results and reporting their differences. The function takes two input results, first and second. An option specifying one or more columns to use as a row identifier must also be provided. Given this input, the function will join the first and second input results using the id column and produce a result which for each joined row reports all changes from the first input to the second input. Added/removed rows will be reported as well. The function options are documented in CompareRowsOptions.
ds_compare_rows(input1, input2)
Example: - val describeColumns: String
This function takes a single input.
This function takes a single input. Each column of the input produce an output row containing a selection of properties describing values in the column. The specific reported properties depend on the data type of each column. For all data types, total number of values, distinct values, nulls, frequent and infrequent values and counts will be reported. For numeric types, various statistical measures and number of positive, negative and zeros will be reported as well. For string column the number of special values like empty strings, null-like strings will also be reported. The function options are documented in DescribeColumnsOptions.
ds_describe_columns(input)
Example: - val describeRows: String
This is a timeline-based function for monitoring the development of a result over time.
This is a timeline-based function for monitoring the development of a result over time. The function takes a single input, imported on a timeline and an option specifying columns to use as a row identifier. The function then performs an operation resembling that of the ds_describe_columns function, but partitioned by the row identifier, so a result will be reported - not for each column - but for each combination of column and row identifier. For numeric columns the changes over time will be described using linear regression for each row id as well. The function options are documented in DescribeRowsOptions.
ds_describe_rows(input)
Example: - final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- val placeOnTimeline: String
This is a function for placing a local transform result on an timeline.
This is a function for placing a local transform result on an timeline. The function takes two parents as input. One parent must be the result of a source import using a timeline. The other parent must not contain timeline information. The execution takes the non-timeline parent, adorns it with timeline information (thus creating a new single-point timeline) and performs a unification of the two timelines. The function can be used to create a local timeline which includes results from the current pipeline and will typically be used as an intermediate result in timeline-oriented pipelines.
ds_place_on_timeline(input1, input2)
Example: - val predictRandomForestCategorical: String
This is a function that uses a previously trained machine learning model for categorical prediction.
This is a function that uses a previously trained machine learning model for categorical prediction. The function takes two input results - one serving as a data result and one serving as a machine-learning model. The function applies the model to the data result, producing output containing the original data and model probabilities of all possible values for each row. The value with the highest probability is also included as the model prediction. The function is meant to be used in conjunction with the ds_train_random_forest_categorical function. Whereas the input to the former must contain the prediction column (for training), this should not. The function options are documented in ModelConsumerOptions.
ds_predict_random_forest_categorical(input)
Example: - val predictRandomForestContinuous: String
This function is similar to ds_predict_random_forest_categorical, but requires a model that predicts a continuous data column.
This function is similar to ds_predict_random_forest_categorical, but requires a model that predicts a continuous data column.
ds_predict_random_forest_continuous(input)
Example: - final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val testRandomForestCategorical: String
This function is similar to ds_predict_random_forest_categorical, but requires the prediction column to be present in the input result.
This function is similar to ds_predict_random_forest_categorical, but requires the prediction column to be present in the input result. It includes the same output, but adds a probability score for how likely the prediction column value is under the model.
ds_test_random_forest_categorical(input)
Example: - val testRandomForestContinuous: String
This function is similar to ds_test_random_forest_categorical, but requires a model that predicts a continuous data column.
This function is similar to ds_test_random_forest_categorical, but requires a model that predicts a continuous data column.
ds_test_random_forest_continuous(input)
Example: - def toString(): String
- Definition Classes
- AnyRef → Any
- val trainRandomForestCategorical: String
This is a function that builds a machine learning model for categorical prediction.
This is a function that builds a machine learning model for categorical prediction. The function takes a single input and a reference to a column with categorical data in that input. Using the random forest algorithm a model is then trained to predict the categorical column based on the other columns. Internally the function leverages the random forest implementation of Apache Spark. The output of the function is a dataset with the models predictions on the training data - see ds_predict_random_forest_categorical. The trained model is stored internally, and is accessible to other transforms referencing this transform. The function options are documented in classes ModelOptions and RandomForestOptions.
ds_train_random_forest_categorical(input)
Example: - val trainRandomForestContinuous: String
This function is similar to ds_train_random_forest_categorical, but requires a column with continuous data as the prediction column, and will output a predicted continuous value for each row.
This function is similar to ds_train_random_forest_categorical, but requires a column with continuous data as the prediction column, and will output a predicted continuous value for each row.
ds_train_random_forest_continuous(input)
Example: - final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)