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

Class TestBoundedTable

    • Constructor Summary

      Constructors 
      Constructor Description
      TestBoundedTable​(org.apache.beam.sdk.schemas.Schema beamSchema)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      TestBoundedTable addRows​(java.lang.Object... args)
      Add rows to the builder.
      org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> buildIOReader​(org.apache.beam.sdk.values.PBegin begin)
      create a PCollection<Row> from source.
      org.apache.beam.sdk.values.POutput buildIOWriter​(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> input)
      create a IO.write() instance to write to target.
      BeamTableStatistics getTableStatistics​(org.apache.beam.sdk.options.PipelineOptions options)
      Estimates the number of rows or the rate for unbounded Tables.
      org.apache.beam.sdk.values.PCollection.IsBounded isBounded()
      Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).
      static TestBoundedTable of​(java.lang.Object... args)
      Convenient way to build a mocked bounded table.
      static TestBoundedTable of​(org.apache.beam.sdk.schemas.Schema type)
      Build a mocked bounded table with the specified type.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • TestBoundedTable

        public TestBoundedTable​(org.apache.beam.sdk.schemas.Schema beamSchema)

    • Method Detail

      • getTableStatistics

        public BeamTableStatistics getTableStatistics​(org.apache.beam.sdk.options.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

      • isBounded

        public org.apache.beam.sdk.values.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).

      • of

        public static TestBoundedTable of​(java.lang.Object... args)
        Convenient way to build a mocked bounded table.

        e.g. 

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

      • of

        public static TestBoundedTable of​(org.apache.beam.sdk.schemas.Schema type)
        Build a mocked bounded table with the specified type.

      • addRows

        public TestBoundedTable addRows​(java.lang.Object... args)
        Add rows to the builder.

        Sample usage: 

        
 addRows(
   1, 3, "james", -- first row
   2, 5, "bond"   -- second row
   ...
 )

      • buildIOReader

        public org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> buildIOReader​(org.apache.beam.sdk.values.PBegin begin)
        Description copied from interface: BeamSqlTable
        create a PCollection<Row> from source.

      • buildIOWriter

        public org.apache.beam.sdk.values.POutput buildIOWriter​(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> input)
        Description copied from interface: BeamSqlTable
        create a IO.write() instance to write to target.
        Specified by:
        buildIOWriter in interface BeamSqlTable
        Overrides:
        buildIOWriter in class TestTable