AnomalyDetectorBase

abstract def responseDataType: DataType

final def !=(arg0: Any): Boolean

final def ##(): Int

final def $[T](param: Param[T]): T

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

final def clear(param: Param[_]): AnomalyDetectorBase.this.type

def clone(): AnyRef

val concurrency: Param[Int]

val concurrentTimeout: Param[Double]

def contentType: (Row) ⇒ String

def copy(extra: ParamMap): Transformer

def copyValues[T <: Params](to: T, extra: ParamMap): T

val customInterval: ServiceParam[Int]

final def defaultCopy[T <: Params](extra: ParamMap): T

def emptyParamData[T](row: Row, p: ServiceParam[T]): Boolean

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

val errorCol: Param[String]

def explainParam(param: Param[_]): String

def explainParams(): String

final def extractParamMap(): ParamMap

final def extractParamMap(extra: ParamMap): ParamMap

def finalize(): Unit

final def get[T](param: Param[T]): Option[T]

final def getClass(): Class[_]

def getConcurrency: Int

def getConcurrentTimeout: Double

final def getDefault[T](param: Param[T]): Option[T]

def getErrorCol: String

def getHandler: HandlerFunc

def getInternalInputParser(schema: StructType): HTTPInputParser

def getInternalOutputParser(schema: StructType): HTTPOutputParser

def getInternalTransformer(schema: StructType): PipelineModel

final def getOrDefault[T](param: Param[T]): T

def getOutputCol: String

def getParam(paramName: String): Param[Any]

def getRequiredParams: Array[ServiceParam[_]]

def getScalarParam[T](name: String): T

def getScalarParam[T](p: ServiceParam[T]): T

def getSubscriptionKey: String

def getSubscriptionKeyCol: String

def getTimeout: Double

def getUrl: String

def getUrlParams: Array[ServiceParam[_]]

def getValue[T](row: Row, p: ServiceParam[T]): T

def getValueAny(row: Row, p: ServiceParam[_]): Any

def getValueAnyOpt(row: Row, p: ServiceParam[_]): Option[Any]

def getValueMap(row: Row, excludes: Set[ServiceParam[_]] = Set()): Map[String, Any]

def getValueOpt[T](row: Row, p: ServiceParam[T]): Option[T]

def getVectorParam(name: String): String

def getVectorParam(p: ServiceParam[_]): String

def getVectorParamMap: Map[String, String]

val granularity: ServiceParam[String]

val handler: UDFParam

def handlingFunc(client: CloseableHttpClient, request: HTTPRequestData): HTTPResponseData

final def hasDefault[T](param: Param[T]): Boolean

def hasParam(paramName: String): Boolean

def hashCode(): Int

def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean

def initializeLogIfNecessary(isInterpreter: Boolean): Unit

def inputFunc(schema: StructType): (Row) ⇒ Option[HttpRequestBase]

final def isDefined(param: Param[_]): Boolean

final def isInstanceOf[T0]: Boolean

final def isSet(param: Param[_]): Boolean

def isTraceEnabled(): Boolean

def log: Logger

def logDebug(msg: ⇒ String, throwable: Throwable): Unit

def logDebug(msg: ⇒ String): Unit

def logError(msg: ⇒ String, throwable: Throwable): Unit

def logError(msg: ⇒ String): Unit

def logInfo(msg: ⇒ String, throwable: Throwable): Unit

def logInfo(msg: ⇒ String): Unit

def logName: String

def logTrace(msg: ⇒ String, throwable: Throwable): Unit

def logTrace(msg: ⇒ String): Unit

def logWarning(msg: ⇒ String, throwable: Throwable): Unit

def logWarning(msg: ⇒ String): Unit

val maxAnomalyRatio: ServiceParam[Double]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val outputCol: Param[String]

The name of the output column

lazy val params: Array[Param[_]]

val period: ServiceParam[Int]

def prepareEntity: (Row) ⇒ Option[AbstractHttpEntity]

def prepareMethod(): HttpRequestBase

def prepareUrl: (Row) ⇒ String

def save(path: String): Unit

val sensitivity: ServiceParam[Int]

val series: ServiceParam[Seq[TimeSeriesPoint]]

final def set(paramPair: ParamPair[_]): AnomalyDetectorBase.this.type

final def set(param: String, value: Any): AnomalyDetectorBase.this.type

final def set[T](param: Param[T], value: T): AnomalyDetectorBase.this.type

def setConcurrency(value: Int): AnomalyDetectorBase.this.type

def setConcurrentTimeout(value: Double): AnomalyDetectorBase.this.type

def setCustomInterval(v: Int): AnomalyDetectorBase.this.type

def setCustomIntervalCol(v: String): AnomalyDetectorBase.this.type

final def setDefault(paramPairs: ParamPair[_]*): AnomalyDetectorBase.this.type

final def setDefault[T](param: Param[T], value: T): AnomalyDetectorBase.this.type

def setDefaultValue[T](p: ServiceParam[T], value: Option[T]): AnomalyDetectorBase.this.type

def setDefaultValue[T](p: ServiceParam[T], value: T): AnomalyDetectorBase.this.type

def setErrorCol(v: String): AnomalyDetectorBase.this.type

def setGranularity(v: String): AnomalyDetectorBase.this.type

def setGranularityCol(v: String): AnomalyDetectorBase.this.type

def setHandler(v: HandlerFunc): AnomalyDetectorBase.this.type

def setMaxAnomalyRatio(v: Double): AnomalyDetectorBase.this.type

def setMaxAnomalyRatioCol(v: String): AnomalyDetectorBase.this.type

def setOutputCol(value: String): AnomalyDetectorBase.this.type

def setPeriod(v: Int): AnomalyDetectorBase.this.type

def setPeriodCol(v: String): AnomalyDetectorBase.this.type

def setScalarParam[T](name: String, value: T): AnomalyDetectorBase.this.type

def setScalarParam[T](p: ServiceParam[T], value: T): AnomalyDetectorBase.this.type

def setSensitivity(v: Int): AnomalyDetectorBase.this.type

def setSensitivityCol(v: String): AnomalyDetectorBase.this.type

def setSubscriptionKey(v: String): AnomalyDetectorBase.this.type

def setSubscriptionKeyCol(v: String): AnomalyDetectorBase.this.type

def setTimeout(value: Double): AnomalyDetectorBase.this.type

def setUrl(value: String): AnomalyDetectorBase.this.type

def setVectorParam(name: String, value: String): AnomalyDetectorBase.this.type

def setVectorParam[T](p: ServiceParam[T], value: String): AnomalyDetectorBase.this.type

def shouldSkip(row: Row): Boolean

val subscriptionKey: ServiceParam[String]

val subscriptionKeyHeaderName: String

final def synchronized[T0](arg0: ⇒ T0): T0

val timeout: Param[Double]

def toString(): String

def transform(dataset: Dataset[_]): DataFrame

def transform(dataset: Dataset[_], paramMap: ParamMap): DataFrame

def transform(dataset: Dataset[_], firstParamPair: ParamPair[_], otherParamPairs: ParamPair[_]*): DataFrame

def transformSchema(schema: StructType): StructType

def transformSchema(schema: StructType, logging: Boolean): StructType

val uid: String

val url: Param[String]

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def write: MLWriter