io.druid.timeline.partition

Class SingleDimensionShardSpec

java.lang.Object

io.druid.timeline.partition.SingleDimensionShardSpec

All Implemented Interfaces:

ShardSpec

public class SingleDimensionShardSpec
extends Object
implements ShardSpec

Class uses getters/setters to work around http://jira.codehaus.org/browse/MSHADE-92 Adjust to JsonCreator and final fields when resolved.

Constructor Summary

Constructors

Constructor and Description
SingleDimensionShardSpec()
SingleDimensionShardSpec(String dimension, String start, String end, int partitionNum)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleDimensionShardSpec

public SingleDimensionShardSpec()

SingleDimensionShardSpec

public SingleDimensionShardSpec(String dimension,
                                String start,
                                String end,
                                int partitionNum)

Method Detail

getDimension

public String getDimension()

setDimension

public void setDimension(String dimension)

getStart

public String getStart()

setStart

public void setStart(String start)

getEnd

public String getEnd()

setEnd

public void setEnd(String end)

getPartitionNum

public int getPartitionNum()

Specified by:

getPartitionNum in interface ShardSpec

getLookup

public ShardSpecLookup getLookup(List<ShardSpec> shardSpecs)

Specified by:

getLookup in interface ShardSpec

getDomain

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

Description copied from interface: ShardSpec

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

Specified by:

getDomain in interface ShardSpec

Returns:

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

setPartitionNum

public void setPartitionNum(int partitionNum)

createChunk

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

Specified by:

createChunk in interface ShardSpec

isInChunk

public boolean isInChunk(long timestamp,
                         InputRow inputRow)

Specified by:

isInChunk in interface ShardSpec

toString

public String toString()

Overrides:

toString in class Object