Package app.babylon.table.aggregation

Class AggregationPlan

java.lang.Object

app.babylon.table.aggregation.AggregationPlan

public class AggregationPlan
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	AggregationPlan.AggregateSpec

Constructor Summary

Constructors

Constructor	Description
AggregationPlan()

Method Summary

Modifier and Type	Method	Description
TableColumnar	execute(DataSource dataSource, Csv.Settings readSettings)
TableColumnar	execute(TableColumnar table)
List<AggregationPlan.AggregateSpec>	getAggregateSpecs()
Column.Type	getColumnType(ColumnName columnName)
Map<ColumnName,Column.Type>	getColumnTypes()
List<ColumnName>	getGroupByColumns()
TableName	getOutputTableName()
AggregationPlan	withAggregate(ColumnName sourceColumnName, Aggregate aggregate)
AggregationPlan	withAggregate(ColumnName sourceColumnName, ColumnName outputColumnName, Aggregate aggregate)
AggregationPlan	withColumnType(ColumnName columnName, Column.Type columnType)
AggregationPlan	withColumnType(ColumnName columnName, Class<?> valueClass)
AggregationPlan	withGroupBy(ColumnName... columnNames)
AggregationPlan	withOutputTableName(TableName outputTableName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AggregationPlan

public AggregationPlan()

Method Details

withOutputTableName

public AggregationPlan withOutputTableName(TableName outputTableName)

getOutputTableName

public TableName getOutputTableName()

withColumnType

public AggregationPlan withColumnType(ColumnName columnName,
 Column.Type columnType)

withColumnType

public AggregationPlan withColumnType(ColumnName columnName,
 Class<?> valueClass)

getColumnType

public Column.Type getColumnType(ColumnName columnName)

getColumnTypes

public Map<ColumnName,Column.Type> getColumnTypes()

withGroupBy

public AggregationPlan withGroupBy(ColumnName... columnNames)

getGroupByColumns

public List<ColumnName> getGroupByColumns()

withAggregate

public AggregationPlan withAggregate(ColumnName sourceColumnName,
 Aggregate aggregate)

withAggregate

public AggregationPlan withAggregate(ColumnName sourceColumnName,
 ColumnName outputColumnName,
 Aggregate aggregate)

getAggregateSpecs

public List<AggregationPlan.AggregateSpec> getAggregateSpecs()

execute

public TableColumnar execute(TableColumnar table)

execute

public TableColumnar execute(DataSource dataSource,
 Csv.Settings readSettings)