This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
commit d7662df2dbc4a643ef5cbc149a3466933f568a30 Author: JingsongLi <[email protected]> AuthorDate: Fri Mar 17 12:00:59 2023 +0800 [core] Rename paimon benchmark --- .../paimon-cluster-benchmark}/README.md | 0 .../paimon-cluster-benchmark}/pom.xml | 0 .../src/main/assemblies/bin.xml | 0 .../java/org/apache/paimon}/benchmark/Benchmark.java | 12 ++++++------ .../org/apache/paimon}/benchmark/BenchmarkOptions.java | 2 +- .../main/java/org/apache/paimon}/benchmark/Query.java | 5 +++-- .../java/org/apache/paimon}/benchmark/QueryRunner.java | 16 ++++++++-------- .../src/main/java/org/apache/paimon}/benchmark/Sink.java | 4 ++-- .../apache/paimon}/benchmark/metric/BenchmarkMetric.java | 9 ++++----- .../apache/paimon}/benchmark/metric/FlinkRestClient.java | 5 ++--- .../paimon}/benchmark/metric/JobBenchmarkMetric.java | 4 ++-- .../apache/paimon}/benchmark/metric/MetricReporter.java | 4 ++-- .../apache/paimon}/benchmark/metric/cpu/CpuMetric.java | 6 +++--- .../paimon}/benchmark/metric/cpu/CpuMetricReceiver.java | 6 +++--- .../paimon}/benchmark/metric/cpu/CpuMetricSender.java | 10 +++++----- .../paimon}/benchmark/metric/cpu/CpuTimeTracker.java | 2 +- .../paimon}/benchmark/metric/cpu/OperatingSystem.java | 2 +- .../benchmark/metric/cpu/ProcfsBasedProcessTree.java | 7 +++---- .../benchmark/metric/cpu/ShellCommandExecutor.java | 2 +- .../paimon}/benchmark/metric/cpu/SysInfoLinux.java | 2 +- .../apache/paimon}/benchmark/metric/cpu/clock/Clock.java | 2 +- .../paimon}/benchmark/metric/cpu/clock/SystemClock.java | 2 +- .../paimon}/benchmark/utils/AutoClosableProcess.java | 2 +- .../benchmark/utils/BenchmarkGlobalConfiguration.java | 2 +- .../apache/paimon}/benchmark/utils/BenchmarkUtils.java | 2 +- .../src/main/resources/bin/config.sh | 0 .../src/main/resources/bin/metric_client.sh | 0 .../src/main/resources/bin/run_benchmark.sh | 0 .../src/main/resources/bin/setup_cluster.sh | 0 .../src/main/resources/bin/shutdown_cluster.sh | 0 .../src/main/resources/conf/benchmark.yaml | 0 .../src/main/resources/conf/log4j.properties | 0 .../src/main/resources/queries/q1.sql | 0 .../src/main/resources/queries/queries.yaml | 0 .../src/main/resources/sinks/table_store.yaml | 0 .../paimon-micro-benchmarks}/pom.xml | 0 .../java/org/apache/paimon}/benchmark/Benchmark.java | 2 +- .../org/apache/paimon}/benchmark/TableBenchmark.java | 2 +- .../apache/paimon}/benchmark/TableWriterBenchmark.java | 2 +- .../src/test/resources/log4j2-test.properties | 0 .../pom.xml | 4 ++-- pom.xml | 2 +- 42 files changed, 59 insertions(+), 61 deletions(-) diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/README.md b/paimon-benchmark/paimon-cluster-benchmark/README.md similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/README.md rename to paimon-benchmark/paimon-cluster-benchmark/README.md diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/pom.xml b/paimon-benchmark/paimon-cluster-benchmark/pom.xml similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/pom.xml rename to paimon-benchmark/paimon-cluster-benchmark/pom.xml diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/assemblies/bin.xml b/paimon-benchmark/paimon-cluster-benchmark/src/main/assemblies/bin.xml similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/assemblies/bin.xml rename to paimon-benchmark/paimon-cluster-benchmark/src/main/assemblies/bin.xml diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Benchmark.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java similarity index 95% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Benchmark.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java index 3634c5b12..efb4e70f2 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Benchmark.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java @@ -16,19 +16,19 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; import org.apache.flink.configuration.Configuration; -import org.apache.flink.table.store.benchmark.metric.FlinkRestClient; -import org.apache.flink.table.store.benchmark.metric.JobBenchmarkMetric; -import org.apache.flink.table.store.benchmark.metric.cpu.CpuMetricReceiver; -import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration; -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.DefaultParser; import org.apache.commons.cli.Option; import org.apache.commons.cli.Options; +import org.apache.paimon.benchmark.metric.FlinkRestClient; +import org.apache.paimon.benchmark.metric.JobBenchmarkMetric; +import org.apache.paimon.benchmark.metric.cpu.CpuMetricReceiver; +import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; import java.io.File; import java.nio.file.Path; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/BenchmarkOptions.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/BenchmarkOptions.java similarity index 98% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/BenchmarkOptions.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/BenchmarkOptions.java index 26ff9ab0b..fca5e5245 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/BenchmarkOptions.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/BenchmarkOptions.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigOptions; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Query.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Query.java similarity index 97% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Query.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Query.java index 12b2cf17c..a231257f3 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Query.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Query.java @@ -16,11 +16,12 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; import org.apache.flink.util.FileUtils; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; + import java.io.IOException; import java.nio.file.Path; import java.util.ArrayList; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/QueryRunner.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java similarity index 92% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/QueryRunner.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java index 7ae2605fb..e1784ccec 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/QueryRunner.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java @@ -16,18 +16,18 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; import org.apache.flink.configuration.Configuration; import org.apache.flink.core.fs.FileSystem; -import org.apache.flink.table.store.benchmark.metric.FlinkRestClient; -import org.apache.flink.table.store.benchmark.metric.JobBenchmarkMetric; -import org.apache.flink.table.store.benchmark.metric.MetricReporter; -import org.apache.flink.table.store.benchmark.metric.cpu.CpuMetricReceiver; -import org.apache.flink.table.store.benchmark.utils.AutoClosableProcess; -import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration; -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; +import org.apache.paimon.benchmark.metric.FlinkRestClient; +import org.apache.paimon.benchmark.metric.JobBenchmarkMetric; +import org.apache.paimon.benchmark.metric.MetricReporter; +import org.apache.paimon.benchmark.metric.cpu.CpuMetricReceiver; +import org.apache.paimon.benchmark.utils.AutoClosableProcess; +import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Sink.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java similarity index 95% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Sink.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java index 3d31c4e68..e633bb05d 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Sink.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java @@ -16,12 +16,12 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; import org.apache.flink.util.FileUtils; import org.apache.commons.io.FilenameUtils; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; import java.io.IOException; import java.nio.file.Files; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/BenchmarkMetric.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/BenchmarkMetric.java similarity index 88% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/BenchmarkMetric.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/BenchmarkMetric.java index 85f4dbb98..376fbe25b 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/BenchmarkMetric.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/BenchmarkMetric.java @@ -16,16 +16,15 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric; +package org.apache.paimon.benchmark.metric; -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; import javax.annotation.Nullable; /** - * Metric collected per {@link - * org.apache.flink.table.store.benchmark.BenchmarkOptions#METRIC_MONITOR_DURATION} for a single - * query. + * Metric collected per {@link org.apache.paimon.benchmark.BenchmarkOptions#METRIC_MONITOR_DURATION} + * for a single query. */ public class BenchmarkMetric { private final double rps; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/FlinkRestClient.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java similarity index 98% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/FlinkRestClient.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java index 73996324b..2a69e37dd 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/FlinkRestClient.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java @@ -16,9 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric; - -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; +package org.apache.paimon.benchmark.metric; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ArrayNode; @@ -37,6 +35,7 @@ import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.util.EntityUtils; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/JobBenchmarkMetric.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/JobBenchmarkMetric.java similarity index 95% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/JobBenchmarkMetric.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/JobBenchmarkMetric.java index 31572b627..1cf6abad3 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/JobBenchmarkMetric.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/JobBenchmarkMetric.java @@ -16,9 +16,9 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric; +package org.apache.paimon.benchmark.metric; -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; /** The aggregated result of a single benchmark query. */ public class JobBenchmarkMetric { diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/MetricReporter.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/MetricReporter.java similarity index 98% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/MetricReporter.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/MetricReporter.java index 53222bfa4..1fde549f2 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/MetricReporter.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/MetricReporter.java @@ -16,11 +16,11 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric; +package org.apache.paimon.benchmark.metric; import org.apache.flink.api.common.time.Deadline; -import org.apache.flink.table.store.benchmark.metric.cpu.CpuMetricReceiver; +import org.apache.paimon.benchmark.metric.cpu.CpuMetricReceiver; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetric.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetric.java similarity index 96% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetric.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetric.java index 1b878bc1e..bd8cb4ca4 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetric.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetric.java @@ -16,9 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; - -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; +package org.apache.paimon.benchmark.metric.cpu; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonCreator; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonIgnore; @@ -28,6 +26,8 @@ import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonProcessin import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ArrayNode; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; + import javax.annotation.Nullable; import java.util.ArrayList; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricReceiver.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricReceiver.java similarity index 96% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricReceiver.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricReceiver.java index 0b89836a6..947134fcc 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricReceiver.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricReceiver.java @@ -16,12 +16,12 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; +package org.apache.paimon.benchmark.metric.cpu; import org.apache.flink.configuration.Configuration; -import org.apache.flink.table.store.benchmark.BenchmarkOptions; -import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration; +import org.apache.paimon.benchmark.BenchmarkOptions; +import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricSender.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricSender.java similarity index 95% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricSender.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricSender.java index 0c461f26b..d8d6add04 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricSender.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricSender.java @@ -16,15 +16,15 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; +package org.apache.paimon.benchmark.metric.cpu; import org.apache.flink.configuration.Configuration; import org.apache.flink.runtime.net.ConnectionUtils; -import org.apache.flink.table.store.benchmark.BenchmarkOptions; -import org.apache.flink.table.store.benchmark.utils.AutoClosableProcess; -import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration; -import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils; +import org.apache.paimon.benchmark.BenchmarkOptions; +import org.apache.paimon.benchmark.utils.AutoClosableProcess; +import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration; +import org.apache.paimon.benchmark.utils.BenchmarkUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuTimeTracker.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuTimeTracker.java similarity index 98% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuTimeTracker.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuTimeTracker.java index 2580a620f..12e3d75f0 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuTimeTracker.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuTimeTracker.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; +package org.apache.paimon.benchmark.metric.cpu; import java.math.BigInteger; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/OperatingSystem.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/OperatingSystem.java similarity index 98% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/OperatingSystem.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/OperatingSystem.java index 490e02e0c..0e15ca154 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/OperatingSystem.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/OperatingSystem.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; +package org.apache.paimon.benchmark.metric.cpu; /** An enumeration indicating the operating system that the JVM runs on. */ public enum OperatingSystem { diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ProcfsBasedProcessTree.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java similarity index 99% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ProcfsBasedProcessTree.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java index d790e0f63..9e685dd64 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ProcfsBasedProcessTree.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java @@ -16,10 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; - -import org.apache.flink.table.store.benchmark.metric.cpu.clock.Clock; -import org.apache.flink.table.store.benchmark.metric.cpu.clock.SystemClock; +package org.apache.paimon.benchmark.metric.cpu; import org.apache.commons.io.IOUtils; import org.apache.commons.io.filefilter.AndFileFilter; @@ -27,6 +24,8 @@ import org.apache.commons.io.filefilter.DirectoryFileFilter; import org.apache.commons.io.filefilter.RegexFileFilter; import org.apache.commons.lang3.ArrayUtils; import org.apache.commons.lang3.StringUtils; +import org.apache.paimon.benchmark.metric.cpu.clock.Clock; +import org.apache.paimon.benchmark.metric.cpu.clock.SystemClock; import java.io.BufferedReader; import java.io.File; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ShellCommandExecutor.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ShellCommandExecutor.java similarity index 97% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ShellCommandExecutor.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ShellCommandExecutor.java index 74b8efebf..e3abc2d34 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ShellCommandExecutor.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ShellCommandExecutor.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; +package org.apache.paimon.benchmark.metric.cpu; import java.io.BufferedReader; import java.io.IOException; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/SysInfoLinux.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java similarity index 99% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/SysInfoLinux.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java index 493146b72..776377589 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/SysInfoLinux.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu; +package org.apache.paimon.benchmark.metric.cpu; import java.io.BufferedReader; import java.io.FileInputStream; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/Clock.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/Clock.java similarity index 96% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/Clock.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/Clock.java index 30fb8c341..a99c9ebee 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/Clock.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/Clock.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu.clock; +package org.apache.paimon.benchmark.metric.cpu.clock; /** * A clock that gives access to time. This clock returns two flavors of time: diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/SystemClock.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/SystemClock.java similarity index 96% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/SystemClock.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/SystemClock.java index 88b70f491..d6cec4caa 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/SystemClock.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/SystemClock.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.metric.cpu.clock; +package org.apache.paimon.benchmark.metric.cpu.clock; /** * A clock that returns the time of the system / process. diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/AutoClosableProcess.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java similarity index 99% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/AutoClosableProcess.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java index 254ed13c2..4f79d7085 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/AutoClosableProcess.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.utils; +package org.apache.paimon.benchmark.utils; import org.apache.flink.api.common.time.Deadline; import org.apache.flink.util.Preconditions; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkGlobalConfiguration.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkGlobalConfiguration.java similarity index 99% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkGlobalConfiguration.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkGlobalConfiguration.java index 3a38afcb2..6e3bc0ce9 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkGlobalConfiguration.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkGlobalConfiguration.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.utils; +package org.apache.paimon.benchmark.utils; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.IllegalConfigurationException; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkUtils.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkUtils.java similarity index 98% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkUtils.java rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkUtils.java index cba04d113..4dc832a61 100644 --- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkUtils.java +++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkUtils.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark.utils; +package org.apache.paimon.benchmark.utils; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.yaml.YAMLFactory; diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/config.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/config.sh similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/config.sh rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/config.sh diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/metric_client.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/metric_client.sh similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/metric_client.sh rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/metric_client.sh diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/run_benchmark.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/run_benchmark.sh similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/run_benchmark.sh rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/run_benchmark.sh diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/setup_cluster.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/setup_cluster.sh similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/setup_cluster.sh rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/setup_cluster.sh diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/benchmark.yaml b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/benchmark.yaml similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/benchmark.yaml rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/benchmark.yaml diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/log4j.properties b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/log4j.properties similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/log4j.properties rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/log4j.properties diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/q1.sql b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/q1.sql similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/q1.sql rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/q1.sql diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/queries.yaml b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/queries.yaml similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/queries.yaml rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/queries.yaml diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/sinks/table_store.yaml b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/sinks/table_store.yaml similarity index 100% rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/sinks/table_store.yaml rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/sinks/table_store.yaml diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/pom.xml b/paimon-benchmark/paimon-micro-benchmarks/pom.xml similarity index 100% rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/pom.xml rename to paimon-benchmark/paimon-micro-benchmarks/pom.xml diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/Benchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/Benchmark.java similarity index 99% rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/Benchmark.java rename to paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/Benchmark.java index accae9c03..38761e7b0 100644 --- a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/Benchmark.java +++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/Benchmark.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.SystemUtils; diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableBenchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableBenchmark.java similarity index 98% rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableBenchmark.java rename to paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableBenchmark.java index ab426a6bb..43206ace5 100644 --- a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableBenchmark.java +++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableBenchmark.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; import org.apache.flink.table.store.CoreOptions; import org.apache.flink.table.store.catalog.CatalogContext; diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableWriterBenchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java similarity index 99% rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableWriterBenchmark.java rename to paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java index 2e8611fdb..eaeacdc19 100644 --- a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableWriterBenchmark.java +++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.table.store.benchmark; +package org.apache.paimon.benchmark; import org.apache.flink.table.store.CoreOptions; import org.apache.flink.table.store.options.Options; diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/resources/log4j2-test.properties b/paimon-benchmark/paimon-micro-benchmarks/src/test/resources/log4j2-test.properties similarity index 100% rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/resources/log4j2-test.properties rename to paimon-benchmark/paimon-micro-benchmarks/src/test/resources/log4j2-test.properties diff --git a/flink-table-store-benchmark/pom.xml b/paimon-benchmark/pom.xml similarity index 93% rename from flink-table-store-benchmark/pom.xml rename to paimon-benchmark/pom.xml index d30a5d261..c5d6cdaab 100644 --- a/flink-table-store-benchmark/pom.xml +++ b/paimon-benchmark/pom.xml @@ -34,8 +34,8 @@ under the License. <packaging>pom</packaging> <modules> - <module>flink-table-store-cluster-benchmark</module> - <module>flink-table-store-micro-benchmarks</module> + <module>paimon-cluster-benchmark</module> + <module>paimon-micro-benchmarks</module> </modules> <properties> diff --git a/pom.xml b/pom.xml index e9dd516ed..8b042247b 100644 --- a/pom.xml +++ b/pom.xml @@ -52,7 +52,7 @@ under the License. </scm> <modules> - <module>flink-table-store-benchmark</module> + <module>paimon-benchmark</module> <module>flink-table-store-codegen</module> <module>flink-table-store-codegen-loader</module> <module>flink-table-store-common</module>
