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

Class TestTableUtils

java.lang.Object

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

@Experimental
public class TestTableUtils
extends java.lang.Object

Utility functions for mock classes.

Constructor Summary

Constructors

Constructor and Description
TestTableUtils()

Method Summary

Modifier and Type	Method and Description
static Schema	buildBeamSqlSchema(java.lang.Object... args) Create a RowsBuilder with the specified row type info.
static java.util.List<Row>	buildRows(Schema type, java.util.List<?> rowsValues) Convenient way to build a BeamSqlRows.
static Schema.Field	toRecordField(java.lang.Object[] args, int i)

Methods inherited from class java.lang.Object

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

Constructor Detail

TestTableUtils

public TestTableUtils()

Method Detail

buildBeamSqlSchema

public static Schema buildBeamSqlSchema(java.lang.Object... args)

Create a RowsBuilder with the specified row type info.

For example:

 TestUtils.RowsBuilder.of(
   Types.INTEGER, "order_id",
   Types.INTEGER, "sum_site_id",
   Types.VARCHAR, "buyer"
 )
 

Parameters:

args - pairs of column type and column names.

toRecordField

public static Schema.Field toRecordField(java.lang.Object[] args,
                                         int i)

buildRows

public static java.util.List<Row> buildRows(Schema type,
                                            java.util.List<?> rowsValues)

Convenient way to build a BeamSqlRows.

e.g.

 buildRows(
     schema,
     1, 1, 1, // the first row
     2, 2, 2, // the second row
     ...
 )