Searched refs:rows (Results 1 – 6 of 6) sorted by relevance
40 session.query(sql) { rows -> in queryLastEntryTimestamp() method41 if (rows.size == 1) { in queryLastEntryTimestamp()42 rows.get(0).get("ts") as Long in queryLastEntryTimestamp()53 session.query(sql) { rows -> in queryToMonotonic() method54 require(rows.size == 1) in queryToMonotonic()55 rows.get(0).get("ts") as Long in queryToMonotonic()63 session.query(sql) { rows -> in queryToRealtime() method64 require(rows.size == 1) in queryToRealtime()65 rows.get(0).get("ts") as Long in queryToRealtime()
59 val rows = entryGroups[entryId]!! in <lambda>() constant60 val entry = buildTraceEntry(rows, realToMonotonicTimeOffsetNs) in <lambda>()83 return session.query(sql) { rows -> in <lambda>() method84 require(rows.size == 1) { "Expected one row with count of trace entries." } in <lambda>()85 rows.get(0).get("count(*)") as Long in <lambda>()100 rows: List<Row>, in <lambda>()103 val args = Args.build(rows) in <lambda>()
37 val rows = session.query(sql) in query() constant38 predicate(rows.toList()) in query()
43 input.query(getSqlQueryProtoLogMessages()) { rows -> in <lambda>() method45 rows.map { in <lambda>()
147 fun build(rows: List<Row>): Args { in build()149 rows.forEach { in build()
132 { rows -> in <lambda>() method133 require(rows.size == 1) in <lambda>()134 rows.get(0).get("COUNT(*)") as Long in <lambda>()179 { rows -> in <lambda>() method180 require(rows.size == 1) in <lambda>()181 rows.get(0).get("COUNT(*)") as Long in <lambda>()