Output the shard's start and end timestamps on String().
parent
ef92908983
commit
fe10d5b1b0
|
@ -292,7 +292,7 @@ func (self *ShardData) String() string {
|
|||
local = "true"
|
||||
}
|
||||
|
||||
return fmt.Sprintf("[ID: %d, LOCAL: %s, SERVERS: [%s]]", self.id, local, strings.Join(serversString, ","))
|
||||
return fmt.Sprintf("[ID: %d, START: %d, END: %d, LOCAL: %s, SERVERS: [%s]]", self.id, self.startMicro, self.endMicro, local, strings.Join(serversString, ","))
|
||||
}
|
||||
|
||||
func (self *ShardData) ShouldAggregateLocally(querySpec *parser.QuerySpec) bool {
|
||||
|
|
Loading…
Reference in New Issue