feldera

• feldera package
  • feldera.pipeline_builder module
    • PipelineBuilder
      • PipelineBuilder.create()
      • PipelineBuilder.create_or_replace()
  • feldera.pipeline module
    • Pipeline
      • Pipeline.activate()
      • Pipeline.all()
      • Pipeline.approve()
      • Pipeline.checkpoint()
      • Pipeline.checkpoint_status()
      • Pipeline.clear_storage()
      • Pipeline.commit_transaction()
      • Pipeline.completion_token_status()
      • Pipeline.created_at()
      • Pipeline.delete()
      • Pipeline.deployment_config()
      • Pipeline.deployment_desired_status()
      • Pipeline.deployment_error()
      • Pipeline.deployment_location()
      • Pipeline.deployment_resources_desired_status()
      • Pipeline.deployment_resources_status()
      • Pipeline.deployment_runtime_desired_status()
      • Pipeline.deployment_runtime_status()
      • Pipeline.deployment_runtime_status_details()
      • Pipeline.deployment_status_since()
      • Pipeline.description()
      • Pipeline.errors()
      • Pipeline.execute()
      • Pipeline.foreach_chunk()
      • Pipeline.generate_completion_token()
      • 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.platform_version()
      • 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_paused()
      • Pipeline.start_standby()
      • 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.testing_force_update_platform_version()
      • Pipeline.transaction_id()
      • Pipeline.transaction_status()
      • Pipeline.udf_rust()
      • Pipeline.udf_toml()
      • Pipeline.update_runtime()
      • Pipeline.version()
      • Pipeline.views()
      • Pipeline.wait_for_completion()
      • Pipeline.wait_for_idle()
      • Pipeline.wait_for_status()
      • Pipeline.wait_for_token()
  • feldera.enums module
    • BootstrapPolicy
      • BootstrapPolicy.ALLOW
      • BootstrapPolicy.AWAIT_APPROVAL
      • BootstrapPolicy.REJECT
    • 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
    • CompletionTokenStatus
      • CompletionTokenStatus.COMPLETE
      • CompletionTokenStatus.IN_PROGRESS
    • DeploymentDesiredStatus
      • DeploymentDesiredStatus.PAUSED
      • DeploymentDesiredStatus.RUNNING
      • DeploymentDesiredStatus.STANDBY
      • DeploymentDesiredStatus.STOPPED
      • DeploymentDesiredStatus.SUSPENDED
      • DeploymentDesiredStatus.UNAVAILABLE
      • DeploymentDesiredStatus.from_str()
    • DeploymentResourcesDesiredStatus
      • DeploymentResourcesDesiredStatus.PROVISIONED
      • DeploymentResourcesDesiredStatus.STOPPED
      • DeploymentResourcesDesiredStatus.from_str()
    • DeploymentResourcesStatus
      • DeploymentResourcesStatus.PROVISIONED
      • DeploymentResourcesStatus.PROVISIONING
      • DeploymentResourcesStatus.STOPPED
      • DeploymentResourcesStatus.STOPPING
      • DeploymentResourcesStatus.from_str()
    • DeploymentRuntimeDesiredStatus
      • DeploymentRuntimeDesiredStatus.PAUSED
      • DeploymentRuntimeDesiredStatus.RUNNING
      • DeploymentRuntimeDesiredStatus.STANDBY
      • DeploymentRuntimeDesiredStatus.SUSPENDED
      • DeploymentRuntimeDesiredStatus.UNAVAILABLE
      • DeploymentRuntimeDesiredStatus.from_str()
    • DeploymentRuntimeStatus
      • DeploymentRuntimeStatus.AWAITINGAPPROVAL
      • DeploymentRuntimeStatus.BOOTSTRAPPING
      • DeploymentRuntimeStatus.INITIALIZING
      • DeploymentRuntimeStatus.PAUSED
      • DeploymentRuntimeStatus.REPLAYING
      • DeploymentRuntimeStatus.RUNNING
      • DeploymentRuntimeStatus.STANDBY
      • DeploymentRuntimeStatus.SUSPENDED
      • DeploymentRuntimeStatus.UNAVAILABLE
      • DeploymentRuntimeStatus.from_str()
    • FaultToleranceModel
      • FaultToleranceModel.AtLeastOnce
      • FaultToleranceModel.ExactlyOnce
      • FaultToleranceModel.from_str()
    • PipelineFieldSelector
      • PipelineFieldSelector.ALL
      • PipelineFieldSelector.STATUS
    • PipelineStatus
      • PipelineStatus.AWAITINGAPPROVAL
      • PipelineStatus.BOOTSTRAPPING
      • PipelineStatus.INITIALIZING
      • PipelineStatus.NOT_FOUND
      • PipelineStatus.PAUSED
      • PipelineStatus.PROVISIONING
      • PipelineStatus.REPLAYING
      • PipelineStatus.RUNNING
      • PipelineStatus.STANDBY
      • PipelineStatus.STOPPED
      • PipelineStatus.STOPPING
      • PipelineStatus.SUSPENDED
      • 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()
    • TransactionStatus
      • TransactionStatus.CommitInProgress
      • TransactionStatus.NoTransaction
      • TransactionStatus.TransactionInProgress
      • TransactionStatus.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