public class QueryRunner extends Object
Modifier and Type | Class and Description |
---|---|
static class |
QueryRunner.Result
Result metric of the current query.
|
Constructor and Description |
---|
QueryRunner(Query query,
Sink sink,
Path flinkDist,
FlinkRestClient flinkRestClient,
CpuMetricReceiver cpuMetricReceiver,
org.apache.flink.configuration.Configuration benchmarkConf) |
Modifier and Type | Method and Description |
---|---|
QueryRunner.Result |
run() |
String |
submitSQLJob(String sql) |
public QueryRunner(Query query, Sink sink, Path flinkDist, FlinkRestClient flinkRestClient, CpuMetricReceiver cpuMetricReceiver, org.apache.flink.configuration.Configuration benchmarkConf)
public QueryRunner.Result run()
public String submitSQLJob(String sql) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.