Index

B

BuildMode (class in feldera.enums)

C

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

D

delete() (feldera.pipeline.Pipeline method)

delete_pipeline() (feldera.rest.feldera_client.FelderaClient method) DEV (feldera.enums.CompilationProfile attribute)

E

execute() (feldera.pipeline.Pipeline method)

F

FAILED (feldera.enums.PipelineStatus attribute) 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.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 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.PipelineStatus static method)

G

GET (feldera.enums.BuildMode attribute) get() (feldera.pipeline.Pipeline static method) GET_OR_CREATE (feldera.enums.BuildMode attribute)

get_pipeline() (feldera.rest.feldera_client.FelderaClient method) get_pipeline_stats() (feldera.rest.feldera_client.FelderaClient method) get_runtime_config() (feldera.rest.feldera_client.FelderaClient method)

I

INITIALIZING (feldera.enums.PipelineStatus attribute)

input_json() (feldera.pipeline.Pipeline method) input_pandas() (feldera.pipeline.Pipeline method)

L

listen() (feldera.pipeline.Pipeline method)

listen_to_pipeline() (feldera.rest.feldera_client.FelderaClient 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.pipeline feldera.rest.sql_table feldera.rest.sql_view feldera.runtime_config

N

NOT_FOUND (feldera.enums.PipelineStatus attribute)

O

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_pipeline() (feldera.rest.feldera_client.FelderaClient method) PAUSED (feldera.enums.PipelineStatus attribute) Pipeline (class in feldera.pipeline) (class in feldera.rest.pipeline)

PipelineBuilder (class in feldera.pipeline_builder) pipelines() (feldera.rest.feldera_client.FelderaClient method) PipelineStatus (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_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_parquet() (feldera.pipeline.Pipeline method) query_tabular() (feldera.pipeline.Pipeline method)

R

Resources (class in feldera.runtime_config) restart() (feldera.pipeline.Pipeline method)

resume() (feldera.pipeline.Pipeline method) RUNNING (feldera.enums.PipelineStatus attribute) RuntimeConfig (class in feldera.runtime_config)

S

SERVER_DEFAULT (feldera.enums.CompilationProfile attribute) SHUTDOWN (feldera.enums.PipelineStatus attribute) shutdown() (feldera.pipeline.Pipeline method) shutdown_pipeline() (feldera.rest.feldera_client.FelderaClient method) SHUTTING_DOWN (feldera.enums.PipelineStatus 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) status() (feldera.pipeline.Pipeline method)

T

to_dict() (feldera.output_handler.OutputHandler method)

to_pandas() (feldera.output_handler.OutputHandler method)

U

UNAVAILABLE (feldera.enums.PipelineStatus attribute)

UNOPTIMIZED (feldera.enums.CompilationProfile attribute)

W

wait_for_completion() (feldera.pipeline.Pipeline method)

wait_for_idle() (feldera.pipeline.Pipeline method)