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

Class TestUnboundedTable

    • Method Detail

      • of

        public static TestUnboundedTable of​(java.lang.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")

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

      • addRows

        public TestUnboundedTable addRows​(org.joda.time.Duration duration,
                                  java.lang.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 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.