Feldera Python SDK Documentation
Contents:
- Introduction
- Pandas Compatibility
- Examples
- Connecting to Feldera Sandbox
- Connecting to Feldera on localhost
- TLS with Self Signed Certificates
- Setting HTTP Connection Timeouts
- Creating a Pipeline (OVERWRITING existing pipelines)
- Creating a Pipeline with Fault Tolerance Enabled
- Runtime configuration of a Pipeline
- Starting a Pipeline
- Analyzing Existing Feldera Pipeline for Errors
- Using Pandas DataFrames
- Using Completion Tokens
- Executing ad-hoc SQL Queries
- Iterating over Output Chunks
- Waiting for Completion
- End-to-End Example with Kafka Sink
- Retrieve a support-bundle for a pipeline
- Specifying Data Sources / Sinks
API Reference:
- feldera
- feldera package
- feldera.pipeline_builder module
- feldera.pipeline module
- feldera.enums module
BootstrapPolicyBuildModeCheckpointStatusCompilationProfileCompletionTokenStatusDeploymentDesiredStatusDeploymentResourcesDesiredStatusDeploymentResourcesStatusDeploymentRuntimeDesiredStatusDeploymentRuntimeStatusFaultToleranceModelPipelineFieldSelectorPipelineStatusProgramStatusStorageStatusTransactionStatus
- feldera.output_handler module
- feldera.runtime_config module
- Subpackages
- feldera package