Package org.apache.beam.sdk.extensions.sql.meta.provider.test

Class TestUnboundedTable

java.lang.Object
org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable
org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable
org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTable
org.apache.beam.sdk.extensions.sql.meta.provider.test.TestUnboundedTable
All Implemented Interfaces:
Serializable, BeamSqlTable
public class TestUnboundedTable extends TestTable
A mocked unbounded table.
See Also:

  • Method Details

    • of

      public static TestUnboundedTable of(Object... args)
      Convenient way to build a mocked unbounded table.

      e.g. 

      
 TestUnboundedTable
   .of(Types.BIGINT, "order_id",
       Types.INTEGER, "site_id",
       Types.DOUBLE, "price",
       Types.TIMESTAMP, "order_time")

    • setStatistics

      public TestUnboundedTable setStatistics(BeamTableStatistics statistics)

    • getTableStatistics

      public BeamTableStatistics getTableStatistics(PipelineOptions options)
      Description copied from interface: BeamSqlTable
      Estimates the number of rows or the rate for unbounded Tables. If it is not possible to estimate the row count or rate it will return BeamTableStatistics.BOUNDED_UNKNOWN.
      Specified by:
      getTableStatistics in interface BeamSqlTable
      Overrides:
      getTableStatistics in class BaseBeamTable

    • timestampColumnIndex

      public TestUnboundedTable timestampColumnIndex(int idx)

    • isBounded

      public PCollection.IsBounded isBounded()
      Description copied from interface: BeamSqlTable
      Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).

    • addRows

      public TestUnboundedTable addRows(Duration duration, Object... args)
      Add rows to the builder.

      Sample usage: 

      
 addRows(
   duration,      -- duration which stands for the corresponding watermark instant
   1, 3, "james", -- first row
   2, 5, "bond"   -- second row
   ...
 )

    • buildIOReader

      public PCollection<Row> buildIOReader(PBegin begin)
      Description copied from interface: BeamSqlTable
      create a PCollection<Row> from source.