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

Package-level declarations

Types

Functions

internal fun <T, C, R> DataFrame<T>.aggregateAll(aggregator: Aggregator<C & Any, R>, columns: ColumnsSelector<T, C>): R

internal fun <T, C, R> PivotGroupBy<T>.aggregateAll(aggregator: Aggregator<C & Any, R>, columns: ColumnsSelector<T, C>): DataFrame<T>

@PublishedApi

internal fun <T, C, R> Aggregator<*, R>.aggregateAll(data: DataFrame<T>, columns: ColumnsSelector<T, C>): R

internal fun <T, C, R> Aggregator<*, R>.aggregateAll(data: PivotGroupBy<T>, columns: ColumnsSelector<T, C>): DataFrame<T>

internal fun <T, C, R> Grouped<T>.aggregateAll(aggregator: Aggregator<C & Any, R>, columns: ColumnsSelector<T, C>, name: String?): DataFrame<T>

internal fun <T, C, R> Aggregator<*, R>.aggregateAll(data: Grouped<T>, name: String?, columns: ColumnsSelector<T, C>): DataFrame<T>

aggregateBy

@PublishedApi

internal inline fun <T, reified V : R, R> Aggregator<V & Any, R>.aggregateBy(values: Iterable<T>, crossinline selector: (T) -> V): Result<T>

Selects the best matching value in the iterable using the provided Aggregator by the provided selector.

@PublishedApi

internal inline fun <T, reified V : R, R> Aggregator<V & Any, R>.aggregateBy(values: Sequence<T>, crossinline selector: (T) -> V): Result<T>

Selects the best matching value in the sequence using the provided Aggregator by the provided selector.

@PublishedApi

internal inline fun <T, reified V : R, R> Aggregator<V & Any, R>.aggregateBy(column: DataColumn<T>, crossinline selector: (T) -> V): Result<T>

Selects the best matching value in the column using the provided Aggregator by the provided selector.

aggregateByOrNull

@PublishedApi

internal inline fun <T, reified V : R, R> Aggregator<V & Any, R>.aggregateByOrNull(data: DataFrame<T>, crossinline rowExpression: RowExpression<T, V>): DataRow<T>?

Selects the best matching value in the dataframe using the provided Aggregator by the provided rowExpression.

@PublishedApi

internal inline fun <T, reified V : R, R> Aggregator<V & Any, R>.aggregateByOrNull(data: DataFrame<T>, column: ColumnReference<V>): DataRow<T>?

Selects the best matching value in the dataframe using the provided Aggregator by the provided column.

aggregateFor

internal fun <T, C, R> Aggregator<*, R>.aggregateFor(data: DataFrame<T>, columns: ColumnsForAggregateSelector<T, C?>): DataRow<T>

internal fun <T, C, R> Aggregator<*, R>.aggregateFor(data: Grouped<T>, columns: ColumnsForAggregateSelector<T, C?>): DataFrame<T>

internal fun <T, C : Any, R> AggregateInternalDsl<T>.aggregateFor(columns: ColumnsForAggregateSelector<T, C?>, aggregator: Aggregator<C, R>)

internal fun <T, C, R> Aggregator<*, R>.aggregateFor(data: PivotGroupBy<T>, separate: Boolean, columns: ColumnsForAggregateSelector<T, C?>): DataFrame<T>

aggregateOf

@PublishedApi

internal inline fun <T, reified C, R> PivotGroupBy<T>.aggregateOf(crossinline expression: RowExpression<T, C>, aggregator: Aggregator<C & Any, R>): DataFrame<T>

@PublishedApi

internal inline fun <T, reified C, reified R> Aggregator<*, R>.aggregateOf(data: PivotGroupBy<T>, crossinline expression: RowExpression<T, C>): DataFrame<T>

@PublishedApi

internal inline fun <T, reified C, reified R> Grouped<T>.aggregateOf(resultName: String?, crossinline expression: RowExpression<T, C>, aggregator: Aggregator<C & Any, R>): DataFrame<T>

@PublishedApi

internal inline fun <T, reified V, R> Aggregator<*, R>.aggregateOf(frame: DataFrame<T>, crossinline expression: RowExpression<T, V>): R

Aggregates frame by first applying expression to each row of the frame and then applying the Aggregator (this) to the resulting sequence.

@PublishedApi

internal inline fun <C, reified V, R> Aggregator<V & Any, R>.aggregateOf(values: Sequence<C>, crossinline transform: (C) -> V): R

Aggregates values by first applying transform to each element of the sequence and then applying the Aggregator (this) to the resulting sequence.

@PublishedApi

internal inline fun <C, reified V, R> Aggregator<V & Any, R>.aggregateOf(column: DataColumn<C>, crossinline transform: (C) -> V): R

Aggregates column by first applying transform to each element of the column and then applying the Aggregator (this) to the resulting sequence.

@PublishedApi

internal inline fun <T, reified C, reified R> Aggregator<*, R>.aggregateOf(data: Grouped<T>, resultName: String? = null, crossinline expression: RowExpression<T, C>): DataFrame<T>

Aggregates data by first applying expression to each row of the frame and then

aggregateOfDelegated

@PublishedApi

internal fun <T, C, R> Aggregator<*, R>.aggregateOfDelegated(frame: Grouped<T>, name: String?, body: AggregateBody<T, C>): DataFrame<T>

aggregateOfRow

@PublishedApi

internal fun <T, V, R> Aggregator<V & Any, R>.aggregateOfRow(row: DataRow<T>, columns: ColumnsSelector<T, V>): R

Generic function to apply an Aggregator (this) to aggregate values of a row.

aggregateValue

@PublishedApi

internal fun <T, R> Grouped<T>.aggregateValue(resultName: String, body: AggregateBody<T, R>): DataFrame<T>