CCAF Avro Schema Helpers Python Library
Project description
Confluent Cloud for Apache Flink (CCAF) Avro Schema Helpers Python Library
Table of Contents
1.0 Overview
1.1 generate_flink_sql_statements_for_fully_flatten_root_record module
This module's class constructs a pair of Flink SQL statements using a breadth-first traversal method from an Avro schema based on the provided outermost JSON object or JSON array column. These Flink SQL statements include the CREATE TABLE and INSERT INTO SELECT FROM statements. The CREATE TABLE statement creates the Sink Table, which subsequently establishes the backing sink Kafka topic. The INSERT INTO SELECT FROM statement generates a continuous, unbounded data stream that populates the sink table
1.2 swap_camelcase_with_snakecase module
This module's class uses a depth-first traversal method to traverse an entire Avro schema and converts every camelCase record or field name into a snake_case record or field name. This is useful for transforming Avro schema field names into Flink SQL style field names.
2.0 Installation
Install the Confluent Cloud for Apache Flink (CCAF) Avro Schema Helpers Python Library using pip:
pip install ccaf-avro-schema-helpers-python-lib
Or, using uv:
uv add ccaf-avro-schema-helpers-python-lib
3.0 Resources
3.1 Traversal Method Background
3.2 Confluent Cloud for Apache Flink (CCAF) SQL Statements
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file ccaf_avro_schema_helpers_python_lib-0.4.2.0.tar.gz.
File metadata
- Download URL: ccaf_avro_schema_helpers_python_lib-0.4.2.0.tar.gz
- Upload date:
- Size: 89.7 kB
- Tags: Source
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.12.9
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
22c203b8e5ce4f19506ce8fc61f413d78bd4635c53f16afaae0ec83323baf32d
|
|
| MD5 |
1187435832b6b77dac352e11bb133f4e
|
|
| BLAKE2b-256 |
76a3c4ca12d3a7018d686dc28ae4734e4bd7f0571f938bde6e85c3371773c536
|
Provenance
The following attestation bundles were made for ccaf_avro_schema_helpers_python_lib-0.4.2.0.tar.gz:
Publisher:
pypi_release.yml on j3-signalroom/ccaf-avro_schema_helpers-python_lib
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
ccaf_avro_schema_helpers_python_lib-0.4.2.0.tar.gz -
Subject digest:
22c203b8e5ce4f19506ce8fc61f413d78bd4635c53f16afaae0ec83323baf32d - Sigstore transparency entry: 177674813
- Sigstore integration time:
-
Permalink:
j3-signalroom/ccaf-avro_schema_helpers-python_lib@7ec5e33564103ea72cb0f313eb22d6d3717a14b9 -
Branch / Tag:
refs/tags/v0.04.02.000 - Owner: https://github.com/j3-signalroom
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
pypi_release.yml@7ec5e33564103ea72cb0f313eb22d6d3717a14b9 -
Trigger Event:
release
-
Statement type:
File details
Details for the file ccaf_avro_schema_helpers_python_lib-0.4.2.0-py3-none-any.whl.
File metadata
- Download URL: ccaf_avro_schema_helpers_python_lib-0.4.2.0-py3-none-any.whl
- Upload date:
- Size: 13.1 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.12.9
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
910698b84c37641fd16461aaf89132b125a0058c14c272234830a7808be7f967
|
|
| MD5 |
cba16f71499aeaac6b29c533f3fa8779
|
|
| BLAKE2b-256 |
80acc1e31803ea39d6099d5dfca6459594ab2fce8c721ff7a34d7f2dd4df4ca5
|
Provenance
The following attestation bundles were made for ccaf_avro_schema_helpers_python_lib-0.4.2.0-py3-none-any.whl:
Publisher:
pypi_release.yml on j3-signalroom/ccaf-avro_schema_helpers-python_lib
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
ccaf_avro_schema_helpers_python_lib-0.4.2.0-py3-none-any.whl -
Subject digest:
910698b84c37641fd16461aaf89132b125a0058c14c272234830a7808be7f967 - Sigstore transparency entry: 177674817
- Sigstore integration time:
-
Permalink:
j3-signalroom/ccaf-avro_schema_helpers-python_lib@7ec5e33564103ea72cb0f313eb22d6d3717a14b9 -
Branch / Tag:
refs/tags/v0.04.02.000 - Owner: https://github.com/j3-signalroom
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
pypi_release.yml@7ec5e33564103ea72cb0f313eb22d6d3717a14b9 -
Trigger Event:
release
-
Statement type:
