Index

_

__init__() (feldera.enums.CheckpointStatus method) (feldera.enums.ProgramStatus method) (feldera.output_handler.OutputHandler method) (feldera.pipeline.Pipeline method) (feldera.pipeline_builder.PipelineBuilder method) (feldera.rest.config.Config method) (feldera.rest.errors.FelderaAPIError method) (feldera.rest.errors.FelderaCommunicationError method) (feldera.rest.errors.FelderaError method) (feldera.rest.errors.FelderaTimeoutError method) (feldera.rest.feldera_client.FelderaClient method) (feldera.rest.feldera_config.FelderaConfig method) (feldera.rest.pipeline.Pipeline method) (feldera.rest.sql_table.SQLTable method) (feldera.rest.sql_view.SQLView method) (feldera.runtime_config.Resources method) (feldera.runtime_config.RuntimeConfig method) (feldera.runtime_config.Storage method)

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

bootstrap_policy() (feldera.pipeline.Pipeline method) 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) checkpoints() (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_api_key() (feldera.rest.feldera_client.FelderaClient 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) dismiss_error() (feldera.pipeline.Pipeline method) dismiss_error_pipeline() (feldera.rest.feldera_client.FelderaClient method)

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.BootstrapPolicy static method) (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_checkpoints() (feldera.rest.feldera_client.FelderaClient method) get_cluster_event() (feldera.rest.feldera_client.FelderaClient method) get_cluster_events() (feldera.rest.feldera_client.FelderaClient 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) get_samply_profile() (feldera.pipeline.Pipeline method) (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

last_successful_checkpoint_sync() (feldera.pipeline.Pipeline method) 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)

OPTIMIZED_SYMBOLS (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

rebalance() (feldera.pipeline.Pipeline method) rebalance_pipeline() (feldera.rest.feldera_client.FelderaClient method) 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_samply_profile() (feldera.pipeline.Pipeline method) (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)