Skip to content

Commit

Permalink
fixed detekt errors
Browse files Browse the repository at this point in the history
Signed-off-by: Ronnak Saxena <[email protected]>
  • Loading branch information
ronnaksaxena committed Sep 5, 2023
1 parent b145ecf commit a9c6369
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -123,6 +123,7 @@ class ResponseInterceptor(
}

// Calculated the end time for the current shard index if it is a rollup index with data overlapp
@Suppress("SpreadOperator")
fun getRollupEndTime(liveDataStartPoint: Long, rollupIndices: Array<String>, dateTargetField: String): Long {
// Build search request to find the maximum rollup timestamp <= liveDataStartPoint
val sort = SortBuilders.fieldSort("$dateTargetField.date_histogram").order(SortOrder.DESC)
Expand Down Expand Up @@ -163,7 +164,7 @@ class ResponseInterceptor(

// Returns Pair(startRange: Long, endRange: Long)
// Note startRange is inclusive and endRange is exclusive, they are Longs because the type is epoch milliseconds
@Suppress("LongMethod")
@Suppress("LongMethod", "SpreadOperator")
fun findOverlap(response: QuerySearchResult): Pair<Long, Long> {
val job: Rollup = getRollupJob(response)!! // maybe throw a try catch later
var dateSourceField: String = ""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -182,7 +182,7 @@ class RollupInterceptor(
return
}

@Suppress("SpreadOperator")
@Suppress("SpreadOperator", "NestedBlockDepth")
override fun <T : TransportRequest> interceptHandler(
action: String,
executor: String,
Expand Down

0 comments on commit a9c6369

Please sign in to comment.