### Question:
Scrolling { Scrolling(ElasticsearchTransport transport) { this.transport = Objects.requireNonNull(transport, "transport"); final int fetchSize = transport.fetchSize; Preconditions.checkArgument(fetchSize > 0, "invalid fetch size. Expected %s > 0", fetchSize); this.fetchSize = fetchSize; } Scrolling(ElasticsearchTransport transport);   }### Answer:
@Disabled("It seems like other tests leave scrolls behind, so this test fails if executed after" + " one of the other elasticsearch test") @Test void scrolling() throws Exception { final String[] expected = IntStream.range(0, SIZE).mapToObj(i -> "V=" + i) .toArray(String[]::new); final String query = String.format(Locale.ROOT, "select _MAP['value'] as v from " + "\"elastic\".\"%s\"", NAME); for (int fetchSize: Arrays.asList(1, 2, 3, SIZE / 2, SIZE - 1, SIZE, SIZE + 1, 2 * SIZE)) { CalciteAssert.that() .with(newConnectionFactory(fetchSize)) .query(query) .returnsUnordered(expected); assertNoActiveScrolls(); } }