Package app.babylon.table.plans

Interface TablePlan

All Known Implementing Classes:
TablePlanAggregate, TablePlanCommon, TablePlanRead
public interface TablePlan

  • Method Details

    • withTableName

      TablePlan withTableName(TableName tableName)

    • getTableName

      TableName getTableName()

    • withTableDescription

      TablePlan withTableDescription(TableDescription tableDescription)

    • getTableDescription

      TableDescription getTableDescription()

    • execute

      TableColumnar execute(StreamSource streamSource, TabularRowReader reader)

    • execute

      TableColumnar execute(RowCursor rowCursor)
      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

      TableColumnar execute(RowSource rowSource)
      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