object AccumuloUtils
- Alphabetic
- By Inheritance
- AccumuloUtils
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
def
addSplits[K](tableName: String, accumuloInstance: AccumuloInstance, keyBounds: KeyBounds[K], keyIndexer: KeyIndex[K], count: Int): Unit
Split the given Accumulo table into the given number of tablets.
Split the given Accumulo table into the given number of tablets. This should improve the ingest performance, as it will allow more than one tablet server to participate in the ingestion.
- tableName
The name of the table to be split
- accumuloInstance
The Accumulo instance associated with the ingest
- keyBounds
The KeyBounds of the RDD that is being stored in the table
- keyIndexer
The indexing scheme used to turn keys K into Accumulo keys
- count
The number of tablets to split the table into
-
def
getSplits[K](kb: KeyBounds[K], ki: KeyIndex[K], count: Int): Seq[BigInt]
Mapping KeyBounds of Extent to SFC ranges will often result in a set of non-contigrious ranges.
Mapping KeyBounds of Extent to SFC ranges will often result in a set of non-contigrious ranges. The indices exluded by these ranges should not be included in split calculation as they will never be seen.