public class NumberedShardSpec extends Object implements ShardSpec
partitionNum
and partitions
, which represent the unique id of a partition and the number of core
partitions, respectively. partitions
simply indicates that the atomic update is regarded as completed when
partitions
partitions are successfully updated, and partitionNum
can go beyond it when some types
of index tasks are trying to append to existing partitions.Constructor and Description |
---|
NumberedShardSpec(int partitionNum,
int partitions) |
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() |
int |
getPartitions() |
boolean |
isInChunk(long timestamp,
InputRow inputRow) |
String |
toString() |
public int getPartitionNum()
getPartitionNum
in interface ShardSpec
public ShardSpecLookup getLookup(List<ShardSpec> shardSpecs)
public Map<String,com.google.common.collect.Range<String>> getDomain()
ShardSpec
public int getPartitions()
public <T> PartitionChunk<T> createChunk(T obj)
createChunk
in interface ShardSpec
public boolean isInChunk(long timestamp, InputRow inputRow)
Copyright © 2011–2018. All rights reserved.