fix(tsi1): make mergeable
parent
2c1f3e2987
commit
9bd6200f15
|
@ -65,6 +65,9 @@ func RunReportTsi(cmd *cobra.Command, args []string) error {
|
||||||
config := logger.NewConfig()
|
config := logger.NewConfig()
|
||||||
config.Level = zapcore.InfoLevel
|
config.Level = zapcore.InfoLevel
|
||||||
log, err := config.New(os.Stderr)
|
log, err := config.New(os.Stderr)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
// if path is unset, set to $HOME/.influxdbv2/engine"
|
// if path is unset, set to $HOME/.influxdbv2/engine"
|
||||||
if tsiFlags.Path == "" {
|
if tsiFlags.Path == "" {
|
||||||
|
|
|
@ -157,12 +157,6 @@ func (c *cardinality) cardinality() int64 {
|
||||||
return int64(c.set.Cardinality())
|
return int64(c.set.Cardinality())
|
||||||
}
|
}
|
||||||
|
|
||||||
type cardinalities []*cardinality
|
|
||||||
|
|
||||||
func (a cardinalities) Len() int { return len(a) }
|
|
||||||
func (a cardinalities) Less(i, j int) bool { return a[i].cardinality() < a[j].cardinality() }
|
|
||||||
func (a cardinalities) Swap(i, j int) { a[i], a[j] = a[j], a[i] }
|
|
||||||
|
|
||||||
func (report *ReportCommand) calculateCardinalities() error {
|
func (report *ReportCommand) calculateCardinalities() error {
|
||||||
idx := report.indexFile
|
idx := report.indexFile
|
||||||
itr, err := idx.MeasurementIterator()
|
itr, err := idx.MeasurementIterator()
|
||||||
|
|
Loading…
Reference in New Issue