public interface ShardSpec
Modifier and Type | Method and Description |
---|---|
<T> PartitionChunk<T> |
createChunk(T obj) |
ShardSpecLookup |
getLookup(List<ShardSpec> shardSpecs) |
int |
getPartitionNum() |
boolean |
isInChunk(long timestamp,
InputRow inputRow) |
<T> PartitionChunk<T> createChunk(T obj)
boolean isInChunk(long timestamp, InputRow inputRow)
int getPartitionNum()
ShardSpecLookup getLookup(List<ShardSpec> shardSpecs)
Copyright © 2011–2016. All rights reserved.