StatCounterAggregator

Instance Constructors

new StatCounterAggregator(aggType: Type)

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 aggType: Type
def anyNull: Boolean

Returns true if there are any NULL values in this row.
Returns true if there are any NULL values in this row.

Definition Classes
BaseGenericInternalRow → InternalRow
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def copy(): StatCounterAggregator

Clone this StatVarianceCounter
Clone this StatVarianceCounter

Definition Classes
StatCounterAggregator → StatVarianceCounter → InternalRow
def copy(other: ClosedFormStats): Unit

Definition Classes
ClosedFormStats
final var count: Long

Definition Classes
StatVarianceCounter
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(o: Any): Boolean

Definition Classes
BaseGenericInternalRow → AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def genericGet(ordinal: Int): Any

Attributes
protected
Definition Classes
ClosedFormStats
def get(ordinal: Int, dataType: DataType): AnyRef

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getArray(ordinal: Int): ArrayData

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getBinary(ordinal: Int): Array[Byte]

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getBoolean(ordinal: Int): Boolean

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getByte(ordinal: Int): Byte

Definition Classes
BaseGenericInternalRow → SpecializedGetters
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getDecimal(ordinal: Int, precision: Int, scale: Int): Decimal

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getDouble(ordinal: Int): Double

Definition Classes
ClosedFormStats
def getFloat(ordinal: Int): Float

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getInt(ordinal: Int): Int

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getInterval(ordinal: Int): CalendarInterval

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getLong(ordinal: Int): Long

Definition Classes
ClosedFormStats
def getMap(ordinal: Int): MapData

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getShort(ordinal: Int): Short

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getStrataErrorStat: StatCounterWithFullCount
def getString(ordinal: Int): String

Definition Classes
InternalRow
def getStruct(ordinal: Int, numFields: Int): InternalRow

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def getUTF8String(ordinal: Int): UTF8String

Definition Classes
BaseGenericInternalRow → SpecializedGetters
def hashCode(): Int

Definition Classes
BaseGenericInternalRow → AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def isNullAt(ordinal: Int): Boolean

Definition Classes
BaseGenericInternalRow → SpecializedGetters
final var mean: Double

Definition Classes
StatVarianceCounter
def merge(other: ClosedFormStats): Unit

Definition Classes
ClosedFormStats
final def merge(other: StatVarianceCounter): Unit

Merge another StatVarianceCounter into this one, adding up the internal statistics.
Merge another StatVarianceCounter into this one, adding up the internal statistics.

Definition Classes
StatVarianceCounter
final def merge(values: TraversableOnce[Double]): Unit

Add multiple values into this StatVarianceCounter, updating the internal statistics.
Add multiple values into this StatVarianceCounter, updating the internal statistics.

Definition Classes
StatVarianceCounter
final def merge(value: Double): Unit

Add a value into this StatVarianceCounter, updating the internal statistics.
Add a value into this StatVarianceCounter, updating the internal statistics.

Definition Classes
StatVarianceCounter
def mergeDistinctCounter(other: ClosedFormStats): Unit

Attributes
protected
Definition Classes
ClosedFormStats
def mergeDistinctCounter(other: StatVarianceCounter): Unit

Merge another StatVarianceCounter into this one, adding up the internal statistics when other != this.
Merge another StatVarianceCounter into this one, adding up the internal statistics when other != this.

Attributes
protected
Definition Classes
StatVarianceCounter
def mergeTrueSum(other: ClosedFormStats): Unit

Definition Classes
ClosedFormStats
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def numFields: Int

Definition Classes
ClosedFormStats
final def sampleStdev: Double

Return the sample standard deviation of the values, which corrects for bias in estimating the variance by dividing by N-1 instead of N.
Return the sample standard deviation of the values, which corrects for bias in estimating the variance by dividing by N-1 instead of N.

Definition Classes
StatVarianceCounter
final def sampleVariance: Double

Return the sample variance, which corrects for bias in estimating the variance by dividing by N-1 instead of N.
Return the sample variance, which corrects for bias in estimating the variance by dividing by N-1 instead of N.

Definition Classes
StatVarianceCounter
def setBoolean(i: Int, value: Boolean): Unit

Definition Classes
InternalRow
def setByte(i: Int, value: Byte): Unit

Definition Classes
InternalRow
def setDecimal(i: Int, value: Decimal, precision: Int): Unit

Update the decimal column at i.
Update the decimal column at i.
Note: In order to support update decimal with precision > 18 in UnsafeRow, CAN NOT call setNullAt() for decimal column on UnsafeRow, call setDecimal(i, null, precision).

Definition Classes
InternalRow
def setDouble(i: Int, value: Double): Unit

Definition Classes
InternalRow
def setFloat(i: Int, value: Float): Unit

Definition Classes
InternalRow
def setInt(i: Int, value: Int): Unit

Definition Classes
InternalRow
def setLong(i: Int, value: Long): Unit

Definition Classes
InternalRow
def setNullAt(i: Int): Unit

Definition Classes
StatCounterAggregator → InternalRow
def setShort(i: Int, value: Short): Unit

Definition Classes
InternalRow
final def stdev: Double

Return the standard deviation of the values.
Return the standard deviation of the values.

Definition Classes
StatVarianceCounter
def store(): Unit
final def sum: Double

Definition Classes
StatVarianceCounter
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toSeq(schema: StructType): Seq[Any]

Definition Classes
InternalRow
def toSeq(fieldTypes: Seq[DataType]): Seq[Any]

Return a Scala Seq representing the row.
Return a Scala Seq representing the row. Elements are placed in the same order in the Seq.

Definition Classes
InternalRow
def toString(): String

Definition Classes
StatVarianceCounter → AnyRef → Any
def triggerSerialization(): Unit

Evaluate once at each partition
Evaluate once at each partition

Definition Classes
StatCounterAggregator → ClosedFormStats
var trueSum: Double

Definition Classes
StatCounterAggregator → ClosedFormStats
def update(i: Int, value: Any): Unit

Definition Classes
StatCounterAggregator → InternalRow
final def variance: Double

Return the variance of the values.
Return the variance of the values.

Definition Classes
StatVarianceCounter
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
var weightedCount: Double

Definition Classes
StatCounterAggregator → ClosedFormStats

Related Doc: package closedform

class StatCounterAggregator extends InternalRow with BaseGenericInternalRow with ClosedFormStats

Instance Constructors

new StatCounterAggregator(aggType: Type)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val aggType: Type

def anyNull: Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def copy(): StatCounterAggregator

def copy(other: ClosedFormStats): Unit

final var count: Long

final def eq(arg0: AnyRef): Boolean

def equals(o: Any): Boolean

def finalize(): Unit

def genericGet(ordinal: Int): Any

def get(ordinal: Int, dataType: DataType): AnyRef

def getArray(ordinal: Int): ArrayData

def getBinary(ordinal: Int): Array[Byte]

def getBoolean(ordinal: Int): Boolean

def getByte(ordinal: Int): Byte

final def getClass(): Class[_]

def getDecimal(ordinal: Int, precision: Int, scale: Int): Decimal

def getDouble(ordinal: Int): Double

def getFloat(ordinal: Int): Float

def getInt(ordinal: Int): Int

def getInterval(ordinal: Int): CalendarInterval

def getLong(ordinal: Int): Long

def getMap(ordinal: Int): MapData

def getShort(ordinal: Int): Short

def getStrataErrorStat: StatCounterWithFullCount

def getString(ordinal: Int): String

def getStruct(ordinal: Int, numFields: Int): InternalRow

def getUTF8String(ordinal: Int): UTF8String

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def isNullAt(ordinal: Int): Boolean

final var mean: Double

def merge(other: ClosedFormStats): Unit

final def merge(other: StatVarianceCounter): Unit

final def merge(values: TraversableOnce[Double]): Unit

final def merge(value: Double): Unit

def mergeDistinctCounter(other: ClosedFormStats): Unit

def mergeDistinctCounter(other: StatVarianceCounter): Unit

def mergeTrueSum(other: ClosedFormStats): Unit

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def numFields: Int

final def sampleStdev: Double

final def sampleVariance: Double

def setBoolean(i: Int, value: Boolean): Unit

def setByte(i: Int, value: Byte): Unit

def setDecimal(i: Int, value: Decimal, precision: Int): Unit

def setDouble(i: Int, value: Double): Unit

def setFloat(i: Int, value: Float): Unit

def setInt(i: Int, value: Int): Unit

def setLong(i: Int, value: Long): Unit

def setNullAt(i: Int): Unit

def setShort(i: Int, value: Short): Unit

final def stdev: Double

def store(): Unit

final def sum: Double

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

def toSeq(schema: StructType): Seq[Any]

def toSeq(fieldTypes: Seq[DataType]): Seq[Any]

def toString(): String

def triggerSerialization(): Unit

var trueSum: Double

def update(i: Int, value: Any): Unit

final def variance: Double

final def wait(): Unit

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

final def wait(arg0: Long): Unit

var weightedCount: Double

Inherited from ClosedFormStats