Package org.apache.druid.data.input.impl

Class MapInputRowParser

java.lang.Object

org.apache.druid.data.input.impl.MapInputRowParser

public class MapInputRowParser
extends Object

Method Summary

Modifier and Type	Method	Description
static List<String>	findDimensions(TimestampSpec timestampSpec, DimensionsSpec dimensionsSpec, Set<String> fields)	Finds the final set of dimension names to use for InputRow.
static InputRow	parse(TimestampSpec timestampSpec, List<String> dimensions, Map<String,Object> theMap)
static InputRow	parse(InputRowSchema inputRowSchema, Map<String,Object> theMap)
static org.joda.time.DateTime	parseTimestamp(TimestampSpec timestampSpec, Map<String,Object> theMap)
static org.joda.time.DateTime	parseTimestampOrThrowParseException(Object timeValue, TimestampSpec timestampSpec, Supplier<Map<String,?>> rawMapSupplier)	Given a plain Java Object, extract a timestamp from it using the provided TimestampSpec, or throw a ParseException if we can't.

Methods inherited from class java.lang.Object

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

Method Details

parse

public static InputRow parse(InputRowSchema inputRowSchema,
 Map<String,Object> theMap)
                      throws ParseException

Throws:

ParseException

parse

public static InputRow parse(TimestampSpec timestampSpec,
 List<String> dimensions,
 Map<String,Object> theMap)
                      throws ParseException

Throws:

ParseException

findDimensions

public static List<String> findDimensions(TimestampSpec timestampSpec,
 DimensionsSpec dimensionsSpec,
 Set<String> fields)

Finds the final set of dimension names to use for InputRow. There are 3 cases here. 1) If DimensionsSpec.isIncludeAllDimensions() is set, the returned list includes _both_ DimensionsSpec.getDimensionNames() and the dimensions in the given map (rawInputRow#keySet()). 2) If isIncludeAllDimensions is not set and DimensionsSpec.getDimensionNames() is not empty, the dimensions in dimensionsSpec is returned. 3) If isIncludeAllDimensions is not set and DimensionsSpec.getDimensionNames() is empty, the dimensions in the given map is returned. In any case, the returned list does not include any dimensions in DimensionsSpec.getDimensionExclusions() or TimestampSpec.getTimestampColumn().

parseTimestamp

public static org.joda.time.DateTime parseTimestamp(TimestampSpec timestampSpec,
 Map<String,Object> theMap)

parseTimestampOrThrowParseException

public static org.joda.time.DateTime parseTimestampOrThrowParseException(Object timeValue,
 TimestampSpec timestampSpec,
 Supplier<Map<String,?>> rawMapSupplier)

Given a plain Java Object, extract a timestamp from it using the provided TimestampSpec, or throw a ParseException if we can't.

Parameters:

timeValue - object to interpret as timestmap

timestampSpec - timestamp spec

rawMapSupplier - supplier of the original raw data that this object came from. Used for error messages.