Package org.apache.spark.ml.feature
Class StopWordsRemover
Object
org.apache.spark.ml.PipelineStage
org.apache.spark.ml.Transformer
org.apache.spark.ml.feature.StopWordsRemover
- All Implemented Interfaces:
Serializable,org.apache.spark.internal.Logging,Params,HasInputCol,HasInputCols,HasOutputCol,HasOutputCols,DefaultParamsWritable,Identifiable,MLWritable
public class StopWordsRemover
extends Transformer
implements HasInputCol, HasOutputCol, HasInputCols, HasOutputCols, DefaultParamsWritable
A feature transformer that filters out stop words from input.
Since 3.0.0, StopWordsRemover can filter out multiple columns at once by setting the
inputCols parameter. Note that when both the inputCol and inputCols parameters are set,
an Exception will be thrown.
- See Also:
- Note:
- null values from input array are preserved unless adding null to stopWords explicitly.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging
org.apache.spark.internal.Logging.LogStringContext, org.apache.spark.internal.Logging.SparkShellLoggingFilter -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionWhether to do a case sensitive comparison over the stop words.Creates a copy of this instance with the same UID and some extra params.booleanString[]inputCol()Param for input column name.final StringArrayParamParam for input column names.static StopWordsRemoverstatic String[]loadDefaultStopWords(String language) Loads the default stop words for the given language.locale()Locale of the input for case insensitive matching.static org.apache.spark.internal.Logging.LogStringContextLogStringContext(scala.StringContext sc) static org.slf4j.Loggerstatic voidorg$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1) Param for output column name.final StringArrayParamParam for output column names.static MLReader<T>read()setCaseSensitive(boolean value) setInputCol(String value) setInputCols(String[] value) setOutputCol(String value) setOutputCols(String[] value) setStopWords(String[] value) The words to be filtered out.toString()Transforms the input dataset.transformSchema(StructType schema) Check transform validity and derive the output schema from the input schema.uid()An immutable unique ID for the object and its derivatives.Methods inherited from class org.apache.spark.ml.Transformer
transform, transform, transformMethods inherited from class org.apache.spark.ml.PipelineStage
paramsMethods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.spark.ml.util.DefaultParamsWritable
writeMethods inherited from interface org.apache.spark.ml.param.shared.HasInputCol
getInputColMethods inherited from interface org.apache.spark.ml.param.shared.HasInputCols
getInputColsMethods inherited from interface org.apache.spark.ml.param.shared.HasOutputCol
getOutputColMethods inherited from interface org.apache.spark.ml.param.shared.HasOutputCols
getOutputColsMethods inherited from interface org.apache.spark.internal.Logging
initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logBasedOnLevel, logDebug, logDebug, logDebug, logDebug, logError, logError, logError, logError, logInfo, logInfo, logInfo, logInfo, logName, LogStringContext, logTrace, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, logWarning, org$apache$spark$internal$Logging$$log_, org$apache$spark$internal$Logging$$log__$eq, withLogContextMethods inherited from interface org.apache.spark.ml.util.MLWritable
saveMethods inherited from interface org.apache.spark.ml.param.Params
clear, copyValues, defaultCopy, defaultParamMap, estimateMatadataSize, explainParam, explainParams, extractParamMap, extractParamMap, get, getDefault, getOrDefault, getParam, hasDefault, hasParam, isDefined, isSet, onParamChange, paramMap, params, set, set, set, setDefault, setDefault, shouldOwn
-
Constructor Details
-
StopWordsRemover
-
StopWordsRemover
public StopWordsRemover()
-
-
Method Details
-
load
-
loadDefaultStopWords
Loads the default stop words for the given language. Supported languages: danish, dutch, english, finnish, french, german, hungarian, italian, norwegian, portuguese, russian, spanish, swedish, turkish- Parameters:
language- (undocumented)- Returns:
- (undocumented)
- See Also:
-
read
-
org$apache$spark$internal$Logging$$log_
public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_() -
org$apache$spark$internal$Logging$$log__$eq
public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1) -
LogStringContext
public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc) -
outputCols
Description copied from interface:HasOutputColsParam for output column names.- Specified by:
outputColsin interfaceHasOutputCols- Returns:
- (undocumented)
-
inputCols
Description copied from interface:HasInputColsParam for input column names.- Specified by:
inputColsin interfaceHasInputCols- Returns:
- (undocumented)
-
outputCol
Description copied from interface:HasOutputColParam for output column name.- Specified by:
outputColin interfaceHasOutputCol- Returns:
- (undocumented)
-
inputCol
Description copied from interface:HasInputColParam for input column name.- Specified by:
inputColin interfaceHasInputCol- Returns:
- (undocumented)
-
uid
Description copied from interface:IdentifiableAn immutable unique ID for the object and its derivatives.- Specified by:
uidin interfaceIdentifiable- Returns:
- (undocumented)
-
setInputCol
-
setOutputCol
-
setInputCols
-
setOutputCols
-
stopWords
The words to be filtered out. Default: English stop words- Returns:
- (undocumented)
- See Also:
-
StopWordsRemover.loadDefaultStopWords()
-
setStopWords
-
getStopWords
-
caseSensitive
Whether to do a case sensitive comparison over the stop words. Default: false- Returns:
- (undocumented)
-
setCaseSensitive
-
getCaseSensitive
public boolean getCaseSensitive() -
locale
Locale of the input for case insensitive matching. Ignored whencaseSensitive()is true. Default: the string of default locale (Locale.getDefault), orLocale.USif default locale is not in available locales in JVM.- Returns:
- (undocumented)
-
setLocale
-
getLocale
-
transform
Description copied from class:TransformerTransforms the input dataset.- Specified by:
transformin classTransformer- Parameters:
dataset- (undocumented)- Returns:
- (undocumented)
-
transformSchema
Description copied from class:PipelineStageCheck transform validity and derive the output schema from the input schema.We check validity for interactions between parameters during
transformSchemaand raise an exception if any parameter value is invalid. Parameter value checks which do not depend on other parameters are handled byParam.validate().Typical implementation should first conduct verification on schema change and parameter validity, including complex parameter interaction checks.
- Specified by:
transformSchemain classPipelineStage- Parameters:
schema- (undocumented)- Returns:
- (undocumented)
-
copy
Description copied from interface:ParamsCreates a copy of this instance with the same UID and some extra params. Subclasses should implement this method and set the return type properly. SeedefaultCopy().- Specified by:
copyin interfaceParams- Specified by:
copyin classTransformer- Parameters:
extra- (undocumented)- Returns:
- (undocumented)
-
toString
- Specified by:
toStringin interfaceIdentifiable- Overrides:
toStringin classObject
-