org.apache.beam.sdk.extensions.sql.impl.schema

Class BeamTableUtils

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.schema.BeamTableUtils

public final class BeamTableUtils
extends java.lang.Object

Utility methods for working with BeamTable.

TODO: Does not yet support nested types.

Constructor Summary

Constructors

Constructor and Description
BeamTableUtils()

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	autoCastField(Schema.Field field, java.lang.Object rawObj)
static java.lang.String	beamRow2CsvLine(Row row, org.apache.commons.csv.CSVFormat csvFormat)
static Row	csvLine2BeamRow(org.apache.commons.csv.CSVFormat csvFormat, java.lang.String line, Schema schema)

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamTableUtils

public BeamTableUtils()

Method Detail

csvLine2BeamRow

public static Row csvLine2BeamRow(org.apache.commons.csv.CSVFormat csvFormat,
                                  java.lang.String line,
                                  Schema schema)

beamRow2CsvLine

public static java.lang.String beamRow2CsvLine(Row row,
                                               org.apache.commons.csv.CSVFormat csvFormat)

autoCastField

public static java.lang.Object autoCastField(Schema.Field field,
                                             java.lang.Object rawObj)