org.apache.calcite.adapter.druid

Class TimeExtractionFunction

java.lang.Object

org.apache.calcite.adapter.druid.TimeExtractionFunction

All Implemented Interfaces:

DruidJson, ExtractionFunction

public class TimeExtractionFunction
extends Object
implements ExtractionFunction

Implementation of Druid time format extraction function.

These functions return the dimension value formatted according to the given format string, time zone, and locale.

For __time dimension values, this formats the time value bucketed by the aggregation granularity.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ISO_TIME_FORMAT

Constructor Summary

Constructors

Constructor and Description
TimeExtractionFunction(String format, Granularity granularity, String timeZone, String local)

Method Summary

Modifier and Type	Method and Description
static TimeExtractionFunction	createDefault(String timeZone) Creates the default time format extraction function.
static TimeExtractionFunction	createExtractFromGranularity(Granularity granularity, String timeZone) Creates the time format extraction function for the given granularity.
static TimeExtractionFunction	createFloorFromGranularity(Granularity granularity, String timeZone) Creates time format floor time extraction function using a given granularity.
String	getFormat()
Granularity	getGranularity()
static boolean	isValidTimeExtract(RexNode rexNode) Returns whether the RexCall contains a valid extract unit that we can serialize to Druid.
static boolean	isValidTimeFloor(RexNode rexNode) Returns whether the RexCall contains a valid FLOOR unit that we can serialize to Druid.
static TimeExtractionFunction	translateCastToTimeExtract(RexNode rexNode, TimeZone timeZone)
void	write(com.fasterxml.jackson.core.JsonGenerator generator)

Methods inherited from class java.lang.Object

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

Field Detail

ISO_TIME_FORMAT

public static final String ISO_TIME_FORMAT

See Also:

Constant Field Values

Constructor Detail

TimeExtractionFunction

public TimeExtractionFunction(String format,
                              Granularity granularity,
                              String timeZone,
                              String local)

Method Detail

write

public void write(com.fasterxml.jackson.core.JsonGenerator generator)
           throws IOException

Specified by:

write in interface DruidJson

Throws:

IOException

getFormat

public String getFormat()

getGranularity

public Granularity getGranularity()

createDefault

public static TimeExtractionFunction createDefault(String timeZone)

Creates the default time format extraction function.

Returns:

the time extraction function

createExtractFromGranularity

public static TimeExtractionFunction createExtractFromGranularity(Granularity granularity,
                                                                  String timeZone)

Creates the time format extraction function for the given granularity.

Parameters:

granularity - granularity to apply to the column

Returns:

the time extraction function corresponding to the granularity input unit VALID_TIME_EXTRACT for supported granularity

createFloorFromGranularity

public static TimeExtractionFunction createFloorFromGranularity(Granularity granularity,
                                                                String timeZone)

Creates time format floor time extraction function using a given granularity.

Parameters:

granularity - granularity to apply to the column

Returns:

the time extraction function or null if granularity is not supported

isValidTimeExtract

public static boolean isValidTimeExtract(RexNode rexNode)

Returns whether the RexCall contains a valid extract unit that we can serialize to Druid.

Parameters:

rexNode - Extract expression

Returns:

true if the extract unit is valid

isValidTimeFloor

public static boolean isValidTimeFloor(RexNode rexNode)

Returns whether the RexCall contains a valid FLOOR unit that we can serialize to Druid.

Parameters:

rexNode - Extract expression

Returns:

true if the extract unit is valid

translateCastToTimeExtract

@Nullable
public static TimeExtractionFunction translateCastToTimeExtract(RexNode rexNode,
                                                                          TimeZone timeZone)

Parameters:

rexNode - cast RexNode

timeZone - timezone

Returns:

Druid Time extraction function or null when can not translate the cast.