| /// ┌──────────────────────────┬──────────┬────────────────┬────────────────┐ | |
| /// │ Scenario │ Raw+zstd │ Bitpacked+zstd │ Winner │ | |
| /// ├──────────────────────────┼──────────┼────────────────┼────────────────┤ | |
| /// │ Uniform random 7-bit │ 8837 │ 8759 │ Bitpack (-78) │ | |
| /// ├──────────────────────────┼──────────┼────────────────┼────────────────┤ | |
| /// │ Sorted 7-bit │ 246 │ 662 │ Raw (+416) │ | |
| /// ├──────────────────────────┼──────────┼────────────────┼────────────────┤ | |
| /// │ Repeated runs 7-bit │ 280 │ 984 │ Raw (+704) │ | |
| /// ├──────────────────────────┼──────────┼────────────────┼────────────────┤ | |
| /// │ Sequential 7-bit │ 147 │ 131 │ Bitpack (-16) │ |
| #!/bin/bash | |
| # Rust Backtrace Formatter | |
| # Usage: format-backtrace [-v] [-vv] | |
| # (no flag): show short function name only | |
| # -v: show truncated full path with ... prefix | |
| # -vv: show complete full path | |
| SCRIPT_DIR="$(dirname "$0")" | |
| VERBOSE=0 |
| import * as fs from 'fs'; | |
| import * as rd from 'readline' | |
| function getKey(result: RegExpExecArray) { | |
| return result[1] + '/' + result[3] | |
| } | |
| const regex = /\[(transaction_id_store-[0-9]+)] Flushing ([0-9]+) records with batchSize=[0-9]+ to remote \(offset=([0-9]+)/ | |
| const regex2 = /\[(transaction_id_store-[0-9]+)] Flushed ([0-9]+) records to [0-9]+ table partitions with offset ([0-9]+)/ | |
| const reader = rd.createInterface(fs.createReadStream('<log file>')) |
| public interface ConsumerPartitionAssignor { | |
| /** | |
| * Return serialized data that will be included in the {@link Subscription} sent to the leader | |
| * and can be leveraged in {@link #assign(Cluster, GroupSubscription)} ((e.g. local host/rack information) | |
| */ | |
| default ByteBuffer subscriptionUserData(Set<String> topics) { | |
| return null; | |
| } |
| apiVersion: "application.responsive.dev/v1" | |
| kind: "ResponsivePolicy" | |
| metadata: | |
| name: example-policy | |
| namespace: responsive | |
| spec: | |
| applicationNamespace: responsive | |
| applicationName: example | |
| status: POLICY_STATUS_MANAGED | |
| policyType: KAFKA_STREAMS |
| # | |
| # Example Usage: | |
| # ./get-and-subscribe.sh -t foo -s "user = 'User_6'" will get all rows with `user = 'User_6'` from the foo table | |
| # ./get-and-subscribe.sh -f -t foo -s "user = 'User_6'" will issue the above query, and also subscribe to changes | |
| usage() { echo "Usage: $0 [-f follow] [-t table] [-s <sql where clause>]" 1>&2; exit 1; } | |
| while getopts "ft:s:" o; do | |
| case "${o}" in | |
| t) |