Index

A

ACCEPTED (tests.platform.helper.HTTPStatus attribute) activate() (feldera.pipeline.Pipeline method)

activate_pipeline() (feldera.rest.feldera_client.FelderaClient method) ALREADY_REPORTED (tests.platform.helper.HTTPStatus attribute) AtLeastOnce (feldera.enums.FaultToleranceModel attribute)

B

BAD_GATEWAY (tests.platform.helper.HTTPStatus attribute)

BAD_REQUEST (tests.platform.helper.HTTPStatus attribute) 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) Config (class in feldera.rest.config) CONFLICT (tests.platform.helper.HTTPStatus attribute) connector_action() (in module tests.platform.helper) CONTINUE (tests.platform.helper.HTTPStatus attribute) 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) (in module tests.platform.test_ingress_formats) CREATED (tests.platform.helper.HTTPStatus attribute) created_at() (feldera.pipeline.Pipeline method)

D

default() (feldera.runtime_config.RuntimeConfig static method) delete() (feldera.pipeline.Pipeline method) (in module tests.platform.helper) 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

EARLY_HINTS (tests.platform.helper.HTTPStatus attribute) 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) EXPECTATION_FAILED (tests.platform.helper.HTTPStatus attribute) extract_object_by_name() (in module tests.platform.helper)

F

FAILED_DEPENDENCY (tests.platform.helper.HTTPStatus attribute) 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 fixture_pipeline_name() (in module tests.conftest) FORBIDDEN (tests.platform.helper.HTTPStatus attribute) foreach_chunk() (feldera.pipeline.Pipeline method) FOUND (tests.platform.helper.HTTPStatus attribute) 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) (feldera.enums.TransactionStatus static method) from_value() (feldera.enums.ProgramStatus static method) (feldera.rest.feldera_config.FelderaEdition static method)

G

GATEWAY_TIMEOUT (tests.platform.helper.HTTPStatus attribute) gen_pipeline_name() (in module tests.platform.helper) GET (feldera.enums.BuildMode attribute) get() (feldera.pipeline.Pipeline static method) (in module tests.platform.helper) 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) GONE (tests.platform.helper.HTTPStatus attribute)

H

http_request() (in module tests.platform.helper)

HTTP_VERSION_NOT_SUPPORTED (tests.platform.helper.HTTPStatus attribute) HTTPStatus (class in tests.platform.helper)

I

id() (feldera.pipeline.Pipeline method) IM_A_TEAPOT (tests.platform.helper.HTTPStatus attribute) IM_USED (tests.platform.helper.HTTPStatus attribute) INITIALIZING (feldera.enums.PipelineStatus attribute) InProgress (feldera.enums.CheckpointStatus attribute) input_json() (feldera.pipeline.Pipeline method) input_pandas() (feldera.pipeline.Pipeline method) INSUFFICIENT_STORAGE (tests.platform.helper.HTTPStatus attribute)

INTERNAL_SERVER_ERROR (tests.platform.helper.HTTPStatus attribute) INUSE (feldera.enums.StorageStatus attribute) is_client_error (tests.platform.helper.HTTPStatus property) is_complete() (feldera.pipeline.Pipeline method) is_enterprise() (feldera.rest.feldera_config.FelderaEdition method) is_informational (tests.platform.helper.HTTPStatus property) is_redirection (tests.platform.helper.HTTPStatus property) is_server_error (tests.platform.helper.HTTPStatus property) is_success (tests.platform.helper.HTTPStatus property)

J

JsonLineReader (class in tests.platform.test_ingress_formats)

L

LENGTH_REQUIRED (tests.platform.helper.HTTPStatus attribute) listen() (feldera.pipeline.Pipeline method) listen_to_pipeline() (feldera.rest.feldera_client.FelderaClient method)

localhost() (feldera.rest.feldera_client.FelderaClient static method) LOCKED (tests.platform.helper.HTTPStatus attribute) logs() (feldera.pipeline.Pipeline method) LOOP_DETECTED (tests.platform.helper.HTTPStatus attribute)

M

METHOD_NOT_ALLOWED (tests.platform.helper.HTTPStatus attribute) MISDIRECTED_REQUEST (tests.platform.helper.HTTPStatus attribute) 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 tests tests.conftest tests.platform tests.platform.helper tests.platform.negative_test tests.platform.test_checkpoint_sync tests.platform.test_cluster_health tests.platform.test_completion_tokens tests.platform.test_ingress_formats tests.platform.test_metrics_logs tests.platform.test_orchestration tests.platform.test_pipeline_builder tests.platform.test_pipeline_configs tests.platform.test_pipeline_crud tests.platform.test_shared_pipeline_stress tests.runtime tests.runtime.test_adhoc_queries tests.runtime.test_uda tests.runtime.test_udf tests.shared_test_pipeline

MOVED_PERMANENTLY (tests.platform.helper.HTTPStatus attribute) MULTI_STATUS (tests.platform.helper.HTTPStatus attribute) MULTIPLE_CHOICES (tests.platform.helper.HTTPStatus attribute)

N

name (feldera.pipeline.Pipeline property) NegativeCompilationTests (class in tests.platform.negative_test) NETWORK_AUTHENTICATION_REQUIRED (tests.platform.helper.HTTPStatus attribute) new_pipeline_with_suffix() (tests.shared_test_pipeline.SharedTestPipeline method) NO_CONTENT (tests.platform.helper.HTTPStatus attribute) NON_AUTHORITATIVE_INFORMATION (tests.platform.helper.HTTPStatus attribute)

NOT_ACCEPTABLE (tests.platform.helper.HTTPStatus attribute) NOT_EXTENDED (tests.platform.helper.HTTPStatus attribute) NOT_FOUND (feldera.enums.PipelineStatus attribute) (tests.platform.helper.HTTPStatus attribute) NOT_IMPLEMENTED (tests.platform.helper.HTTPStatus attribute) NOT_MODIFIED (tests.platform.helper.HTTPStatus attribute) NoTransaction (feldera.enums.TransactionStatus attribute)

O

OK (tests.platform.helper.HTTPStatus attribute) OPEN_SOURCE (feldera.rest.feldera_config.FelderaEdition attribute)

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

P

PARTIAL_CONTENT (tests.platform.helper.HTTPStatus attribute) patch_json() (in module tests.platform.helper) 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) PAYMENT_REQUIRED (tests.platform.helper.HTTPStatus attribute) Pending (feldera.enums.ProgramStatus attribute) PERMANENT_REDIRECT (tests.platform.helper.HTTPStatus attribute) Pipeline (class in feldera.pipeline) (class in feldera.rest.pipeline) pipeline (tests.runtime.test_adhoc_queries.TestAdhocQueries property) (tests.shared_test_pipeline.SharedTestPipeline property) PipelineBuilder (class in feldera.pipeline_builder) pipelines() (feldera.rest.feldera_client.FelderaClient method)

PipelineStatus (class in feldera.enums) post_json() (in module tests.platform.helper) PRECONDITION_FAILED (tests.platform.helper.HTTPStatus attribute) PRECONDITION_REQUIRED (tests.platform.helper.HTTPStatus attribute) PROCESSING (tests.platform.helper.HTTPStatus attribute) 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) PROXY_AUTHENTICATION_REQUIRED (tests.platform.helper.HTTPStatus attribute) push_to_pipeline() (feldera.rest.feldera_client.FelderaClient method) put_json() (in module tests.platform.helper)

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

read_events() (tests.platform.test_ingress_formats.JsonLineReader method) refresh() (feldera.pipeline.Pipeline method) REQUEST_ENTITY_TOO_LARGE (tests.platform.helper.HTTPStatus attribute) REQUEST_HEADER_FIELDS_TOO_LARGE (tests.platform.helper.HTTPStatus attribute) REQUEST_TIMEOUT (tests.platform.helper.HTTPStatus attribute) REQUEST_URI_TOO_LONG (tests.platform.helper.HTTPStatus attribute) REQUESTED_RANGE_NOT_SATISFIABLE (tests.platform.helper.HTTPStatus attribute) RESET_CONTENT (tests.platform.helper.HTTPStatus 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) RUNNING (feldera.enums.PipelineStatus attribute) runtime_config() (feldera.pipeline.Pipeline method) RuntimeConfig (class in feldera.runtime_config) RustError (feldera.enums.ProgramStatus attribute)

S

SEE_OTHER (tests.platform.helper.HTTPStatus attribute) SERVER_DEFAULT (feldera.enums.CompilationProfile attribute) SERVICE_UNAVAILABLE (tests.platform.helper.HTTPStatus 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) sql() (in module 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) SWITCHING_PROTOCOLS (tests.platform.helper.HTTPStatus 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) TEMPORARY_REDIRECT (tests.platform.helper.HTTPStatus attribute) test_case_sensitive_tables() (in module tests.platform.test_ingress_formats) test_cluster_health_check() (in module tests.platform.test_cluster_health) test_completion_tokens() (in module tests.platform.test_completion_tokens) test_completion_tokens_with_outputs() (in module tests.platform.test_completion_tokens) test_connector_orchestration() (tests.platform.test_pipeline_builder.TestPipelineBuilder method) test_create_pipeline() (tests.platform.test_shared_pipeline_stress.TestPipeline method) test_duplicate_outputs() (in module tests.platform.test_ingress_formats) test_errors0() (tests.platform.negative_test.NegativeCompilationTests method) test_get_pipeline_logs() (tests.platform.test_shared_pipeline_stress.TestPipeline method) test_health_check() (in module tests.platform.test_cluster_health) test_initialization_error() (tests.platform.negative_test.NegativeCompilationTests method) test_json_ingress() (in module tests.platform.test_ingress_formats) test_local() (tests.runtime.test_udf.TestUDF method) test_map_column() (in module tests.platform.test_ingress_formats) test_parse_datetime() (in module tests.platform.test_ingress_formats) test_pipeline_adhoc_query() (tests.runtime.test_adhoc_queries.TestAdhocQueries method) test_pipeline_adhoc_query_empty() (tests.runtime.test_adhoc_queries.TestAdhocQueries method) test_pipeline_connector_endpoint_naming() (in module tests.platform.test_pipeline_crud) test_pipeline_create_compile_delete() (in module tests.platform.test_pipeline_crud) test_pipeline_get() (in module tests.platform.test_pipeline_crud) test_pipeline_get_selector() (in module tests.platform.test_pipeline_crud) test_pipeline_logs() (in module tests.platform.test_metrics_logs) test_pipeline_metrics() (in module tests.platform.test_metrics_logs) test_pipeline_name_conflict() (in module tests.platform.test_pipeline_crud) test_pipeline_name_invalid() (in module tests.platform.test_pipeline_crud) test_pipeline_orchestration_basic() (in module tests.platform.test_orchestration) test_pipeline_orchestration_errors() (in module tests.platform.test_orchestration) test_pipeline_orchestration_scenarios() (in module tests.platform.test_orchestration) test_pipeline_post() (in module tests.platform.test_pipeline_crud) test_pipeline_program_config() (in module tests.platform.test_pipeline_configs) test_pipeline_runtime_config() (in module tests.platform.test_pipeline_configs) test_pipeline_stats() (in module tests.platform.test_metrics_logs) test_primary_keys() (in module tests.platform.test_ingress_formats) test_program_error0() (tests.platform.negative_test.NegativeCompilationTests method) test_program_error1() (tests.platform.negative_test.NegativeCompilationTests method) test_quoted_columns() (in module tests.platform.test_ingress_formats) test_refresh_version() (in module tests.platform.test_pipeline_crud) test_rust_error() (tests.platform.negative_test.NegativeCompilationTests method) test_sql_error() (tests.platform.negative_test.NegativeCompilationTests method) test_uda() (in module tests.runtime.test_uda) test_upsert() (in module tests.platform.test_ingress_formats) TestAdhocQueries (class in tests.runtime.test_adhoc_queries) TestPipeline (class in tests.platform.test_shared_pipeline_stress) TestPipelineBuilder (class in tests.platform.test_pipeline_builder) tests module

tests.conftest module tests.platform module tests.platform.helper module tests.platform.negative_test module tests.platform.test_checkpoint_sync module tests.platform.test_cluster_health module tests.platform.test_completion_tokens module tests.platform.test_ingress_formats module tests.platform.test_metrics_logs module tests.platform.test_orchestration module tests.platform.test_pipeline_builder module tests.platform.test_pipeline_configs module tests.platform.test_pipeline_crud module tests.platform.test_shared_pipeline_stress module tests.runtime module tests.runtime.test_adhoc_queries module tests.runtime.test_uda module tests.runtime.test_udf module tests.shared_test_pipeline module TestUDF (class in tests.runtime.test_udf) to_dict() (feldera.output_handler.OutputHandler method) (feldera.runtime_config.RuntimeConfig method) to_pandas() (feldera.output_handler.OutputHandler method) TOO_EARLY (tests.platform.helper.HTTPStatus attribute) TOO_MANY_REQUESTS (tests.platform.helper.HTTPStatus attribute) 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) UNAUTHORIZED (tests.platform.helper.HTTPStatus attribute) UNAVAILABLE (feldera.enums.PipelineStatus attribute) UNAVAILABLE_FOR_LEGAL_REASONS (tests.platform.helper.HTTPStatus attribute) unique_pipeline_name() (in module tests) (in module tests.platform.helper)

Unknown (feldera.enums.CheckpointStatus attribute) UNOPTIMIZED (feldera.enums.CompilationProfile attribute) UNPROCESSABLE_ENTITY (tests.platform.helper.HTTPStatus attribute) UNSUPPORTED_MEDIA_TYPE (tests.platform.helper.HTTPStatus attribute) UPGRADE_REQUIRED (tests.platform.helper.HTTPStatus attribute) USE_PROXY (tests.platform.helper.HTTPStatus attribute)

V

VARIANT_ALSO_NEGOTIATES (tests.platform.helper.HTTPStatus attribute)

version() (feldera.pipeline.Pipeline method) views() (feldera.pipeline.Pipeline method)

W

wait_for_completion() (feldera.pipeline.Pipeline method) wait_for_condition() (in module tests.platform.helper)

wait_for_idle() (feldera.pipeline.Pipeline method) wait_for_program_success() (in module tests.platform.helper) wait_for_token() (feldera.rest.feldera_client.FelderaClient method)