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.

Constructor Summary

Constructors

Constructor and Description
BeamTableUtils()

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	autoCastField(int fieldType, java.lang.Object rawObj)
static java.lang.String	beamSqlRow2CsvLine(BeamRecord row, CSVFormat csvFormat)
static BeamRecord	csvLine2BeamSqlRow(CSVFormat csvFormat, java.lang.String line, BeamRecordSqlType beamRecordSqlType)

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

csvLine2BeamSqlRow

public static BeamRecord csvLine2BeamSqlRow(CSVFormat csvFormat,
                                            java.lang.String line,
                                            BeamRecordSqlType beamRecordSqlType)

beamSqlRow2CsvLine

public static java.lang.String beamSqlRow2CsvLine(BeamRecord row,
                                                  CSVFormat csvFormat)

autoCastField

public static java.lang.Object autoCastField(int fieldType,
                                             java.lang.Object rawObj)