Feldera Python SDK Documentation

Contents:

• Introduction
  • Installation
  • Key Concepts
• Pandas Compatibility
  • Using Pandas DataFrames as Input / Output
• Examples
  • Connecting to Feldera Sandbox
  • Connecting to Feldera on localhost
  • Setting HTTP Connection Timeouts
  • Creating a Pipeline (OVERWRITING existing pipelines)
  • Starting a Pipeline
  • Analyzing Existing Feldera Pipeline for Errors
  • Using Pandas DataFrames
  • Executing ad-hoc SQL Queries
  • Iterating over Output Chunks
  • Waiting for Completion
  • End-to-End Example with Kafka Sink
  • Specifying Data Sources / Sinks

API Reference:

• feldera
  • feldera package
    • feldera.pipeline_builder module
      • PipelineBuilder
    • feldera.pipeline module
      • Pipeline
    • feldera.enums module
      • BuildMode
      • CompilationProfile
      • PipelineStatus
      • ProgramStatus
    • feldera.output_handler module
      • OutputHandler
    • feldera.runtime_config module
      • Resources
      • RuntimeConfig
      • Storage
    • Subpackages
      • feldera.rest package

Indices and tables

• Index

• Module Index