com.yahoo.bullet.dsl.converter

Class MapBulletRecordConverter

java.lang.Object

com.yahoo.bullet.dsl.converter.BulletRecordConverter

com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

JSONBulletRecordConverter

public class MapBulletRecordConverter
extends BulletRecordConverter

MapBulletRecordConverter is used to convert Map<String, Object> to BulletRecord.

If a schema is not specified, maps are effectively flattened without any regard to type-safety.

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
MapBulletRecordConverter() Constructs a MapBulletRecordConverter without a schema.
MapBulletRecordConverter(com.yahoo.bullet.common.BulletConfig bulletConfig) Constructs a MapBulletRecordConverter from a given configuration.
MapBulletRecordConverter(String schema) Constructs a MapBulletRecordConverter 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 Object	get(Object object, String base) Gets the specified top-level field from the object.

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

build, convert, flattenMap, from, getField, getTypedObject, setField

Methods inherited from class java.lang.Object

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

Constructor Detail

MapBulletRecordConverter

public MapBulletRecordConverter()
                         throws BulletDSLException

Constructs a MapBulletRecordConverter without a schema.

Throws:

BulletDSLException - if there is an error creating the converter.

MapBulletRecordConverter

public MapBulletRecordConverter(String schema)
                         throws BulletDSLException

Constructs a MapBulletRecordConverter 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.

MapBulletRecordConverter

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

Constructs a MapBulletRecordConverter from a given configuration.

Parameters:

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

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 BulletRecordConverter

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.

get

protected Object get(Object object,
                     String base)

Description copied from class: BulletRecordConverter

Gets the specified top-level field from the object.

Specified by:

get in class BulletRecordConverter

Parameters:

object - The object to get from.

base - The top-level field to get.

Returns:

The value of the specified top-level field from the object or null if it does not exist.