Package org.apache.flink.types.variant

Class BinaryVariantInternalBuilder

java.lang.Object

org.apache.flink.types.variant.BinaryVariantInternalBuilder

@Internal
public class BinaryVariantInternalBuilder
extends Object

The internal builder for BinaryVariant.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BinaryVariantInternalBuilder.FieldEntry

Field Summary

Fields

Modifier and Type	Field	Description
static VariantTypeException	VARIANT_DUPLICATE_KEY_EXCEPTION
static VariantTypeException	VARIANT_SIZE_LIMIT_EXCEPTION

Constructor Summary

Constructors

Constructor	Description
BinaryVariantInternalBuilder(boolean allowDuplicateKeys)

Method Summary

Modifier and Type	Method	Description
int	addKey(String key)
void	appendBinary(byte[] binary)
void	appendBoolean(boolean b)
void	appendByte(byte b)
void	appendDate(int daysSinceEpoch)
void	appendDecimal(BigDecimal d)
void	appendDouble(double d)
void	appendFloat(float f)
void	appendInt(int i)
void	appendLong(long l)
void	appendNull()
void	appendNumeric(long l)
void	appendShort(short s)
void	appendString(String str)
void	appendTimestamp(long microsSinceEpoch)
void	appendTimestampLtz(long microsSinceEpoch)
void	appendVariant(BinaryVariant v)
BinaryVariant	build()
void	finishWritingArray(int start, ArrayList<Integer> offsets)
void	finishWritingObject(int start, ArrayList<BinaryVariantInternalBuilder.FieldEntry> fields)
int	getWritePos()
static BinaryVariant	parseJson(String json, boolean allowDuplicateKeys)	Parse a JSON string as a Variant value.

Methods inherited from class java.lang.Object

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

Field Detail

VARIANT_SIZE_LIMIT_EXCEPTION

public static final VariantTypeException VARIANT_SIZE_LIMIT_EXCEPTION

VARIANT_DUPLICATE_KEY_EXCEPTION

public static final VariantTypeException VARIANT_DUPLICATE_KEY_EXCEPTION

Constructor Detail

BinaryVariantInternalBuilder

public BinaryVariantInternalBuilder(boolean allowDuplicateKeys)

Method Detail

parseJson

public static BinaryVariant parseJson(String json,
                                      boolean allowDuplicateKeys)
                               throws IOException

Parse a JSON string as a Variant value.

Throws:

IOException - if any JSON parsing error happens.

build

public BinaryVariant build()

appendString

public void appendString(String str)

appendNull

public void appendNull()

appendBoolean

public void appendBoolean(boolean b)

appendByte

public void appendByte(byte b)

appendShort

public void appendShort(short s)

appendInt

public void appendInt(int i)

appendLong

public void appendLong(long l)

appendNumeric

public void appendNumeric(long l)

appendDouble

public void appendDouble(double d)

appendDecimal

public void appendDecimal(BigDecimal d)

appendDate

public void appendDate(int daysSinceEpoch)

appendTimestampLtz

public void appendTimestampLtz(long microsSinceEpoch)

appendTimestamp

public void appendTimestamp(long microsSinceEpoch)

appendFloat

public void appendFloat(float f)

appendBinary

public void appendBinary(byte[] binary)

addKey

public int addKey(String key)

getWritePos

public int getWritePos()

finishWritingObject

public void finishWritingObject(int start,
                                ArrayList<BinaryVariantInternalBuilder.FieldEntry> fields)

finishWritingArray

public void finishWritingArray(int start,
                               ArrayList<Integer> offsets)

appendVariant

public void appendVariant(BinaryVariant v)