Method run

core/src/main/java/io/questdb/tasks/LatestByTask.java:104–130

()

    }

    public boolean run() {
        try {
            if (!circuitBreaker.checkIfTripped()) {
                GeoHashNative.latestByAndFilterPrefix(
                        frameMemoryPool,
                        keyBaseAddress,
                        keysMemorySize,
                        valueBaseAddress,
                        valuesMemorySize,
                        argsAddress,
                        unIndexedNullCount,
                        rowHi,
                        rowLo,
                        frameIndex,
                        valueBlockCapacity,
                        hashColumnIndex,
                        hashColumnType,
                        prefixesAddress,
                        prefixesCount
                );
            }
            doneLatch.countDown();
            return true;
        } finally {
            frameMemoryPool.close();
        }
    }
}