feldera

• feldera package
  • feldera.pipeline_builder module
    • PipelineBuilder
      • PipelineBuilder.create()
      • PipelineBuilder.create_or_replace()
  • feldera.pipeline module
    • Pipeline
      • Pipeline.checkpoint()
      • 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.execute()
      • Pipeline.foreach_chunk()
      • Pipeline.get()
      • Pipeline.id()
      • Pipeline.input_json()
      • Pipeline.input_pandas()
      • Pipeline.listen()
      • Pipeline.name
      • Pipeline.pause()
      • Pipeline.pause_connector()
      • Pipeline.program_binary_url()
      • Pipeline.program_code()
      • Pipeline.program_config()
      • Pipeline.program_info()
      • Pipeline.program_status()
      • Pipeline.program_status_since()
      • Pipeline.program_version()
      • Pipeline.query()
      • Pipeline.query_parquet()
      • Pipeline.query_tabular()
      • Pipeline.refresh()
      • Pipeline.restart()
      • Pipeline.resume()
      • Pipeline.resume_connector()
      • Pipeline.runtime_config()
      • Pipeline.shutdown()
      • Pipeline.start()
      • Pipeline.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
    • CompilationProfile
      • CompilationProfile.DEV
      • CompilationProfile.OPTIMIZED
      • CompilationProfile.SERVER_DEFAULT
      • CompilationProfile.UNOPTIMIZED
    • PipelineStatus
      • PipelineStatus.FAILED
      • PipelineStatus.INITIALIZING
      • PipelineStatus.NOT_FOUND
      • PipelineStatus.PAUSED
      • PipelineStatus.PROVISIONING
      • PipelineStatus.RUNNING
      • PipelineStatus.SHUTDOWN
      • PipelineStatus.SHUTTING_DOWN
      • 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()
  • feldera.output_handler module
    • OutputHandler
      • OutputHandler.start()
      • OutputHandler.to_dict()
      • OutputHandler.to_pandas()
  • feldera.runtime_config module
    • Resources
    • RuntimeConfig
      • RuntimeConfig.from_dict()
  • Subpackages
    • feldera.rest package
      • Submodules
      • feldera.rest.config module
      • feldera.rest.errors module
      • feldera.rest.feldera_client module
      • feldera.rest.pipeline module
      • feldera.rest.sql_table module
      • feldera.rest.sql_view module
      • Module contents