python

• feldera package
  • feldera.pipeline_builder module
    • PipelineBuilder
      • PipelineBuilder.create()
      • PipelineBuilder.create_or_replace()
  • feldera.pipeline module
    • Pipeline
      • Pipeline.checkpoint()
      • Pipeline.checkpoint_status()
      • Pipeline.created_at()
      • Pipeline.delete()
      • Pipeline.deployment_config()
      • Pipeline.deployment_desired_status()
      • Pipeline.deployment_error()
      • Pipeline.deployment_location()
      • Pipeline.deployment_status_since()
      • Pipeline.description()
      • Pipeline.errors()
      • Pipeline.execute()
      • Pipeline.foreach_chunk()
      • Pipeline.get()
      • Pipeline.id()
      • Pipeline.input_json()
      • Pipeline.input_pandas()
      • Pipeline.listen()
      • Pipeline.name
      • Pipeline.pause()
      • Pipeline.pause_connector()
      • Pipeline.program_binary_url()
      • Pipeline.program_code()
      • Pipeline.program_config()
      • Pipeline.program_error()
      • Pipeline.program_info()
      • Pipeline.program_status()
      • Pipeline.program_status_since()
      • Pipeline.program_version()
      • Pipeline.query()
      • Pipeline.query_parquet()
      • Pipeline.query_tabular()
      • Pipeline.refresh()
      • Pipeline.restart()
      • Pipeline.resume()
      • Pipeline.resume_connector()
      • Pipeline.runtime_config()
      • Pipeline.shutdown()
      • Pipeline.start()
      • Pipeline.status()
      • Pipeline.suspend()
      • Pipeline.sync_checkpoint()
      • Pipeline.sync_checkpoint_status()
      • Pipeline.tables()
      • Pipeline.udf_rust()
      • Pipeline.udf_toml()
      • Pipeline.version()
      • Pipeline.views()
      • Pipeline.wait_for_completion()
      • Pipeline.wait_for_idle()
  • feldera.enums module
    • BuildMode
      • BuildMode.CREATE
      • BuildMode.GET
      • BuildMode.GET_OR_CREATE
    • CheckpointStatus
      • CheckpointStatus.Failure
      • CheckpointStatus.InProgress
      • CheckpointStatus.Success
      • CheckpointStatus.Unknown
      • CheckpointStatus.get_error()
    • CompilationProfile
      • CompilationProfile.DEV
      • CompilationProfile.OPTIMIZED
      • CompilationProfile.SERVER_DEFAULT
      • CompilationProfile.UNOPTIMIZED
    • PipelineStatus
      • PipelineStatus.FAILED
      • PipelineStatus.INITIALIZING
      • PipelineStatus.NOT_FOUND
      • PipelineStatus.PAUSED
      • PipelineStatus.PROVISIONING
      • PipelineStatus.RUNNING
      • PipelineStatus.SHUTDOWN
      • PipelineStatus.SHUTTING_DOWN
      • PipelineStatus.SUSPENDED
      • PipelineStatus.UNAVAILABLE
      • PipelineStatus.from_str()
    • ProgramStatus
      • ProgramStatus.CompilingRust
      • ProgramStatus.CompilingSql
      • ProgramStatus.Pending
      • ProgramStatus.RustError
      • ProgramStatus.SqlCompiled
      • ProgramStatus.SqlError
      • ProgramStatus.Success
      • ProgramStatus.SystemError
      • ProgramStatus.from_value()
      • ProgramStatus.get_error()
  • feldera.output_handler module
    • OutputHandler
      • OutputHandler.start()
      • OutputHandler.to_dict()
      • OutputHandler.to_pandas()
  • feldera.runtime_config module
    • Resources
    • RuntimeConfig
      • RuntimeConfig.from_dict()
    • Storage
  • Subpackages
    • feldera.rest package
      • Submodules
      • 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
      • Module contents
• tests package
  • Subpackages
    • tests.aggregate_tests package
      • Submodules
      • tests.aggregate_tests.aggtst_base module
      • tests.aggregate_tests.atest_register_tests module
      • tests.aggregate_tests.atest_run module
      • tests.aggregate_tests.main module
      • tests.aggregate_tests.test_arg_max module
      • tests.aggregate_tests.test_arg_min module
      • tests.aggregate_tests.test_array module
      • tests.aggregate_tests.test_array_arg_max module
      • tests.aggregate_tests.test_array_arg_min module
      • tests.aggregate_tests.test_array_arr_agg module
      • tests.aggregate_tests.test_array_count module
      • tests.aggregate_tests.test_array_count_col module
      • tests.aggregate_tests.test_array_every module
      • tests.aggregate_tests.test_array_max module
      • tests.aggregate_tests.test_array_min module
      • tests.aggregate_tests.test_array_some module
      • tests.aggregate_tests.test_array_tbl module
      • tests.aggregate_tests.test_avg module
      • tests.aggregate_tests.test_binary_arg_max module
      • tests.aggregate_tests.test_binary_arg_min module
      • tests.aggregate_tests.test_binary_arr_agg module
      • tests.aggregate_tests.test_binary_count module
      • tests.aggregate_tests.test_binary_count_col module
      • tests.aggregate_tests.test_binary_every module
      • tests.aggregate_tests.test_binary_max module
      • tests.aggregate_tests.test_binary_min module
      • tests.aggregate_tests.test_binary_some module
      • tests.aggregate_tests.test_binary_tbl module
      • tests.aggregate_tests.test_bit_and module
      • tests.aggregate_tests.test_bit_or module
      • tests.aggregate_tests.test_bit_xor module
      • tests.aggregate_tests.test_count module
      • tests.aggregate_tests.test_count_col module
      • tests.aggregate_tests.test_decimal_arg_max module
      • tests.aggregate_tests.test_decimal_arg_min module
      • tests.aggregate_tests.test_decimal_arr_agg module
      • tests.aggregate_tests.test_decimal_avg module
      • tests.aggregate_tests.test_decimal_count module
      • tests.aggregate_tests.test_decimal_count_col module
      • tests.aggregate_tests.test_decimal_every module
      • tests.aggregate_tests.test_decimal_max module
      • tests.aggregate_tests.test_decimal_min module
      • tests.aggregate_tests.test_decimal_some module
      • tests.aggregate_tests.test_decimal_stddev_pop module
      • tests.aggregate_tests.test_decimal_stddev_samp module
      • tests.aggregate_tests.test_decimal_sum module
      • tests.aggregate_tests.test_decimal_table module
      • tests.aggregate_tests.test_empty_set module
      • tests.aggregate_tests.test_every module
      • tests.aggregate_tests.test_float_max module
      • tests.aggregate_tests.test_float_min module
      • tests.aggregate_tests.test_float_tbl module
      • tests.aggregate_tests.test_int_table module
      • tests.aggregate_tests.test_map_arg_max module
      • tests.aggregate_tests.test_map_arg_min module
      • tests.aggregate_tests.test_map_arr_agg module
      • tests.aggregate_tests.test_map_count module
      • tests.aggregate_tests.test_map_count_col module
      • tests.aggregate_tests.test_map_every module
      • tests.aggregate_tests.test_map_max module
      • tests.aggregate_tests.test_map_min module
      • tests.aggregate_tests.test_map_some module
      • tests.aggregate_tests.test_map_tbl module
      • tests.aggregate_tests.test_max module
      • tests.aggregate_tests.test_min module
      • tests.aggregate_tests.test_row_arg_max module
      • tests.aggregate_tests.test_row_arg_min module
      • tests.aggregate_tests.test_row_arr_agg module
      • tests.aggregate_tests.test_row_count_col module
      • tests.aggregate_tests.test_row_every module
      • tests.aggregate_tests.test_row_max module
      • tests.aggregate_tests.test_row_min module
      • tests.aggregate_tests.test_row_some module
      • tests.aggregate_tests.test_row_tbl module
      • tests.aggregate_tests.test_some module
      • tests.aggregate_tests.test_stddev_pop module
      • tests.aggregate_tests.test_stddev_samp module
      • tests.aggregate_tests.test_sum module
      • tests.aggregate_tests.test_varbinary_arg_max module
      • tests.aggregate_tests.test_varbinary_arg_min module
      • tests.aggregate_tests.test_varbinary_arr_agg module
      • tests.aggregate_tests.test_varbinary_count module
      • tests.aggregate_tests.test_varbinary_count_col module
      • tests.aggregate_tests.test_varbinary_every module
      • tests.aggregate_tests.test_varbinary_max module
      • tests.aggregate_tests.test_varbinary_min module
      • tests.aggregate_tests.test_varbinary_some module
      • tests.aggregate_tests.test_varbinary_tbl module
      • Module contents
  • Submodules
  • tests.integration_tests module
  • tests.test_pipeline module
  • tests.test_pipeline_builder module
  • tests.test_udf module
  • tests.test_variant module
  • Module contents