Criterion benchmark for recordbatches_to_timeseries in
src/servers/src/prom_store.rs,
the function that turns a columnar RecordBatch into Prometheus TimeSeries.
Used to measure GreptimeTeam/greptimedb#8587
(perf(servers): optimize PromQL read conversion). Not part of the repository —
kept here so the numbers in the blog post are reproducible.
| CREATE DATABASE IF NOT EXISTS pushdown_demo; | |
| USE pushdown_demo; | |
| CREATE TABLE parent ( | |
| ts TIMESTAMP(3) TIME INDEX, | |
| k STRING, | |
| v DOUBLE, | |
| PRIMARY KEY (k) | |
| ) WITH ('compaction.type'='twcs'); | |
| CREATE TABLE child ( | |
| ts TIMESTAMP(3) TIME INDEX, |
| name | address-pr-comments |
|---|---|
| description | Read a GitHub PR's review comments, evaluate each one, fix trivial issues directly, plan moderate/complex fixes for user decision, and produce a summary report. |
| allowed-tools | Read, Grep, Glob, Bash(git *), Bash(gh *), Bash(cargo *), Bash(go *), Bash(npm *), Bash(make *), Bash(python *), Edit, Write, Agent |
Accept a GitHub PR link, read all review comments, evaluate whether each comment is valid, fix what can be fixed directly, and produce a structured report.
| package com.greptime; | |
| import static org.junit.Assert.assertTrue; | |
| import java.sql.Connection; | |
| import java.sql.DriverManager; | |
| import java.sql.PreparedStatement; | |
| import java.sql.ResultSet; | |
| import java.sql.Statement; | |
| import java.util.ArrayList; |
| Greptime, Inc. Contributor License Agreement | |
| Thank you for your interest in the open source project(s) managed by Greptime, Inc. (“Greptime”). In order to clarify the intellectual property license granted with Contributions from any person or entity, Greptime must have a Contributor License Agreement (“CLA”) on file that has been signed by each contributor, indicating agreement to the license terms below. This license is for your protection as a contributor as well as the protection of Greptime and its other contributors and users; it does not change your rights to use your own Contributions for any other purpose. | |
| By clicking “Accept” on this page You accept and agree to these terms and conditions for Your present and future Contributions submitted to Greptime. In return, Greptime shall consider Your Contributions for addition to the official Greptime open source project(s) for which they were submitted. Except for the license granted herein to Greptime and recipients of software distributed by Greptime, Yo |
岗位描述:
蚂蚁中间件团队是服务于整个蚂蚁金服集团（包括钱包、网商、小贷、芝麻、聚宝、国际、口碑等）的核心技术团队，致力于打造支撑每秒亿级金融交易规模的基础中间件平台，为高速发展的业务提供业界一流的，金融级高可用高性能的分布式基础服务，也将十年磨一剑的技术做产品化输出，为蚂蚁业务生态的合作伙伴提供技术赋能。期待您的加入，一起在蚂蚁这个极具挑战和丰富多彩的业务舞台上玩技术，支撑 DT 驱动的互联网金融生态！
您将参与蚂蚁 Java 中间件（包括RPC通讯、消息队列、应用容器、开发框架、协调管控系统、数据中间件、搜索平台等）的高可用设计、核心编码、性能优化和产品化开发等工作。 岗位要求:
| #include <stdlib.h> | |
| #include <stdio.h> | |
| #include <unistd.h> | |
| int main(int argc, char *argv[]) | |
| { | |
| int pp[2]; | |
| int pid; | |
| char* word; |
| import java.util.HashSet; | |
| import java.util.Iterator; | |
| import java.util.Set; | |
| import java.util.concurrent.CyclicBarrier; | |
| public class HashSetTest { | |
| private static Set<String> set = new HashSet<String>(); | |
| public static boolean update(final Set<String> subList) { |
| import 'socket'; | |
| var ss = socket.socket(socket.AF_INET, socket.SOCK_STREAM); | |
| socket.bind(ss, 8080); | |
| socket.listen(ss); | |
| while(true) { | |
| var s = socket.accept(ss); | |
| var msg = socket.recv(s[0]); | |
| while(msg.trim() != "exit") { | |
| socket.send(s[0], msg); |
| package org.apache.kafka.example; | |
| import org.apache.kafka.common.serialization.Serdes; | |
| import org.apache.kafka.streams.KafkaStreams; | |
| import org.apache.kafka.streams.StreamsConfig; | |
| import org.apache.kafka.streams.kstream.KStream; | |
| import org.apache.kafka.streams.kstream.KStreamBuilder; | |
| import org.apache.kafka.streams.kstream.KTable; | |
| import java.util.Arrays; |