org.apache.beam.sdk.extensions.sql

Class BeamSqlRecordHelper

java.lang.Object

org.apache.beam.sdk.extensions.sql.BeamSqlRecordHelper

@Experimental
public class BeamSqlRecordHelper
extends java.lang.Object

A Coder encodes BeamRecord.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BeamSqlRecordHelper.BooleanCoder Coder for Java type Boolean.
static class	BeamSqlRecordHelper.DateCoder Coder for Java type Date, it's stored as Long.
static class	BeamSqlRecordHelper.DoubleCoder Coder for Java type Double, it's stored as BigDecimal.
static class	BeamSqlRecordHelper.FloatCoder Coder for Java type Float, it's stored as BigDecimal.
static class	BeamSqlRecordHelper.ShortCoder Coder for Java type Short.
static class	BeamSqlRecordHelper.TimeCoder Coder for Java type GregorianCalendar, it's stored as Long.

Constructor Summary

Constructors

Constructor and Description
BeamSqlRecordHelper()

Method Summary

Modifier and Type	Method and Description
static BeamRecordSqlType	getSqlRecordType(BeamRecord record)

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamSqlRecordHelper

public BeamSqlRecordHelper()

Method Detail

getSqlRecordType

public static BeamRecordSqlType getSqlRecordType(BeamRecord record)