feldera

• feldera package
  • feldera.pipeline_builder module
    • PipelineBuilder
      • PipelineBuilder.create()
      • PipelineBuilder.create_or_replace()
  • feldera.pipeline module
    • Pipeline
      • Pipeline.delete()
      • Pipeline.execute()
      • Pipeline.foreach_chunk()
      • Pipeline.get()
      • Pipeline.input_json()
      • Pipeline.input_pandas()
      • Pipeline.listen()
      • Pipeline.pause()
      • Pipeline.query()
      • Pipeline.query_parquet()
      • Pipeline.query_tabular()
      • Pipeline.restart()
      • Pipeline.resume()
      • Pipeline.shutdown()
      • Pipeline.start()
      • Pipeline.status()
      • Pipeline.wait_for_completion()
      • Pipeline.wait_for_idle()
  • feldera.enums module
    • BuildMode
      • BuildMode.CREATE
      • BuildMode.GET
      • BuildMode.GET_OR_CREATE
    • 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.UNAVAILABLE
      • PipelineStatus.from_str()
  • feldera.output_handler module
    • OutputHandler
      • OutputHandler.start()
      • OutputHandler.to_dict()
      • OutputHandler.to_pandas()
  • feldera.runtime_config module
    • Resources
    • RuntimeConfig
      • RuntimeConfig.from_dict()
  • Subpackages
    • feldera.rest package
      • Submodules
      • 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
      • Module contents