public abstract class UnaryTransformer<IN,OUT,T extends UnaryTransformer<IN,OUT,T>> extends Transformer
Constructor and Description |
---|
UnaryTransformer() |
Modifier and Type | Method and Description |
---|---|
T |
copy(ParamMap extra)
Creates a copy of this instance with the same UID and some extra params.
|
protected abstract scala.Function1<IN,OUT> |
createTransformFunc()
Creates the transform function using the given param map.
|
protected abstract DataType |
outputDataType()
Returns the data type of the output column.
|
T |
setInputCol(java.lang.String value) |
T |
setOutputCol(java.lang.String value) |
Dataset<Row> |
transform(Dataset<?> dataset)
Transforms the input dataset.
|
StructType |
transformSchema(StructType schema)
:: DeveloperApi ::
|
protected void |
validateInputType(DataType inputType)
Validates the input type.
|
transform, transform, transform
transformSchema
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clear, copyValues, defaultCopy, defaultParamMap, explainParam, explainParams, extractParamMap, extractParamMap, get, getDefault, getOrDefault, getParam, hasDefault, hasParam, isDefined, isSet, paramMap, params, set, set, set, setDefault, setDefault, shouldOwn, validateParams
toString, uid
public T setInputCol(java.lang.String value)
public T setOutputCol(java.lang.String value)
protected abstract scala.Function1<IN,OUT> createTransformFunc()
protected abstract DataType outputDataType()
protected void validateInputType(DataType inputType)
inputType
- (undocumented)public StructType transformSchema(StructType schema)
PipelineStage
Derives the output schema from the input schema.
transformSchema
in class PipelineStage
schema
- (undocumented)public Dataset<Row> transform(Dataset<?> dataset)
Transformer
transform
in class Transformer
dataset
- (undocumented)public T copy(ParamMap extra)
Params
copy
in interface Params
copy
in class Transformer
extra
- (undocumented)defaultCopy()