python
- feldera package
- feldera.pipeline_builder module
- feldera.pipeline module
Pipeline
Pipeline.activate()
Pipeline.checkpoint()
Pipeline.checkpoint_status()
Pipeline.clear_storage()
Pipeline.commit_transaction()
Pipeline.created_at()
Pipeline.delete()
Pipeline.deployment_config()
Pipeline.deployment_desired_status()
Pipeline.deployment_error()
Pipeline.deployment_location()
Pipeline.deployment_status_since()
Pipeline.description()
Pipeline.errors()
Pipeline.execute()
Pipeline.foreach_chunk()
Pipeline.get()
Pipeline.id()
Pipeline.input_json()
Pipeline.input_pandas()
Pipeline.is_complete()
Pipeline.listen()
Pipeline.logs()
Pipeline.modify()
Pipeline.name
Pipeline.pause()
Pipeline.pause_connector()
Pipeline.program_code()
Pipeline.program_config()
Pipeline.program_error()
Pipeline.program_info()
Pipeline.program_status()
Pipeline.program_status_since()
Pipeline.program_version()
Pipeline.query()
Pipeline.query_hash()
Pipeline.query_parquet()
Pipeline.query_tabular()
Pipeline.refresh()
Pipeline.restart()
Pipeline.resume()
Pipeline.resume_connector()
Pipeline.runtime_config()
Pipeline.set_runtime_config()
Pipeline.start()
Pipeline.start_transaction()
Pipeline.stats()
Pipeline.status()
Pipeline.stop()
Pipeline.storage_status()
Pipeline.support_bundle()
Pipeline.sync_checkpoint()
Pipeline.sync_checkpoint_status()
Pipeline.tables()
Pipeline.transaction_id()
Pipeline.transaction_status()
Pipeline.udf_rust()
Pipeline.udf_toml()
Pipeline.version()
Pipeline.views()
Pipeline.wait_for_completion()
Pipeline.wait_for_idle()
- feldera.enums module
- feldera.output_handler module
- feldera.runtime_config module
- Subpackages
- tests package
- Subpackages
- tests.platform package
- Submodules
- tests.platform.helper module
- tests.platform.negative_test module
- tests.platform.test_checkpoint_suspend module
- tests.platform.test_checkpoint_sync module
- tests.platform.test_cluster_health module
- tests.platform.test_completion_tokens module
- tests.platform.test_ingress_formats module
- tests.platform.test_metrics_logs module
- tests.platform.test_orchestration module
- tests.platform.test_pipeline_builder module
- tests.platform.test_pipeline_configs module
- tests.platform.test_pipeline_crud module
- tests.platform.test_pipeline_lifecycle module
- tests.platform.test_shared_pipeline module
- tests.platform.test_shared_pipeline_stress module
- Module contents
- tests.runtime package
- tests.platform package
- Submodules
- tests.conftest module
- tests.shared_test_pipeline module
- Module contents
- Subpackages