diff --git a/scripts/cli/completions.bash b/scripts/cli/completions.bash index c85855fe3..bd13475fe 100644 --- a/scripts/cli/completions.bash +++ b/scripts/cli/completions.bash @@ -36,10 +36,6 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) ;; - *'connector-plugin search-jar'*'--connector-plugin') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur" ) - ;; - *'tcp-proxy toggle-reads-service'*'--connection-id') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) ;; @@ -48,44 +44,48 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "BACKWARD BACKWARD_TRANSITIVE FORWARD FORWARD_TRANSITIVE FULL FULL_TRANSITIVE NONE")" -- "$cur" ) ;; - *'tcp-proxy toggle-reads-client'*'--connection-id') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) + *'connector-plugin search-jar'*'--connector-plugin') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur" ) ;; *'connector open-in-confluent-cloud'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector-plugin versions'*'--connector-plugin') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur" ) + *'tcp-proxy toggle-reads-client'*'--connection-id') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) ;; *'connector show-config-parameters'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'topic produce'*'--value-subject-name-strategy') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "TopicNameStrategy RecordNameStrategy TopicRecordNameStrategy")" -- "$cur" ) + *'connector-plugin versions'*'--connector-plugin') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur" ) ;; - *'tcp-proxy close-all-connection-with-error'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) + *'topic produce'*'--value-subject-name-strategy') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "TopicNameStrategy RecordNameStrategy TopicRecordNameStrategy")" -- "$cur" ) ;; *'tcp-proxy close-connection'*'--connection-id') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) ;; - *'tcp-proxy get-connections'*'--connection-id') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) + *'tcp-proxy close-all-connection-with-error'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) + ;; + + *'topic produce'*'--key-subject-name-strategy') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "TopicNameStrategy RecordNameStrategy TopicRecordNameStrategy")" -- "$cur" ) ;; *'debug enable-remote-debugging'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'topic produce'*'--key-subject-name-strategy') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "TopicNameStrategy RecordNameStrategy TopicRecordNameStrategy")" -- "$cur" ) + *'tcp-proxy get-connections'*'--connection-id') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) ;; *'schema set-compatibility'*'--compatibility') @@ -116,7 +116,7 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) ;; - *'connector select-config'*'--connector') + *'connector offsets reset'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; @@ -128,23 +128,23 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector offsets reset'*'--connector') + *'connector select-config'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'schema get-compatibility'*'--subject') + *'schema set-compatibility'*'--subject') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) ;; - *'connector open-in-confluent-cloud'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur" ) - ;; - *'connector create-or-update'*'--level') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) ;; - *'schema set-compatibility'*'--subject') + *'connector open-in-confluent-cloud'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur" ) + ;; + + *'schema get-compatibility'*'--subject') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) ;; @@ -152,62 +152,54 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "aws gcp azure ccloud salesforce")" -- "$cur" ) ;; - *'debug flight-recorder'*'--container') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector offsets get'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; *'topic produce'*'--compression-codec') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "gzip snappy lz4 zstd")" -- "$cur" ) ;; - *'connector show-config-parameters'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --force-refresh --help --only-show-json --open --verbose -c -h -o -v")" -- "$cur" ) + *'connector show-config'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; *'topic set-schema-compatibility'*'-t') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; - *'connector offsets get'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'debug flight-recorder'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector show-config'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'connector show-config-parameters'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --force-refresh --help --only-show-json --open --verbose -c -h -o -v")" -- "$cur" ) ;; *'container change-jdk'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'tcp-proxy toggle-writes-service'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) + *'debug enable-remote-debugging'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; *'topic get-number-records'*'--topic') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; - *'debug enable-remote-debugging'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) - ;; - - *'topic produce'*'--validate-config') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "scrub.invalid.names=true enhanced.avro.schema.support=true connect.meta.data=false object.additional.properties=false use.optional.for.nonrequired=true ignore.default.for.nullables=true generalized.sum.type.support=true enhanced.protobuf.schema.support=true generate.index.for.unions=false int.for.enums=true optional.for.nullables=true generate.struct.for.nulls=true wrapper.for.nullables=true wrapper.for.raw.primitives=false")" -- "$cur" ) + *'tcp-proxy toggle-writes-service'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) ;; *'connector log-level'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'tcp-proxy toggle-reads-service'*) + *'tcp-proxy toggle-writes-client'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) ;; - *'tcp-proxy delay'*'--connection-id') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) - ;; - *'topic display-consumer-offsets'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --verbose -h -v")" -- "$cur" ) ;; @@ -216,20 +208,24 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'tcp-proxy toggle-writes-client'*) + *'tcp-proxy toggle-reads-service'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) ;; - *'tcp-proxy break'*'--connection-id') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) + *'topic produce'*'--validate-config') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "scrub.invalid.names=true enhanced.avro.schema.support=true connect.meta.data=false object.additional.properties=false use.optional.for.nonrequired=true ignore.default.for.nullables=true generalized.sum.type.support=true enhanced.protobuf.schema.support=true generate.index.for.unions=false int.for.enums=true optional.for.nullables=true generate.struct.for.nulls=true wrapper.for.nullables=true wrapper.for.raw.primitives=false")" -- "$cur" ) ;; *'topic set-schema-compatibility'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--compatibility --help --topic --verbose -h -t -v")" -- "$cur" ) ;; - *'connector snippets'*'--converter') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "avro protobuf json-schema json json-schema-enabled string bytearray")" -- "$cur" ) + *'tcp-proxy break'*'--connection-id') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) + ;; + + *'tcp-proxy delay'*'--connection-id') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur" ) ;; *'update-version'*'--connector-zip') @@ -244,55 +240,59 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) ;; - *'connector-plugin search-jar'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur" ) - ;; - - *'debug flight-recorder'*'--action') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "start stop")" -- "$cur" ) - ;; - *'container change-jdk'*'--version') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "8 11 17 21 22")" -- "$cur" ) ;; + *'tools read-parquet-file'*'--file') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "parquet")")" -- "$cur" ) + ;; + *'connector show-lag'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; + *'connector snippets'*'--converter') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "avro protobuf json-schema json json-schema-enabled string bytearray")" -- "$cur" ) + ;; + *'debug enable-remote-debugging'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) ;; - *'connector unpause'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'connector-plugin search-jar'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur" ) ;; - *'connector create-or-update'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'debug flight-recorder'*'--action') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "start stop")" -- "$cur" ) ;; - *'container unpause'*'--container') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector restart'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'container restart'*'--container') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector create-or-update'*'-l') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) ;; *'topic produce'*'--compatibility') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "BACKWARD BACKWARD_TRANSITIVE FORWARD FORWARD_TRANSITIVE FULL FULL_TRANSITIVE NONE")" -- "$cur" ) ;; - *'connector restart'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'debug thread-dump'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'debug generate-diagnostics'*'-c') + *'container unpause'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'debug thread-dump'*'--container') + *'connector create-or-update'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + ;; + + *'debug generate-diagnostics'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; @@ -300,55 +300,51 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) ;; - *'connector create-or-update'*'-l') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) - ;; - - *'debug block-traffic'*'--action') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "start stop")" -- "$cur" ) + *'connector unpause'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'container resume'*'--container') + *'container restart'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector-plugin search-jar'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--class --connector-plugin --connector-tag --help -c -h")" -- "$cur" ) + *'connector resume'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector status'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'container resume'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector update'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'debug block-traffic'*'--action') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "start stop")" -- "$cur" ) ;; *'connector-plugin versions'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur" ) ;; - *'debug java-debug'*'--container') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector status'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; *'connector delete'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector resume'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'debug java-debug'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector pause'*'--connector') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'connector-plugin search-jar'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--class --connector-plugin --connector-tag --help -c -h")" -- "$cur" ) ;; - *'topic consume'*'--key-subject') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) + *'connector update'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'container get-properties'*'-c') + *'debug heap-dump'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; @@ -356,19 +352,11 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; - *'debug generate-diagnostics'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) - ;; - *'connector create-or-update'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --level --package --skip-automatic-connector-config --validate --verbose --wait-for-zero-lag -c -h -l -p -v")" -- "$cur" ) ;; - *'container get-ip-addresses'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) - ;; - - *'get-jmx-metrics'*'--container') + *'container get-properties'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; @@ -376,28 +364,48 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) ;; - *'tools read-avro-file'*'--file') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "avro")")" -- "$cur" ) + *'topic consume'*'--key-subject') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) + ;; + + *'get-jmx-metrics'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; *'debug log-level set'*'--level') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) ;; - *'container pause'*'--container') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector pause'*'--connector') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'debug heap-dump'*'--container') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'debug generate-diagnostics'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) ;; *'tcp-proxy close-connection'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) ;; - *'debug block-traffic'*'--port') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-docker-ports)")" -- "$cur" ) + *'container pause'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + ;; + + *'container get-ip-addresses'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) + ;; + + *'tools read-avro-file'*'--file') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "avro")")" -- "$cur" ) + ;; + + *'connector offsets alter'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + ;; + + *'container kill'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; *'repro bootstrap'*'--pipeline') @@ -408,66 +416,54 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "none avro avro-with-key protobuf protobuf-with-key json-schema json-schema-with-key")" -- "$cur" ) ;; - *'connector select-config'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) - ;; - *'container logs'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'container kill'*'--container') + *'container exec'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector-plugin versions'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector-plugin --force-refresh --help --last -c -h")" -- "$cur" ) + *'connector select-config'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector offsets alter'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'connector-plugin versions'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector-plugin --force-refresh --help --last -c -h")" -- "$cur" ) ;; *'connector stop'*'--connector') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'tcp-proxy get-connections'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) + *'debug block-traffic'*'--port') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-docker-ports)")" -- "$cur" ) ;; - *'tcp-proxy start'*'--hostname') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector offsets reset'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'container exec'*'--container') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'tcp-proxy get-connections'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur" ) ;; *'debug tcp-dump'*'--container') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector offsets reset'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'tools read-parquet-file'*'-f') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "parquet")")" -- "$cur" ) ;; - *'container ssh'*'--container') + *'tcp-proxy start'*'--hostname') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'topic get-number-records'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --topic -h -t")" -- "$cur" ) - ;; - *'container get-properties'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) ;; - *'debug java-debug'*'--action') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "enable disable")" -- "$cur" ) - ;; - *'schema get-mode'*'--subject') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) ;; @@ -492,10 +488,18 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur" ) ;; + *'container ssh'*'--container') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + ;; + *'remove-all-docker-images'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) ;; + *'debug java-debug'*'--action') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "enable disable")" -- "$cur" ) + ;; + *'run'*'--cluster-environment') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-ccloud-environment-list "$cur")")" -- "$cur" ) ;; @@ -504,6 +508,10 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) ;; + *'topic get-number-records'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --topic -h -t")" -- "$cur" ) + ;; + *'config folder_zip_or_jar'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) ;; @@ -512,7 +520,11 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur" ) ;; - *'connector offsets reset'*) + *'tools read-parquet-file'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur" ) + ;; + + *'connector offsets alter'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; @@ -524,11 +536,11 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--force --help --resource -h")" -- "$cur" ) ;; - *'connector show-config'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'connector offsets reset'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; - *'connector offsets get'*'-c') + *'connector show-config'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; @@ -536,8 +548,8 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector offsets alter'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) + *'connector offsets get'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; *'tools read-avro-file'*'-f') @@ -548,18 +560,26 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) ;; + *'debug java-debug'*'--type') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "ssl_all ssl_handshake class_loading kerberos")" -- "$cur" ) + ;; + *'container change-jdk'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'debug java-debug'*'--type') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "ssl_all ssl_handshake class_loading kerberos")" -- "$cur" ) + *'connector show-config'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --force-rest-endpoint --help --verbose -c -h -v")" -- "$cur" ) ;; *'tcp-proxy start'*'--port') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-docker-ports)")" -- "$cur" ) ;; + *'debug log-level set'*'-l') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) + ;; + *'schema set-mode'*'--mode') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "IMPORT READONLY READWRITE")" -- "$cur" ) ;; @@ -568,32 +588,24 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf --without-repro "$cur")")" -- "$cur" ) ;; - *'connector log-level'*'-l') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) - ;; - - *'topic describe'*'--topic') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) + *'container exec'*'--shell') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "bash sh ksh zsh")" -- "$cur" ) ;; *'connector log-level'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector show-config'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --force-rest-endpoint --help --verbose -c -h -v")" -- "$cur" ) - ;; - *'connector offsets get'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; - *'container exec'*'--shell') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "bash sh ksh zsh")" -- "$cur" ) + *'connector log-level'*'-l') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) ;; - *'debug log-level set'*'-l') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur" ) + *'topic describe'*'--topic') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; *'debug flight-recorder'*) @@ -608,23 +620,15 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur" ) ;; - *'topic produce'*'--topic') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) - ;; - - *'topic produce'*'--value') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur" ) - ;; - *'container change-jdk'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help --version -c -h")" -- "$cur" ) ;; - *'container ssh'*'--shell') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "bash sh ksh zsh")" -- "$cur" ) + *'topic consume'*'--topic') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; - *'topic consume'*'--topic') + *'topic produce'*'--topic') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; @@ -632,10 +636,22 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; + *'container ssh'*'--shell') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "bash sh ksh zsh")" -- "$cur" ) + ;; + *'debug tcp-dump'*'--port') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-docker-ports)")" -- "$cur" ) ;; + *'topic produce'*'--value') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur" ) + ;; + + *'connector unpause'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + ;; + *'debug thread-dump'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; @@ -644,36 +660,28 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur" ) ;; - *'connector restart'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) - ;; - - *'connector open-docs'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --only-show-url -h")" -- "$cur" ) + *'connector log-level'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --level -c -h -l")" -- "$cur" ) ;; *'update-version'*'--tag') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-tag-list "$cur")")" -- "$cur" ) ;; - *'connector log-level'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --level -c -h -l")" -- "$cur" ) - ;; - *'run'*'--cluster-region') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-kafka-region-list "$cur")")" -- "$cur" ) ;; - *'connector unpause'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'container unpause'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; *'container restart'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'container unpause'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'topic delete'*'--topic') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; *'debug log-level get'*) @@ -684,34 +692,22 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --level --package -h -l -p")" -- "$cur" ) ;; - *'debug block-traffic'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--action --container --destination --help --port -c -h")" -- "$cur" ) - ;; - - *'topic delete'*'--topic') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) + *'connector open-docs'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --only-show-url -h")" -- "$cur" ) ;; - *'connector status'*'-c') + *'connector restart'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector resume'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'debug block-traffic'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--action --container --destination --help --port -c -h")" -- "$cur" ) ;; - *'get-docker-compose'*) + *'connector versions'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) ;; - *'repro import'*'--file') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-playground-repro-export-with-fzf "$cur")")" -- "$cur" ) - ;; - - *'connector update'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) - ;; - *'container kill-all'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) ;; @@ -720,28 +716,44 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --ignore-current-versions -h")" -- "$cur" ) ;; - *'connector versions'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) + *'debug java-debug'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; *'container resume'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'debug java-debug'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector status'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'connector delete'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'topic alter'*'--topic') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) + ;; + + *'get-docker-compose'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) + ;; + + *'repro import'*'--file') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-playground-repro-export-with-fzf "$cur")")" -- "$cur" ) + ;; + + *'connector show-lag'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --interval --verbose -c -h -v")" -- "$cur" ) ;; *'connector snippets'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--converter --dlq --help -h")" -- "$cur" ) ;; - *'topic alter'*'--topic') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) + *'connector delete'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + ;; + + *'connector resume'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; *'run'*'--connector-jar') @@ -756,48 +768,48 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "aws gcp azure")" -- "$cur" ) ;; - *'connector show-lag'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --interval --verbose -c -h -v")" -- "$cur" ) + *'connector update'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; *'topic produce'*'--key') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur" ) ;; - *'container unpause'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) - ;; - *'container pause'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; + *'container unpause'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) + ;; + *'container restart'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) ;; - *'get-jmx-metrics'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector offsets'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h alter get reset")" -- "$cur" ) ;; - *'connector plugins'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--all --help --verbose -h -v")" -- "$cur" ) + *'connector pause'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; - *'debug thread-dump'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) + *'get-jmx-metrics'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; *'debug heap-dump'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'connector offsets'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h alter get reset")" -- "$cur" ) + *'debug thread-dump'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) ;; - *'connector restart'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) + *'connector plugins'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--all --help --verbose -h -v")" -- "$cur" ) ;; *'repro bootstrap'*'-p') @@ -808,10 +820,6 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf --without-repro "$cur")")" -- "$cur" ) ;; - *'connector unpause'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) - ;; - *'run'*'--cluster-name') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-ccloud-cluster-list "$cur")")" -- "$cur" ) ;; @@ -820,12 +828,12 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "basic standard dedicated")" -- "$cur" ) ;; - *'connector pause'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'connector restart'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; - *'container kill'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + *'connector unpause'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; *'container resume'*) @@ -836,34 +844,38 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'topic describe'*'-t') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) + *'container kill'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; *'container logs'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; + *'debug java-debug'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--action --container --help --type -c -h")" -- "$cur" ) + ;; + *'debug tcp-dump'*'-c') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) ;; - *'debug java-debug'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--action --container --help --type -c -h")" -- "$cur" ) + *'connector status'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; *'connector resume'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; - *'run'*'--environment') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "ccloud plaintext sasl-ssl sasl-plain 2way-ssl sasl-scram kraft-external-plaintext kraft-plaintext kerberos ssl_kerberos ldap-authorizer-sasl-plain ldap-sasl-plain rbac-sasl-plain")" -- "$cur" ) - ;; - *'connector delete'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; + *'run'*'--environment') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "ccloud plaintext sasl-ssl sasl-plain 2way-ssl sasl-scram kraft-external-plaintext kraft-plaintext kerberos ssl_kerberos ldap-authorizer-sasl-plain ldap-sasl-plain rbac-sasl-plain")" -- "$cur" ) + ;; + *'config clipboard'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur" ) ;; @@ -872,30 +884,30 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur" ) ;; - *'connector stop'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) + *'topic describe'*'-t') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; *'connector-plugin'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h search-jar versions")" -- "$cur" ) ;; - *'connector status'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) + *'connector stop'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur" ) ;; *'container pause'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) ;; - *'container ssh'*'-c') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) - ;; - *'container ssh'*'-s') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "bash sh ksh zsh")" -- "$cur" ) ;; + *'container ssh'*'-c') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur" ) + ;; + *'get-jmx-metrics'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --domain --help --open -c -d -h -o")" -- "$cur" ) ;; @@ -904,10 +916,6 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h get set")" -- "$cur" ) ;; - *'debug heap-dump'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) - ;; - *'tcp-proxy break'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--break-service-response --connection-id --help -h")" -- "$cur" ) ;; @@ -936,6 +944,10 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--custom-smt --description --file --help --pipeline -d -f -h")" -- "$cur" ) ;; + *'debug heap-dump'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur" ) + ;; + *'connector pause'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; @@ -960,32 +972,32 @@ _playground_completions() { while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --help --max-wait --open --wait-for-log -c -h -m -o -w")" -- "$cur" ) ;; - *'connector stop'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) - ;; - - *'connector logs'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --lcc-id --max-wait --open --wait-for-log -h -m -o -w")" -- "$cur" ) + *'debug tcp-dump'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --duration --help --port -c -h")" -- "$cur" ) ;; *'repro import'*'-f') while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-playground-repro-export-with-fzf "$cur")")" -- "$cur" ) ;; + *'connector logs'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --lcc-id --max-wait --open --wait-for-log -h -m -o -w")" -- "$cur" ) + ;; + *'update-version'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector-jar --connector-tag --connector-zip --help --tag -h")" -- "$cur" ) ;; - *'debug tcp-dump'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--container --duration --help --port -c -h")" -- "$cur" ) + *'topic delete'*'-t') + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) ;; *'topic describe'*) while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help --topic --verbose -h -t -v")" -- "$cur" ) ;; - *'topic delete'*'-t') - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur" ) + *'connector stop'*) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur" ) ;; *'container ssh'*) @@ -1117,7 +1129,7 @@ _playground_completions() { ;; *'tools'*) - while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h read-avro-file")" -- "$cur" ) + while read -r; do COMPREPLY+=( "$REPLY" ); done < <( compgen -W "$(_playground_completions_filter "--help -h read-avro-file read-parquet-file")" -- "$cur" ) ;; *'repro'*) diff --git a/scripts/cli/playground b/scripts/cli/playground index 97d9f68c2..c8e065a9e 100755 --- a/scripts/cli/playground +++ b/scripts/cli/playground @@ -92,6 +92,7 @@ playground_usage() { printf "%s\n" "$(bold "Tools commands:")" printf " %s šŸ§° Tools commands\n" "$(green "tools") " printf " %s šŸ” Read provided avro file\n" "$(green "tools read-avro-file") " + printf " %s šŸ” Read provided parquet file\n" "$(green "tools read-parquet-file") " echo printf "%s\n" "$(bold "Debug commands:")" printf " %s šŸž Debug commands\n" "$(green "debug") " @@ -3288,7 +3289,8 @@ playground_tools_usage() { echo # :command.usage_commands printf "%s\n" "$(bold "== Commands ==")" - printf " %s šŸ” Read provided avro file\n" "$(green "read-avro-file")" + printf " %s šŸ” Read provided avro file\n" "$(green "read-avro-file") " + printf " %s šŸ” Read provided parquet file\n" "$(green "read-parquet-file")" echo # :command.long_usage @@ -3338,6 +3340,41 @@ playground_tools_read_avro_file_usage() { fi } +# :command.usage +playground_tools_read_parquet_file_usage() { + if [[ -n $long_usage ]]; then + printf "playground tools read-parquet-file - šŸ” Read provided parquet file\n" + echo + + else + printf "playground tools read-parquet-file - šŸ” Read provided parquet file\n" + echo + + fi + + printf "%s\n" "$(bold "== Usage ==")" + printf " playground tools read-parquet-file [OPTIONS]\n" + printf " playground tools read-parquet-file --help | -h\n" + echo + + # :command.long_usage + if [[ -n $long_usage ]]; then + printf "%s\n" "$(bold "== Options ==")" + + # :command.usage_flags + # :flag.usage + printf " %s\n" "$(magenta "--file, -f FILE")" + printf " šŸ”– Parquet file to read\n \n ā• It must be absolute full path\n \n šŸŽ“ Tip: use completion to trigger fzf completion\n" + echo + + # :command.usage_fixed_flags + printf " %s\n" "$(magenta "--help, -h")" + printf " Show this help\n" + echo + + fi +} + # :command.usage playground_debug_usage() { if [[ -n $long_usage ]]; then @@ -12211,6 +12248,20 @@ validate_file_exists_and_avro() { [[ "$real_file" == *.avro ]] || logerror "<$real_file> is not an Avro file. Please provide a file with .avro extension." } +# src/lib/validations/validate_file_exists_and_parquet.sh +validate_file_exists_and_parquet() { + file="$1" + + real_file=$file + if [[ $file == *"@"* ]] + then + real_file=$(echo "$file" | cut -d "@" -f 2) + fi + + [[ -f "$real_file" ]] || logerror "<$real_file> does not correspond to the path of an existing file, please make sure to use absolute full path or correct relative path !" + [[ "$real_file" == *.parquet ]] || logerror "<$real_file> is not an Parquet file. Please provide a file with .parquet extension." +} + # src/lib/validations/validate_file_exists_with_trick.sh validate_file_exists_with_trick() { file="$1" @@ -18443,6 +18494,26 @@ playground_tools_read_avro_file_command() { } +# :command.function +playground_tools_read_parquet_file_command() { + # src/commands/tools/read-parquet-file.sh + file="${args[--file]}" + + if [[ $file == *"@"* ]] + then + file=$(echo "$file" | cut -d "@" -f 2) + fi + + filename=$(basename $file) + + log "šŸ”– ${filename}.parquet schema" + docker run --quiet --rm -v ${file}:/tmp/${filename} nathanhowell/parquet-tools schema /tmp/${filename} + + log "šŸ”– ${filename}.parquet content" + docker run --quiet --rm -v ${file}:/tmp/${filename} nathanhowell/parquet-tools cat /tmp/${filename} + +} + # :command.function playground_debug_enable_remote_debugging_command() { # src/commands/debug/enable-remote-debugging.sh @@ -30303,6 +30374,13 @@ playground_tools_parse_requirements() { shift $# ;; + read-parquet-file) + action="read-parquet-file" + shift + playground_tools_read_parquet_file_parse_requirements "$@" + shift $# + ;; + # :command.command_fallback "") playground_tools_usage >&2 @@ -30403,6 +30481,70 @@ playground_tools_read_avro_file_parse_requirements() { } +# :command.parse_requirements +playground_tools_read_parquet_file_parse_requirements() { + # :command.fixed_flags_filter + while [[ $# -gt 0 ]]; do + case "${1:-}" in + --help | -h) + long_usage=yes + playground_tools_read_parquet_file_usage + exit + ;; + + *) + break + ;; + + esac + done + + # :command.command_filter + action="tools read-parquet-file" + + # :command.parse_requirements_while + while [[ $# -gt 0 ]]; do + key="$1" + case "$key" in + # :flag.case + --file | -f) + + # :flag.case_arg + if [[ -n ${2+x} ]]; then + args['--file']="$2" + shift + shift + else + printf "%s\n" "--file requires an argument: --file, -f FILE" >&2 + exit 1 + fi + ;; + + -?*) + printf "invalid option: %s\n" "$key" >&2 + exit 1 + ;; + + *) + # :command.parse_requirements_case + # :command.parse_requirements_case_simple + printf "invalid argument: %s\n" "$key" >&2 + exit 1 + + ;; + + esac + done + + # :command.validations + # :flag.validations + if [[ -v args['--file'] && -n $(validate_file_exists_and_parquet "${args['--file']:-}") ]]; then + printf "validation error in %s:\n%s\n" "--file, -f FILE" "$(validate_file_exists_and_parquet "${args['--file']:-}")" >&2 + exit 1 + fi + +} + # :command.parse_requirements playground_debug_parse_requirements() { # :command.fixed_flags_filter @@ -36288,6 +36430,7 @@ run() { "tcp-proxy toggle-writes-service") playground_tcp_proxy_toggle_writes_service_command ;; "tools") playground_tools_command ;; "tools read-avro-file") playground_tools_read_avro_file_command ;; + "tools read-parquet-file") playground_tools_read_parquet_file_command ;; "debug") playground_debug_command ;; "debug enable-remote-debugging") playground_debug_enable_remote_debugging_command ;; "debug testssl") playground_debug_testssl_command ;; diff --git a/scripts/cli/playground.json b/scripts/cli/playground.json index 60acd5aa1..bd71c334e 100644 --- a/scripts/cli/playground.json +++ b/scripts/cli/playground.json @@ -959,6 +959,21 @@ "description": "šŸ”– Avro file to read\n\nā• It must be absolute full path\n\nšŸŽ“ Tip: use completion to trigger fzf completion\n" } ] + }, + { + "name": "read-parquet-file", + "description": "šŸ” Read provided parquet file\n", + "usage": "playground tools read-parquet-file [OPTIONS]", + "options": [ + { + "names": [ + "--file", + "-f" + ], + "argument": "FILE", + "description": "šŸ”– Parquet file to read\n\nā• It must be absolute full path\n\nšŸŽ“ Tip: use completion to trigger fzf completion\n" + } + ] } ] }, diff --git a/scripts/cli/playground.yaml b/scripts/cli/playground.yaml index da4b3b9c2..676c01dd9 100644 --- a/scripts/cli/playground.yaml +++ b/scripts/cli/playground.yaml @@ -1086,6 +1086,22 @@ subcommands: šŸŽ“ Tip: use completion to trigger fzf completion + - name: read-parquet-file + description: | + šŸ” Read provided parquet file + usage: playground tools read-parquet-file [OPTIONS] + options: + - names: + - --file + - -f + argument: FILE + description: | + šŸ”– Parquet file to read + + ā• It must be absolute full path + + šŸŽ“ Tip: use completion to trigger fzf completion + - name: debug description: | šŸž Debug commands diff --git a/scripts/cli/src/bashly.yml b/scripts/cli/src/bashly.yml index 6307acafe..12c6a71a9 100644 --- a/scripts/cli/src/bashly.yml +++ b/scripts/cli/src/bashly.yml @@ -1459,6 +1459,24 @@ commands: šŸŽ“ Tip: use completion to trigger fzf completion + - name: read-parquet-file + help: |- + šŸ” Read provided parquet file + flags: + - long: --file + short: -f + required: false + completions: + - $(playground get-specific-file-extension "$cur" --extension "parquet") + validate: file_exists_and_parquet + arg: file + help: |- + šŸ”– Parquet file to read + + ā• It must be absolute full path + + šŸŽ“ Tip: use completion to trigger fzf completion + - name: debug expose: always group: Debug diff --git a/scripts/cli/src/commands/tools/read-parquet-file.sh b/scripts/cli/src/commands/tools/read-parquet-file.sh new file mode 100644 index 000000000..3ac22d191 --- /dev/null +++ b/scripts/cli/src/commands/tools/read-parquet-file.sh @@ -0,0 +1,14 @@ +file="${args[--file]}" + +if [[ $file == *"@"* ]] +then + file=$(echo "$file" | cut -d "@" -f 2) +fi + +filename=$(basename $file) + +log "šŸ”– ${filename}.parquet schema" +docker run --quiet --rm -v ${file}:/tmp/${filename} nathanhowell/parquet-tools schema /tmp/${filename} + +log "šŸ”– ${filename}.parquet content" +docker run --quiet --rm -v ${file}:/tmp/${filename} nathanhowell/parquet-tools cat /tmp/${filename} diff --git a/scripts/cli/src/lib/validations/validate_file_exists_and_parquet.sh b/scripts/cli/src/lib/validations/validate_file_exists_and_parquet.sh new file mode 100644 index 000000000..e2baf973e --- /dev/null +++ b/scripts/cli/src/lib/validations/validate_file_exists_and_parquet.sh @@ -0,0 +1,13 @@ +## [@bashly-upgrade validations] +validate_file_exists_and_parquet() { + file="$1" + + real_file=$file + if [[ $file == *"@"* ]] + then + real_file=$(echo "$file" | cut -d "@" -f 2) + fi + + [[ -f "$real_file" ]] || logerror "<$real_file> does not correspond to the path of an existing file, please make sure to use absolute full path or correct relative path !" + [[ "$real_file" == *.parquet ]] || logerror "<$real_file> is not an Parquet file. Please provide a file with .parquet extension." +} \ No newline at end of file