Package app.babylon.table.plans

Class TablePlanAggregate

java.lang.Object

app.babylon.table.plans.TablePlanCommon<TablePlanAggregate>

app.babylon.table.plans.TablePlanAggregate

All Implemented Interfaces:

TablePlan

public class TablePlanAggregate
extends TablePlanCommon<TablePlanAggregate>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	TablePlanAggregate.AggregateSpec

Constructor Summary

Constructors

Constructor	Description
TablePlanAggregate()

Method Summary

Modifier and Type	Method	Description
TableColumnar	execute(RowCursor rowCursor)	Executes this plan against an already-open row supplier.
TableColumnar	execute(RowSource rowSource)	Executes this plan against a configured row source.
TableColumnar	execute(TableColumnar table)
List<TablePlanAggregate.AggregateSpec>	getAggregateSpecs()
Column.Type	getColumnType(ColumnName columnName)
Map<ColumnName,Column.Type>	getColumnTypes()
List<ColumnName>	getGroupByColumns()
protected TablePlanAggregate	self()
TablePlanAggregate	withAggregate(ColumnName sourceColumnName, Aggregate aggregate)
TablePlanAggregate	withAggregate(ColumnName sourceColumnName, ColumnName outputColumnName, Aggregate aggregate)
TablePlanAggregate	withColumnType(ColumnName columnName, Column.Type columnType)
TablePlanAggregate	withGroupBy(ColumnName... columnNames)

Methods inherited from class app.babylon.table.plans.TablePlanCommon

getTableDescription, getTableName, withTableDescription, withTableName

Methods inherited from class java.lang.Object

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

Constructor Details

TablePlanAggregate

public TablePlanAggregate()

Method Details

withColumnType

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

getColumnType

public Column.Type getColumnType(ColumnName columnName)

getColumnTypes

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

withGroupBy

public TablePlanAggregate withGroupBy(ColumnName... columnNames)

getGroupByColumns

public List<ColumnName> getGroupByColumns()

withAggregate

public TablePlanAggregate withAggregate(ColumnName sourceColumnName,
 Aggregate aggregate)

withAggregate

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

getAggregateSpecs

public List<TablePlanAggregate.AggregateSpec> getAggregateSpecs()

execute

public TableColumnar execute(TableColumnar table)

execute

public TableColumnar execute(RowCursor rowCursor)

Description copied from interface: TablePlan

Executes this plan against an already-open row supplier.

Use this lower-level entry point when the caller already owns the live source resource and wants to control its lifetime explicitly.

For CSV, open the input stream, create a RowCursor, then pass that cursor to this method inside the caller's resource scope. For JDBC, execute the prepared statement, wrap the live ResultSet in a row cursor, and pass it to this method before closing the JDBC resources.

Parameters:

rowCursor - open row supplier to consume

Returns:

the resulting table

execute

public TableColumnar execute(RowSource rowSource)

Description copied from interface: TablePlan

Executes this plan against a configured row source.

This is the simplest high-level entry point when the source should handle opening and closing its own row supplier internally.

For CSV or JDBC, build an appropriate RowSource and pass it to this method. The row source owns the open/close lifecycle for each execution.

Parameters:

rowSource - configured source that opens rows for this execution

Returns:

the resulting table

self

protected TablePlanAggregate self()

Specified by:

self in class TablePlanCommon<TablePlanAggregate>