TestTableUtils (Apache Beam 2.23.0)

@Experimental
public class TestTableUtils
extends java.lang.Object

Utility functions for mock classes.

Constructors
Constructor and Description
`TestTableUtils()`

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static Schema`	`buildBeamSqlNullableSchema(java.lang.Object... args)`
`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 `BeamSqlRow`s.
`static Schema.Field`	`toNullableRecordField(java.lang.Object[] args, int i)`
`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

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"
 )

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

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

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

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

Class TestTableUtils