io.druid.timeline.partition

Interface ShardSpec

All Known Implementing Classes:

HashBasedNumberedShardSpec, LinearShardSpec, NoneShardSpec, NumberedShardSpec, SingleDimensionShardSpec

public interface ShardSpec

A Marker interface that exists to combine ShardSpec objects together for Jackson. Note that this is not an extension API. Extensions are not expected to create new kinds of ShardSpecs.

Method Summary

Modifier and Type	Method and Description
<T> PartitionChunk<T>	createChunk(T obj)
Map<String,com.google.common.collect.Range<String>>	getDomain() Get the possible range of each dimension for the rows this shard contains.
ShardSpecLookup	getLookup(List<ShardSpec> shardSpecs)
int	getPartitionNum()
boolean	isInChunk(long timestamp, InputRow inputRow)

Method Detail

createChunk

<T> PartitionChunk<T> createChunk(T obj)

isInChunk

boolean isInChunk(long timestamp,
                  InputRow inputRow)

getPartitionNum

int getPartitionNum()

getLookup

ShardSpecLookup getLookup(List<ShardSpec> shardSpecs)

getDomain

Map<String,com.google.common.collect.Range<String>> getDomain()

Get the possible range of each dimension for the rows this shard contains.

Returns:

map of dimensions to its possible range. Dimensions with unknown possible range are not mapped