Index

A

activate() (feldera.pipeline.Pipeline method) activate_pipeline() (feldera.rest.feldera_client.FelderaClient method) ALL (feldera.enums.PipelineFieldSelector attribute) all() (feldera.pipeline.Pipeline static method) ALLOW (feldera.enums.BootstrapPolicy attribute)

approve() (feldera.pipeline.Pipeline method) approve_pipeline() (feldera.rest.feldera_client.FelderaClient method) AtLeastOnce (feldera.enums.FaultToleranceModel attribute) AWAIT_APPROVAL (feldera.enums.BootstrapPolicy attribute) AWAITINGAPPROVAL (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute)

B

BOOTSTRAPPING (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute)

BootstrapPolicy (class in feldera.enums) BuildMode (class in feldera.enums)

C

checkpoint() (feldera.pipeline.Pipeline method) checkpoint_pipeline() (feldera.rest.feldera_client.FelderaClient method) checkpoint_pipeline_status() (feldera.rest.feldera_client.FelderaClient method) checkpoint_status() (feldera.pipeline.Pipeline method) CheckpointStatus (class in feldera.enums) clear_storage() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) CLEARED (feldera.enums.StorageStatus attribute) CLEARING (feldera.enums.StorageStatus attribute) commit_transaction() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) CommitInProgress (feldera.enums.TransactionStatus attribute) CompilationProfile (class in feldera.enums)

CompilingRust (feldera.enums.ProgramStatus attribute) CompilingSql (feldera.enums.ProgramStatus attribute) COMPLETE (feldera.enums.CompletionTokenStatus attribute) completion_token_processed() (feldera.rest.feldera_client.FelderaClient method) completion_token_status() (feldera.pipeline.Pipeline method) CompletionTokenStatus (class in feldera.enums) Config (class in feldera.rest.config) CREATE (feldera.enums.BuildMode attribute) create() (feldera.pipeline_builder.PipelineBuilder method) create_or_replace() (feldera.pipeline_builder.PipelineBuilder method) create_or_update_pipeline() (feldera.rest.feldera_client.FelderaClient method) create_pipeline() (feldera.rest.feldera_client.FelderaClient method) created_at() (feldera.pipeline.Pipeline method)

D

default() (feldera.runtime_config.RuntimeConfig static method) delete() (feldera.pipeline.Pipeline method) delete_pipeline() (feldera.rest.feldera_client.FelderaClient method) deployment_config() (feldera.pipeline.Pipeline method) deployment_desired_status() (feldera.pipeline.Pipeline method) deployment_error() (feldera.pipeline.Pipeline method) deployment_location() (feldera.pipeline.Pipeline method) deployment_resources_desired_status() (feldera.pipeline.Pipeline method) deployment_resources_status() (feldera.pipeline.Pipeline method) deployment_runtime_desired_status() (feldera.pipeline.Pipeline method)

deployment_runtime_status() (feldera.pipeline.Pipeline method) deployment_runtime_status_details() (feldera.pipeline.Pipeline method) deployment_status_since() (feldera.pipeline.Pipeline method) DeploymentDesiredStatus (class in feldera.enums) DeploymentResourcesDesiredStatus (class in feldera.enums) DeploymentResourcesStatus (class in feldera.enums) DeploymentRuntimeDesiredStatus (class in feldera.enums) DeploymentRuntimeStatus (class in feldera.enums) description() (feldera.pipeline.Pipeline method) DEV (feldera.enums.CompilationProfile attribute)

E

ENTERPRISE (feldera.rest.feldera_config.FelderaEdition attribute) errors() (feldera.pipeline.Pipeline method)

ExactlyOnce (feldera.enums.FaultToleranceModel attribute) execute() (feldera.pipeline.Pipeline method)

F

Failure (feldera.enums.CheckpointStatus attribute) FaultToleranceModel (class in feldera.enums) feldera.enums module feldera.output_handler module feldera.pipeline module feldera.pipeline_builder module feldera.rest module 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

feldera.runtime_config module FelderaAPIError FelderaClient (class in feldera.rest.feldera_client) FelderaCommunicationError FelderaConfig (class in feldera.rest.feldera_config) FelderaEdition (class in feldera.rest.feldera_config) FelderaError FelderaTimeoutError foreach_chunk() (feldera.pipeline.Pipeline method) from_dict() (feldera.rest.pipeline.Pipeline class method) (feldera.rest.sql_table.SQLTable class method) (feldera.rest.sql_view.SQLView class method) (feldera.runtime_config.RuntimeConfig class method) from_str() (feldera.enums.DeploymentDesiredStatus static method) (feldera.enums.DeploymentResourcesDesiredStatus static method) (feldera.enums.DeploymentResourcesStatus static method) (feldera.enums.DeploymentRuntimeDesiredStatus static method) (feldera.enums.DeploymentRuntimeStatus static method) (feldera.enums.FaultToleranceModel static method) (feldera.enums.PipelineStatus static method) (feldera.enums.StorageStatus static method) (feldera.enums.TransactionStatus static method) from_value() (feldera.enums.ProgramStatus static method) (feldera.rest.feldera_config.FelderaEdition static method)

G

generate_completion_token() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) GET (feldera.enums.BuildMode attribute) get() (feldera.pipeline.Pipeline static method) get_config() (feldera.rest.feldera_client.FelderaClient method) get_error() (feldera.enums.CheckpointStatus method) (feldera.enums.ProgramStatus method)

GET_OR_CREATE (feldera.enums.BuildMode attribute) get_pipeline() (feldera.rest.feldera_client.FelderaClient method) get_pipeline_logs() (feldera.rest.feldera_client.FelderaClient method) get_pipeline_stats() (feldera.rest.feldera_client.FelderaClient method) get_pipeline_support_bundle() (feldera.rest.feldera_client.FelderaClient method) get_runtime_config() (feldera.rest.feldera_client.FelderaClient method)

I

id() (feldera.pipeline.Pipeline method) IN_PROGRESS (feldera.enums.CompletionTokenStatus attribute) INITIALIZING (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute) InProgress (feldera.enums.CheckpointStatus attribute)

input_json() (feldera.pipeline.Pipeline method) input_pandas() (feldera.pipeline.Pipeline method) INUSE (feldera.enums.StorageStatus attribute) is_complete() (feldera.pipeline.Pipeline method) is_enterprise() (feldera.rest.feldera_config.FelderaEdition method)

L

listen() (feldera.pipeline.Pipeline method) listen_to_pipeline() (feldera.rest.feldera_client.FelderaClient method)

localhost() (feldera.rest.feldera_client.FelderaClient static method) logs() (feldera.pipeline.Pipeline method)

M

modify() (feldera.pipeline.Pipeline method) module feldera.enums feldera.output_handler feldera.pipeline feldera.pipeline_builder feldera.rest feldera.rest.config feldera.rest.errors feldera.rest.feldera_client feldera.rest.feldera_config feldera.rest.pipeline feldera.rest.sql_table feldera.rest.sql_view feldera.runtime_config

N

name (feldera.pipeline.Pipeline property)

NOT_FOUND (feldera.enums.PipelineStatus attribute) NoTransaction (feldera.enums.TransactionStatus attribute)

O

OPEN_SOURCE (feldera.rest.feldera_config.FelderaEdition attribute)

OPTIMIZED (feldera.enums.CompilationProfile attribute) OutputHandler (class in feldera.output_handler)

P

patch_pipeline() (feldera.rest.feldera_client.FelderaClient method) pause() (feldera.pipeline.Pipeline method) pause_connector() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) pause_pipeline() (feldera.rest.feldera_client.FelderaClient method) PAUSED (feldera.enums.DeploymentDesiredStatus attribute) (feldera.enums.DeploymentRuntimeDesiredStatus attribute) (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute) Pending (feldera.enums.ProgramStatus attribute) Pipeline (class in feldera.pipeline) (class in feldera.rest.pipeline) PipelineBuilder (class in feldera.pipeline_builder) PipelineFieldSelector (class in feldera.enums) pipelines() (feldera.rest.feldera_client.FelderaClient method)

PipelineStatus (class in feldera.enums) platform_version() (feldera.pipeline.Pipeline method) program_code() (feldera.pipeline.Pipeline method) program_config() (feldera.pipeline.Pipeline method) program_error() (feldera.pipeline.Pipeline method) program_info() (feldera.pipeline.Pipeline method) program_status() (feldera.pipeline.Pipeline method) program_status_since() (feldera.pipeline.Pipeline method) program_version() (feldera.pipeline.Pipeline method) ProgramStatus (class in feldera.enums) PROVISIONED (feldera.enums.DeploymentResourcesDesiredStatus attribute) (feldera.enums.DeploymentResourcesStatus attribute) PROVISIONING (feldera.enums.DeploymentResourcesStatus attribute) (feldera.enums.PipelineStatus attribute) push_to_pipeline() (feldera.rest.feldera_client.FelderaClient method)

Q

query() (feldera.pipeline.Pipeline method) query_as_hash() (feldera.rest.feldera_client.FelderaClient method) query_as_json() (feldera.rest.feldera_client.FelderaClient method) query_as_parquet() (feldera.rest.feldera_client.FelderaClient method)

query_as_text() (feldera.rest.feldera_client.FelderaClient method) query_hash() (feldera.pipeline.Pipeline method) query_parquet() (feldera.pipeline.Pipeline method) query_tabular() (feldera.pipeline.Pipeline method)

R

refresh() (feldera.pipeline.Pipeline method) REJECT (feldera.enums.BootstrapPolicy attribute) REPLAYING (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute) Resources (class in feldera.runtime_config) restart() (feldera.pipeline.Pipeline method) resume() (feldera.pipeline.Pipeline method) resume_connector() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method)

resume_pipeline() (feldera.rest.feldera_client.FelderaClient method) RUNNING (feldera.enums.DeploymentDesiredStatus attribute) (feldera.enums.DeploymentRuntimeDesiredStatus attribute) (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute) runtime_config() (feldera.pipeline.Pipeline method) RuntimeConfig (class in feldera.runtime_config) RustError (feldera.enums.ProgramStatus attribute)

S

SERVER_DEFAULT (feldera.enums.CompilationProfile attribute) set_runtime_config() (feldera.pipeline.Pipeline method) SqlCompiled (feldera.enums.ProgramStatus attribute) SqlError (feldera.enums.ProgramStatus attribute) SQLTable (class in feldera.rest.sql_table) SQLView (class in feldera.rest.sql_view) STANDBY (feldera.enums.DeploymentDesiredStatus attribute) (feldera.enums.DeploymentRuntimeDesiredStatus attribute) (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute) start() (feldera.output_handler.OutputHandler method) (feldera.pipeline.Pipeline method) start_paused() (feldera.pipeline.Pipeline method) start_pipeline() (feldera.rest.feldera_client.FelderaClient method) start_pipeline_as_paused() (feldera.rest.feldera_client.FelderaClient method) start_pipeline_as_standby() (feldera.rest.feldera_client.FelderaClient method) start_standby() (feldera.pipeline.Pipeline method) start_transaction() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) stats() (feldera.pipeline.Pipeline method) STATUS (feldera.enums.PipelineFieldSelector attribute) status() (feldera.pipeline.Pipeline method)

stop() (feldera.pipeline.Pipeline method) stop_pipeline() (feldera.rest.feldera_client.FelderaClient method) STOPPED (feldera.enums.DeploymentDesiredStatus attribute) (feldera.enums.DeploymentResourcesDesiredStatus attribute) (feldera.enums.DeploymentResourcesStatus attribute) (feldera.enums.PipelineStatus attribute) STOPPING (feldera.enums.DeploymentResourcesStatus attribute) (feldera.enums.PipelineStatus attribute) Storage (class in feldera.runtime_config) storage_status() (feldera.pipeline.Pipeline method) StorageStatus (class in feldera.enums) Success (feldera.enums.CheckpointStatus attribute) (feldera.enums.ProgramStatus attribute) support_bundle() (feldera.pipeline.Pipeline method) SUSPENDED (feldera.enums.DeploymentDesiredStatus attribute) (feldera.enums.DeploymentRuntimeDesiredStatus attribute) (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute) sync_checkpoint() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) sync_checkpoint_status() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) SystemError (feldera.enums.ProgramStatus attribute)

T

tables() (feldera.pipeline.Pipeline method) testing_force_update_platform_version() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) to_dict() (feldera.output_handler.OutputHandler method) (feldera.runtime_config.RuntimeConfig method)

to_pandas() (feldera.output_handler.OutputHandler method) transaction_id() (feldera.pipeline.Pipeline method) transaction_status() (feldera.pipeline.Pipeline method) TransactionInProgress (feldera.enums.TransactionStatus attribute) TransactionStatus (class in feldera.enums)

U

udf_rust() (feldera.pipeline.Pipeline method) udf_toml() (feldera.pipeline.Pipeline method) UNAVAILABLE (feldera.enums.DeploymentDesiredStatus attribute) (feldera.enums.DeploymentRuntimeDesiredStatus attribute) (feldera.enums.DeploymentRuntimeStatus attribute) (feldera.enums.PipelineStatus attribute)

Unknown (feldera.enums.CheckpointStatus attribute) UNOPTIMIZED (feldera.enums.CompilationProfile attribute) update_pipeline_runtime() (feldera.rest.feldera_client.FelderaClient method) update_runtime() (feldera.pipeline.Pipeline method)

V

version() (feldera.pipeline.Pipeline method)

views() (feldera.pipeline.Pipeline method)

W

wait_for_completion() (feldera.pipeline.Pipeline method) wait_for_idle() (feldera.pipeline.Pipeline method)

wait_for_status() (feldera.pipeline.Pipeline method) wait_for_token() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method)