core/org.jetbrains.kotlinx.dataframe.impl.aggregation

Package-level declarations

Types

internal interface AggregatableInternal<out T> : Aggregatable<T>

internal class AggregateColumnDescriptor<C>(val column: ColumnWithPath<C>, val default: C? = null, val newPath: ColumnPath? = null) : ColumnWithPath<C>

ConfiguredAggregateColumn

internal class ConfiguredAggregateColumn<C> : SingleColumn<C> , ColumnSet<C>

GroupByReceiverImpl

internal class GroupByReceiverImpl<T>(val df: DataFrame<T>, val hasGroupingKeys: Boolean) : AggregateGroupedDsl<T> , AggregateInternalDsl<T> , AggregatableInternal<T> , DataFrame<T>

PivotGroupByImpl

internal data class PivotGroupByImpl<T>(val df: GroupBy<*, T>, val columns: PivotColumnsSelector<T, *>, val inward: Boolean?, val default: Any? = null) : PivotGroupBy<T> , AggregatableInternal<T>

PivotImpl

internal data class PivotImpl<T>(val df: DataFrame<T>, val columns: PivotColumnsSelector<T, *>, val inward: Boolean?) : Pivot<T> , AggregatableInternal<T>

PivotInAggregateImpl

internal data class PivotInAggregateImpl<T>(val aggregator: AggregateGroupedDsl<T>, val columns: PivotColumnsSelector<T, *>, val inward: Boolean?, val default: Any? = null) : PivotGroupBy<T> , AggregatableInternal<T>

ValueWithDefault

internal class ValueWithDefault<T>(val value: T, val default: T)

Functions

aggregateInternal

@PublishedApi

internal fun <T, R> Grouped<T>.aggregateInternal(body: AggregateBodyInternal<T, R>): DataFrame<T>

columnValues

internal fun <T, C> AggregateInternalDsl<T>.columnValues(columns: ColumnsForAggregateSelector<T, C>, reducer: Selector<DataFrame<T>, DataRow<T>?>)

internal fun <T, C> AggregateInternalDsl<T>.columnValues(columns: ColumnsForAggregateSelector<T, C>, forceYieldLists: Boolean, dropNA: Boolean, distinct: Boolean)

getAggregateColumn

internal fun <T, C> DataFrame<T>.getAggregateColumn(selector: ColumnsForAggregateSelector<T, C>): AggregateColumnDescriptor<C>

getAggregateColumns

internal fun <T, C> DataFrame<T>.getAggregateColumns(selector: ColumnsForAggregateSelector<T, C>): List<AggregateColumnDescriptor<C>>

getPath

internal fun <T, C> AggregateInternalDsl<T>.getPath(col: AggregateColumnDescriptor<C>, isSingle: Boolean): ColumnPath

internal

@PublishedApi

internal fun <T> Aggregatable<T>.internal(): AggregatableInternal<T>

@PublishedApi

internal fun <T> AggregateDsl<T>.internal(): AggregateInternalDsl<T>

intraComparableColumns

internal fun <T> Aggregatable<T>.intraComparableColumns(): ColumnsSelector<T, Comparable<Any>?>

Emulates selecting all columns whose values are mutually comparable to each other. These are columns of type R where R : Comparable<R>.

numberColumns

internal fun <T> Aggregatable<T>.numberColumns(): ColumnsSelector<T, Number?>

primitiveOrMixedNumberColumns

internal fun <T> DataRow<T>.primitiveOrMixedNumberColumns(): ColumnsSelector<T, Number?>

internal fun <T> Aggregatable<T>.primitiveOrMixedNumberColumns(): ColumnsSelector<T, Number?>

remainingColumns

internal inline fun <T> Aggregatable<T>.remainingColumns(crossinline predicate: (AnyCol) -> Boolean): ColumnsSelector<T, Any?>

remainingColumnsSelector

internal fun <T> Aggregatable<T>.remainingColumnsSelector(): ColumnsSelector<*, *>

toColumns

@JvmName(name = "toColumnSetForAggregate")

internal fun <T, C> ColumnsForAggregateSelector<T, C>.toColumns(): ColumnSet<C>

toColumnWithPath

internal fun NamedValue.toColumnWithPath(): Pair<ColumnPath, DataColumn<Any?>>

withExpr

@PublishedApi

internal fun <T, V> AggregateInternalDsl<T>.withExpr(type: KType, path: ColumnPath, expression: RowExpression<T, V>)

yieldOneOrMany

@PublishedApi

internal fun <T, V> AggregateInternalDsl<T>.yieldOneOrMany(path: ColumnPath, values: List<V>, type: KType, default: V? = null)