Package io.deephaven.kafka.ingest.protobuf

Class ProtobufRecordUtil

java.lang.Object

io.deephaven.kafka.ingest.protobuf.ProtobufRecordUtil

public class ProtobufRecordUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProtobufRecordUtil.ProtobufBooleanSetter
static class	ProtobufRecordUtil.ProtobufDBDateTimeSetter
static class	ProtobufRecordUtil.ProtobufDoubleSetter
static class	ProtobufRecordUtil.ProtobufFloatSetter
static class	ProtobufRecordUtil.ProtobufIntSetter
static class	ProtobufRecordUtil.ProtobufLongSetter
static class	ProtobufRecordUtil.ProtobufShortSetter
static class	ProtobufRecordUtil.ProtobufStringSetter

Constructor Summary

Constructors

Constructor	Description
ProtobufRecordUtil()

Method Summary

Modifier and Type	Method	Description
static Boolean	getBoolean(ProtobufRecord record, String key)
static Byte	getBoxedByte(ProtobufRecord record, String key)
static Character	getBoxedChar(ProtobufRecord record, String key)
static Double	getBoxedDouble(ProtobufRecord record, String key)
static Float	getBoxedFloat(ProtobufRecord record, String key)
static Integer	getBoxedInt(ProtobufRecord record, String key)
static Long	getBoxedLong(ProtobufRecord record, String key)
static Short	getBoxedShort(ProtobufRecord record, String key)
static byte	getByte(ProtobufRecord record, String key)
static char	getChar(ProtobufRecord record, String key)
static DBDateTime	getDBDateTime(ProtobufRecord record, String key)
static double	getDouble(ProtobufRecord record, String key)
static float	getFloat(ProtobufRecord record, String key)
static int	getInt(ProtobufRecord record, String key)
static long	getLong(ProtobufRecord record, String key)
static ProtobufRecordSetter	getSetter(Class<?> columnClass)
static short	getShort(ProtobufRecord record, String key)
static String	getString(ProtobufRecord record, String key)

Methods inherited from class java.lang.Object

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

Constructor Details

ProtobufRecordUtil

public ProtobufRecordUtil()

Method Details

getSetter

public static ProtobufRecordSetter getSetter(Class<?> columnClass)

getString

public static String getString(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getInt

public static int getInt(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoxedInt

@Nullable
public static Integer getBoxedInt(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getLong

public static long getLong(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoxedLong

public static Long getBoxedLong(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getDouble

public static double getDouble(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoxedDouble

public static Double getBoxedDouble(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getFloat

public static float getFloat(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoxedFloat

public static Float getBoxedFloat(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getShort

public static short getShort(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoxedShort

public static Short getBoxedShort(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getChar

public static char getChar(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoxedChar

public static Character getBoxedChar(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getByte

public static byte getByte(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoxedByte

public static Byte getBoxedByte(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getBoolean

public static Boolean getBoolean(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)

getDBDateTime

public static DBDateTime getDBDateTime(@NotNull
 ProtobufRecord record,
 @NotNull
 String key)