com.yahoo.bullet.dsl.converter

Class JSONBulletRecordConverter

java.lang.Object

com.yahoo.bullet.dsl.converter.BulletRecordConverter

com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

com.yahoo.bullet.dsl.converter.JSONBulletRecordConverter

All Implemented Interfaces:

Serializable

public class JSONBulletRecordConverter
extends MapBulletRecordConverter

JSONBulletRecordConverter is used to convert String JSON to BulletRecord instances. The JSON must be an object containing the fields of the record.

If a schema is not specified, numeric types will default to Double. If a schema is provided, the appropriate specified types will be used.

See Also:

Serialized Form

Field Summary

Fields inherited from class com.yahoo.bullet.dsl.converter.BulletRecordConverter

config, schema, shouldTypeCheck

Constructor Summary

Constructors

Constructor and Description
JSONBulletRecordConverter() Constructs a JSONBulletRecordConverter without a schema.
JSONBulletRecordConverter(com.yahoo.bullet.common.BulletConfig bulletConfig) Constructs a JSONBulletRecordConverter from a given configuration.
JSONBulletRecordConverter(String schema) Constructs a JSONBulletRecordConverter from a given schema.

Method Summary

Modifier and Type	Method and Description
com.yahoo.bullet.record.BulletRecord	convert(Object object, com.yahoo.bullet.record.BulletRecord record) Converts an object to a BulletRecord using the given record.
protected com.yahoo.bullet.typesystem.TypedObject	getTypedObject(String name, com.yahoo.bullet.typesystem.Type type, Serializable value) Converts the field value with the given name and expected type into a TypedObject.

Methods inherited from class com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

get

Methods inherited from class com.yahoo.bullet.dsl.converter.BulletRecordConverter

build, convert, flattenMap, from, getField, setField

Methods inherited from class java.lang.Object

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

Constructor Detail

JSONBulletRecordConverter

public JSONBulletRecordConverter()
                          throws BulletDSLException

Constructs a JSONBulletRecordConverter without a schema.

Throws:

BulletDSLException - if there is an error creating the converter.

JSONBulletRecordConverter

public JSONBulletRecordConverter(String schema)
                          throws BulletDSLException

Constructs a JSONBulletRecordConverter from a given schema.

Parameters:

schema - A schema file that specifies the fields to extract and their types.

Throws:

BulletDSLException - if there is an error creating the converter.

JSONBulletRecordConverter

public JSONBulletRecordConverter(com.yahoo.bullet.common.BulletConfig bulletConfig)
                          throws BulletDSLException

Constructs a JSONBulletRecordConverter from a given configuration.

Parameters:

bulletConfig - The configuration that specifies the settings for a JSONBulletRecordConverter.

Throws:

BulletDSLException - if there is an error creating the converter.

Method Detail

convert

public com.yahoo.bullet.record.BulletRecord convert(Object object,
                                                    com.yahoo.bullet.record.BulletRecord record)
                                             throws BulletDSLException

Description copied from class: BulletRecordConverter

Converts an object to a BulletRecord using the given record. The default implementation assumes a valid schema.

Overrides:

convert in class MapBulletRecordConverter

Parameters:

object - The object to be converted.

record - The record to insert fields into.

Returns:

The record with additional fields from object.

Throws:

BulletDSLException - if there is an error converting the object to a BulletRecord.

getTypedObject

protected com.yahoo.bullet.typesystem.TypedObject getTypedObject(String name,
                                                                 com.yahoo.bullet.typesystem.Type type,
                                                                 Serializable value)

Description copied from class: BulletRecordConverter

Converts the field value with the given name and expected type into a TypedObject. If type checking is enabled, it will check to make sure that the expected type matches the final type in the TypedObject. This method is only used for non-record fields.

Overrides:

getTypedObject in class BulletRecordConverter

Parameters:

name - The name of the field.

type - The expected type of the field.

value - The Serializable value of the field.

Returns:

A TypedObject wrapping the value.