com.yahoo.bard.webservice.data.dimension

Class AvroDimensionRowParser

java.lang.Object

com.yahoo.bard.webservice.data.dimension.AvroDimensionRowParser

public class AvroDimensionRowParser
extends Object

Parses an AVRO file into Dimension Rows.

Constructor Summary

Constructors

Constructor and Description
AvroDimensionRowParser(DimensionFieldNameMapper dimensionFieldNameMapper) Constructs an AvroDimensionRowParser object based on the DimensionFieldNameMapper object.

Method Summary

Modifier and Type	Method and Description
Set<DimensionRow>	parseAvroFileDimensionRows(Dimension dimension, String avroFilePath) Parses the avro file and returns the dimension rows.
void	parseAvroFileDimensionRows(Dimension dimension, String avroFilePath, Consumer<DimensionRow> consumer) Parses the avro file and sends dimension rows to a consumer.

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroDimensionRowParser

public AvroDimensionRowParser(DimensionFieldNameMapper dimensionFieldNameMapper)

Constructs an AvroDimensionRowParser object based on the DimensionFieldNameMapper object.

Parameters:

dimensionFieldNameMapper - Object that defines the dimension field name transformations

Method Detail

parseAvroFileDimensionRows

public void parseAvroFileDimensionRows(Dimension dimension,
                                       String avroFilePath,
                                       Consumer<DimensionRow> consumer)
                                throws IllegalArgumentException

Parses the avro file and sends dimension rows to a consumer.

Parameters:

dimension - The dimension object used to configure the dimension

avroFilePath - The path of the AVRO data file (.avro)

consumer - A consumer to process records from the avro file

Throws:

IllegalArgumentException - thrown if JSON object `fields` is not present

parseAvroFileDimensionRows

public Set<DimensionRow> parseAvroFileDimensionRows(Dimension dimension,
                                                    String avroFilePath)
                                             throws IllegalArgumentException

Parses the avro file and returns the dimension rows.

Parameters:

dimension - The dimension object used to configure the dimension

avroFilePath - The path of the AVRO data file (.avro)

Returns:

A set of dimension rows

Throws:

IllegalArgumentException - thrown if JSON object `fields` is not present