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	beamRecord2CsvLine(BeamRecord row, CSVFormat csvFormat)
static BeamRecord	csvLine2BeamRecord(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

csvLine2BeamRecord

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

beamRecord2CsvLine

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

autoCastField

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