Index

A

activate() (feldera.pipeline.Pipeline method)

activate_pipeline() (feldera.rest.feldera_client.FelderaClient method) AtLeastOnce (feldera.enums.FaultToleranceModel attribute)

B

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)

CompilationProfile (class in feldera.enums) CompilingRust (feldera.enums.ProgramStatus attribute) CompilingSql (feldera.enums.ProgramStatus attribute) 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_status_since() (feldera.pipeline.Pipeline method) description() (feldera.pipeline.Pipeline method) DEV (feldera.enums.CompilationProfile attribute)

E

ENTERPRISE (feldera.rest.feldera_config.FelderaEdition attribute) enterprise_only() (in module tests)

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.FaultToleranceModel static method) (feldera.enums.PipelineStatus static method) (feldera.enums.StorageStatus static method) from_value() (feldera.enums.ProgramStatus static method) (feldera.rest.feldera_config.FelderaEdition static method)

G

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) INITIALIZING (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_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

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 tests tests.shared_test_pipeline tests.test_uda

N

name (feldera.pipeline.Pipeline property)

new_pipeline_with_suffix() (tests.shared_test_pipeline.SharedTestPipeline method) NOT_FOUND (feldera.enums.PipelineStatus 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.PipelineStatus attribute) Pending (feldera.enums.ProgramStatus attribute) Pipeline (class in feldera.pipeline) (class in feldera.rest.pipeline) pipeline (tests.shared_test_pipeline.SharedTestPipeline property) PipelineBuilder (class in feldera.pipeline_builder)

pipelines() (feldera.rest.feldera_client.FelderaClient method) PipelineStatus (class in feldera.enums) 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) PROVISIONING (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) 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)

RUNNING (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) setUp() (tests.shared_test_pipeline.SharedTestPipeline method) setUpClass() (tests.shared_test_pipeline.SharedTestPipeline class method) SharedTestPipeline (class in tests.shared_test_pipeline) SqlCompiled (feldera.enums.ProgramStatus attribute) SqlError (feldera.enums.ProgramStatus attribute) SQLTable (class in feldera.rest.sql_table) SQLView (class in feldera.rest.sql_view) start() (feldera.output_handler.OutputHandler method) (feldera.pipeline.Pipeline method) start_pipeline() (feldera.rest.feldera_client.FelderaClient method) start_transaction() (feldera.pipeline.Pipeline method) (feldera.rest.feldera_client.FelderaClient method) stats() (feldera.pipeline.Pipeline method) status() (feldera.pipeline.Pipeline method)

stop() (feldera.pipeline.Pipeline method) stop_pipeline() (feldera.rest.feldera_client.FelderaClient method) STOPPED (feldera.enums.PipelineStatus attribute) STOPPING (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) SUSPENDING (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) tearDown() (tests.shared_test_pipeline.SharedTestPipeline method) test_local() (tests.test_uda.TestUDA method) tests module tests.shared_test_pipeline module

tests.test_uda module TestUDA (class in tests.test_uda) to_dict() (feldera.output_handler.OutputHandler method) (feldera.runtime_config.RuntimeConfig method) to_pandas() (feldera.output_handler.OutputHandler method)

U

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

unique_pipeline_name() (in module tests) Unknown (feldera.enums.CheckpointStatus attribute) UNOPTIMIZED (feldera.enums.CompilationProfile attribute)

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_token() (feldera.rest.feldera_client.FelderaClient method)