io.druid.segment.realtime.appenderator

Class SinkQuerySegmentWalker

java.lang.Object

io.druid.segment.realtime.appenderator.SinkQuerySegmentWalker

All Implemented Interfaces:

QuerySegmentWalker

public class SinkQuerySegmentWalker
extends Object
implements QuerySegmentWalker

Constructor Summary

Constructors

Constructor and Description
SinkQuerySegmentWalker(String dataSource, VersionedIntervalTimeline<String,Sink> sinkTimeline, com.fasterxml.jackson.databind.ObjectMapper objectMapper, com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, ExecutorService queryExecutorService, Cache cache, CacheConfig cacheConfig)

Method Summary

Modifier and Type	Method and Description
<T> QueryRunner<T>	getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals) Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.
<T> QueryRunner<T>	getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs) Gets the Queryable for a given list of SegmentSpecs.
static String	makeHydrantCacheIdentifier(FireHydrant input)

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkQuerySegmentWalker

public SinkQuerySegmentWalker(String dataSource,
                              VersionedIntervalTimeline<String,Sink> sinkTimeline,
                              com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                              com.metamx.emitter.service.ServiceEmitter emitter,
                              QueryRunnerFactoryConglomerate conglomerate,
                              ExecutorService queryExecutorService,
                              Cache cache,
                              CacheConfig cacheConfig)

Method Detail

getQueryRunnerForIntervals

public <T> QueryRunner<T> getQueryRunnerForIntervals(Query<T> query,
                                                     Iterable<org.joda.time.Interval> intervals)

Description copied from interface: QuerySegmentWalker

Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.

Specified by:

getQueryRunnerForIntervals in interface QuerySegmentWalker

Type Parameters:

T - query result type

Parameters:

query - the query to find a Queryable for

intervals - the intervals to find a Queryable for

Returns:

a Queryable object that represents the interval

getQueryRunnerForSegments

public <T> QueryRunner<T> getQueryRunnerForSegments(Query<T> query,
                                                    Iterable<SegmentDescriptor> specs)

Description copied from interface: QuerySegmentWalker

Gets the Queryable for a given list of SegmentSpecs.

Specified by:

getQueryRunnerForSegments in interface QuerySegmentWalker

Type Parameters:

T - the query result type

Parameters:

query - the query to return a Queryable for

specs - the list of SegmentSpecs to find a Queryable for

Returns:

the Queryable object with the given SegmentSpecs

makeHydrantCacheIdentifier

public static String makeHydrantCacheIdentifier(FireHydrant input)