agavra

name	description	argument-hint	user-invocable
prepare-review	Break up branch changes into smaller, logically-grouped commits for easier code review	base-branch	true

Prepare Review

Break up the changes on the current branch into smaller, logically-grouped commits for easier code review.

agavra

///  ┌──────────────────────────┬──────────┬────────────────┬────────────────┐
///  │         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)  │

agavra

#!/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

agavra

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>'))

agavra

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;
    }

agavra

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

agavra

#
# 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)