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>

  • Constructor Details

    • TablePlanAggregate

      public TablePlanAggregate()

  • Method Details

    • withColumnType

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

    • withColumnType

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

    • 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(StreamSource streamSource, TabularRowReader reader)

    • 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.

      CSV example: 

      
 StreamSource streamSource = ...;
 TablePlanRead plan = new TablePlanRead();

 try (InputStream inputStream = streamSource.openStream();
         RowCursor rowCursor = RowCursorCsv.builder()
                 .withSeparator(';')
                 .build(inputStream))
 {
     TableColumnar table = plan.execute(rowCursor);
 }
      JDBC example: 
      
 PreparedStatement preparedStatement = ...;
 TablePlanRead plan = new TablePlanRead();

 try (ResultSet resultSet = preparedStatement.executeQuery();
         RowCursor rowCursor = new RowCursorResultSet(resultSet))
 {
     TableColumnar table = plan.execute(rowCursor);
 }
      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.

      CSV example: 

      
 StreamSource streamSource = ...;
 TablePlanRead plan = new TablePlanRead();

 TableColumnar table = plan.execute(RowSourceCsv.builder()
         .withStreamSource(streamSource)
         .withSeparator(';')
         .build());
      JDBC example: 
      
 PreparedStatement preparedStatement = ...;
 TablePlanRead plan = new TablePlanRead();

 TableColumnar table = plan.execute(RowSourceResultSet.builder()
         .withPreparedStatement(preparedStatement)
         .build());
      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>