Package org.apache.spark.types.variant

Class VariantBuilder

Object

org.apache.spark.types.variant.VariantBuilder

public class VariantBuilder
extends Object

Build variant value and metadata by parsing JSON values.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	VariantBuilder.FieldEntry

Constructor Summary

Constructors

Constructor	Description
VariantBuilder(boolean allowDuplicateKeys)

Method Summary

Modifier and Type	Method	Description
int	addKey(String key)
void	appendBinary(byte[] binary)
void	appendBoolean(boolean b)
void	appendDate(int daysSinceEpoch)
void	appendDayTimeInterval(long value, byte startField, byte endField)
void	appendDecimal(BigDecimal d)
void	appendDouble(double d)
void	appendFloat(float f)
void	appendLong(long l)
void	appendNull()
void	appendString(String str)
void	appendTimestamp(long microsSinceEpoch)
void	appendTimestampNtz(long microsSinceEpoch)
void	appendVariant(Variant v)
void	appendYearMonthInterval(long value, byte startField, byte endField)
void	finishWritingArray(int start, ArrayList<Integer> offsets)
void	finishWritingObject(int start, ArrayList<VariantBuilder.FieldEntry> fields)
int	getWritePos()
static Variant	parseJson(com.fasterxml.jackson.core.JsonParser parser, boolean allowDuplicateKeys)	Similar parseJson(String, boolean), but takes a JSON parser instead of string input.
static Variant	parseJson(String json, boolean allowDuplicateKeys)	Parse a JSON string as a Variant value.
Variant	result()

Methods inherited from class java.lang.Object

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

Constructor Details

VariantBuilder

public VariantBuilder(boolean allowDuplicateKeys)

Method Details

parseJson

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

Parse a JSON string as a Variant value.

Throws:

VariantSizeLimitException - if the resulting variant value or metadata would exceed the SIZE_LIMIT (for example, this could be a maximum of 16 MiB).

IOException - if any JSON parsing error happens.

parseJson

public static Variant parseJson(com.fasterxml.jackson.core.JsonParser parser,
 boolean allowDuplicateKeys)
                         throws IOException

Similar parseJson(String, boolean), but takes a JSON parser instead of string input.

Throws:

IOException

result

public Variant result()

appendString

public void appendString(String str)

appendNull

public void appendNull()

appendBoolean

public void appendBoolean(boolean b)

appendLong

public void appendLong(long l)

appendDouble

public void appendDouble(double d)

appendDecimal

public void appendDecimal(BigDecimal d)

appendDate

public void appendDate(int daysSinceEpoch)

appendTimestamp

public void appendTimestamp(long microsSinceEpoch)

appendTimestampNtz

public void appendTimestampNtz(long microsSinceEpoch)

appendYearMonthInterval

public void appendYearMonthInterval(long value,
 byte startField,
 byte endField)

appendDayTimeInterval

public void appendDayTimeInterval(long value,
 byte startField,
 byte endField)

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<VariantBuilder.FieldEntry> fields)

finishWritingArray

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

appendVariant

public void appendVariant(Variant v)