{"repo":"confluentinc/flink-table-api-python-examples","free":true,"listed":false,"github":"https://github.com/confluentinc/flink-table-api-python-examples","clone":"git clone https://github.com/confluentinc/flink-table-api-python-examples.git","description":"Python Examples for running Apache Flink® Table API on Confluent Cloud","language":"Python","stars":17,"topics":["apache-flink","confluent","confluent-cloud","flink-sql","stream-processing","table-api"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Apache Flink® Table API on Confluent Cloud - Examples This repository contains examples for running Apache Flink's Table API on Confluent Cloud. Introduction to Table API for Python The Table API enables a programmatic way of developing, testing, and submitting Flink pipelines for processing data streams. Streams can be finite or infinite, with insert-only or changelog data. The latter allows for dealing with Change Data Capture (CDC) events. Within the API, you conceptually work with tables that change over time - inspired by relational databases. Write a Table Program as a declarative and structured graph of data transformations. Table API is inspired by SQL and complements it with additional tools for juggling real-time data. You can mix and match Flink SQL with Table API at any time as they go hand in hand. Table API on Confluent Cloud Table API on Confluent Cloud is a client-side library that delegates Flink API calls to Confluent’s public REST API. It submits Statements) and retrieves StatementResults). Table programs are implemented against Flink's open source Table API for Python. The provided Confluent pip packages repackage Flink's Python API and bundle the Confluent-specific components for powering the TableEnvironment without the need for a local Flink cluster. While using those packages, Flink internal components such as CatalogStore , Catalog , Planner , Executor , and configuration are managed by the plugin and fully integrate with Confluent Cloud. Including ac","default_branch":null,"files":null,"tree":[],"storefront":"/r/confluentinc","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/confluentinc/flink-table-api-python-examples/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}