Constructor and Description |
---|
SingleDimensionShardSpec() |
SingleDimensionShardSpec(String dimension,
String start,
String end,
int partitionNum) |
Modifier and Type | Method and Description |
---|---|
<T> PartitionChunk<T> |
createChunk(T obj) |
String |
getDimension() |
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() |
public String getDimension()
public void setDimension(String dimension)
public String getStart()
public void setStart(String start)
public String getEnd()
public void setEnd(String end)
public int getPartitionNum()
getPartitionNum
in interface ShardSpec
public ShardSpecLookup getLookup(List<ShardSpec> shardSpecs)
public void setPartitionNum(int partitionNum)
public <T> PartitionChunk<T> createChunk(T obj)
createChunk
in interface ShardSpec
public boolean isInChunk(long timestamp, InputRow inputRow)
Copyright © 2011–2016. All rights reserved.