python

• feldera package
  • feldera.pipeline_builder module
    • PipelineBuilder
      • PipelineBuilder.create()
      • PipelineBuilder.create_or_replace()
  • 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.listen()
      • Pipeline.logs()
      • 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.udf_rust()
      • Pipeline.udf_toml()
      • Pipeline.version()
      • Pipeline.views()
      • Pipeline.wait_for_completion()
      • Pipeline.wait_for_idle()
  • feldera.enums module
    • BuildMode
      • BuildMode.CREATE
      • BuildMode.GET
      • BuildMode.GET_OR_CREATE
    • CheckpointStatus
      • CheckpointStatus.Failure
      • CheckpointStatus.InProgress
      • CheckpointStatus.Success
      • CheckpointStatus.Unknown
      • CheckpointStatus.get_error()
    • CompilationProfile
      • CompilationProfile.DEV
      • CompilationProfile.OPTIMIZED
      • CompilationProfile.SERVER_DEFAULT
      • CompilationProfile.UNOPTIMIZED
    • FaultToleranceModel
      • FaultToleranceModel.AtLeastOnce
      • FaultToleranceModel.ExactlyOnce
      • FaultToleranceModel.from_str()
    • PipelineStatus
      • PipelineStatus.INITIALIZING
      • PipelineStatus.NOT_FOUND
      • PipelineStatus.PAUSED
      • PipelineStatus.PROVISIONING
      • PipelineStatus.RUNNING
      • PipelineStatus.STOPPED
      • PipelineStatus.STOPPING
      • PipelineStatus.SUSPENDING
      • PipelineStatus.UNAVAILABLE
      • PipelineStatus.from_str()
    • ProgramStatus
      • ProgramStatus.CompilingRust
      • ProgramStatus.CompilingSql
      • ProgramStatus.Pending
      • ProgramStatus.RustError
      • ProgramStatus.SqlCompiled
      • ProgramStatus.SqlError
      • ProgramStatus.Success
      • ProgramStatus.SystemError
      • ProgramStatus.from_value()
      • ProgramStatus.get_error()
    • StorageStatus
      • StorageStatus.CLEARED
      • StorageStatus.CLEARING
      • StorageStatus.INUSE
      • StorageStatus.from_str()
  • feldera.output_handler module
    • OutputHandler
      • OutputHandler.start()
      • OutputHandler.to_dict()
      • OutputHandler.to_pandas()
  • feldera.runtime_config module
    • Resources
    • RuntimeConfig
      • RuntimeConfig.default()
      • RuntimeConfig.from_dict()
      • RuntimeConfig.to_dict()
    • Storage
  • Subpackages
    • feldera.rest package
      • Submodules
      • feldera.rest.config module
      • feldera.rest.errors module
      • feldera.rest.feldera_client module
      • feldera.rest.feldera_config module
      • feldera.rest.pipeline module
      • feldera.rest.sql_table module
      • feldera.rest.sql_view module
      • Module contents
• tests package
  • Submodules
  • tests.shared_test_pipeline module
    • SharedTestPipeline
      • SharedTestPipeline.new_pipeline_with_suffix()
      • SharedTestPipeline.pipeline
      • SharedTestPipeline.setUp()
      • SharedTestPipeline.setUpClass()
      • SharedTestPipeline.tearDown()
  • tests.test_uda module
    • TestUDA
      • TestUDA.test_local()
  • Module contents
    • enterprise_only()
    • unique_pipeline_name()