org.apache.paimon.benchmark

Class QueryRunner

java.lang.Object

org.apache.paimon.benchmark.QueryRunner

public class QueryRunner
extends Object

Runner of a single benchmark query.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueryRunner.Result Result metric of the current query.

Constructor Summary

Constructors

Constructor and Description
QueryRunner(Query query, Sink sink, Path flinkDist, FlinkRestClient flinkRestClient, CpuMetricReceiver cpuMetricReceiver, org.apache.flink.configuration.Configuration benchmarkConf)

Method Summary

Modifier and Type	Method and Description
QueryRunner.Result	run()
String	submitSQLJob(String sql)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryRunner

public QueryRunner(Query query,
                   Sink sink,
                   Path flinkDist,
                   FlinkRestClient flinkRestClient,
                   CpuMetricReceiver cpuMetricReceiver,
                   org.apache.flink.configuration.Configuration benchmarkConf)

Method Detail

run

public QueryRunner.Result run()

submitSQLJob

public String submitSQLJob(String sql)
                    throws IOException

Throws:

IOException