com.yahoo.bard.webservice.metadata

Class SegmentIntervalsHashIdGenerator

java.lang.Object

com.yahoo.bard.webservice.metadata.SegmentIntervalsHashIdGenerator

All Implemented Interfaces:

QuerySigningService<Long>

public class SegmentIntervalsHashIdGenerator
extends Object
implements QuerySigningService<Long>

An implementation of the QuerySigningService that generates segment id for requested interval. It uses the sum of segment hashes to create a segment id.

Constructor Summary

Constructors

Constructor and Description
SegmentIntervalsHashIdGenerator(DataSourceMetadataService dataSourceMetadataService) Build a SegmentIntervalsHashIdGenerator that uses the raw simplified intervals of a druidAggregationQuery to create a segmentId.
SegmentIntervalsHashIdGenerator(DataSourceMetadataService dataSourceMetadataService, Map<Class,RequestedIntervalsFunction> requestedIntervalsQueryExtractionFunctions) Build a SegmentIntervalsHashIdGenerator that generates a segmentId using the provided signingFunctions.
SegmentIntervalsHashIdGenerator(PhysicalTableDictionary physicalTableDictionary, DataSourceMetadataService dataSourceMetadataService) Deprecated. phyiscalTableDictionary is not used
SegmentIntervalsHashIdGenerator(PhysicalTableDictionary physicalTableDictionary, DataSourceMetadataService dataSourceMetadataService, Map<Class,RequestedIntervalsFunction> requestedIntervalsQueryExtractionFunctions) Deprecated. phyiscalTableDictionary is not used

Method Summary

Modifier and Type	Method and Description
Optional<Long>	getSegmentHash(Stream<SortedMap<org.joda.time.DateTime,Map<String,SegmentInfo>>> requestedSegments) Given a set of requested segments, calculate a hash to represent the segment set Id.
Optional<Long>	getSegmentSetId(DruidAggregationQuery<?> query) Return an identifier that corresponds to the set of segments that a query references.

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentIntervalsHashIdGenerator

@Deprecated
public SegmentIntervalsHashIdGenerator(PhysicalTableDictionary physicalTableDictionary,
                                                   DataSourceMetadataService dataSourceMetadataService,
                                                   Map<Class,RequestedIntervalsFunction> requestedIntervalsQueryExtractionFunctions)

Deprecated. phyiscalTableDictionary is not used

Build a SegmentIntervalsHashIdGenerator that generates a segmentId using the provided signingFunctions.

Parameters:

physicalTableDictionary - The dictionary of the physical tables

dataSourceMetadataService - A Service to get information about segment metadata

requestedIntervalsQueryExtractionFunctions - Maps a Class to the Function that should be used to compute requestedIntervals for a given query

SegmentIntervalsHashIdGenerator

public SegmentIntervalsHashIdGenerator(DataSourceMetadataService dataSourceMetadataService,
                                       Map<Class,RequestedIntervalsFunction> requestedIntervalsQueryExtractionFunctions)

Build a SegmentIntervalsHashIdGenerator that generates a segmentId using the provided signingFunctions.

Parameters:

dataSourceMetadataService - A Service to get information about segment metadata

requestedIntervalsQueryExtractionFunctions - Maps a Class to the Function that should be used to compute requestedIntervals for a given query

SegmentIntervalsHashIdGenerator

@Deprecated
public SegmentIntervalsHashIdGenerator(PhysicalTableDictionary physicalTableDictionary,
                                                   DataSourceMetadataService dataSourceMetadataService)

Deprecated. phyiscalTableDictionary is not used

Build a SegmentIntervalsHashIdGenerator that uses the raw simplified intervals of a druidAggregationQuery to create a segmentId.

Parameters:

physicalTableDictionary - The dictionary of the physical tables

dataSourceMetadataService - A Service to get information about segment metadata

SegmentIntervalsHashIdGenerator

public SegmentIntervalsHashIdGenerator(DataSourceMetadataService dataSourceMetadataService)

Build a SegmentIntervalsHashIdGenerator that uses the raw simplified intervals of a druidAggregationQuery to create a segmentId.

Parameters:

dataSourceMetadataService - A Service to get information about segment metadata

Method Detail

getSegmentSetId

public Optional<Long> getSegmentSetId(DruidAggregationQuery<?> query)

Description copied from interface: QuerySigningService

Return an identifier that corresponds to the set of segments that a query references.

Specified by:

getSegmentSetId in interface QuerySigningService<Long>

Parameters:

query - The druid aggregation query.

Returns:

An optional that identifies the set of segments referenced by this query. The optional is empty if no segment information was available for this query.

getSegmentHash

public Optional<Long> getSegmentHash(Stream<SortedMap<org.joda.time.DateTime,Map<String,SegmentInfo>>> requestedSegments)

Given a set of requested segments, calculate a hash to represent the segment set Id.

Parameters:

requestedSegments - A set of requestedSegments

Returns:

A hash of the given segments