GV

GeezerVison

The World Wide Web, restored to 800 pixels of glory.

Home|About|Gaming cabinet|Archives|How it works|Starter sites

On this site

  • Get Started
  • SQL Reference
  • Connectors
  • Python SDK
  • Slack
  • Discord
  • GitHub
  • Introduction
  • Pandas Compatibility
  • Examples
  • feldera
  • feldera package
  • View page source

This view

  • Original page
  • New address

GeezerVison is showing docs.feldera.com — feldera — Feldera Python SDK 0.381.0 documentation

feldera

  • feldera package
    • feldera.pipeline_builder module
      • PipelineBuilder
        • PipelineBuilder.__init__()
        • PipelineBuilder.create()
        • PipelineBuilder.create_or_replace()
    • feldera.pipeline module
      • Pipeline
        • Pipeline.__init__()
        • Pipeline.activate()
        • Pipeline.advance_clock()
        • Pipeline.all()
        • Pipeline.approve()
        • Pipeline.bootstrap_policy()
        • Pipeline.checkpoint()
        • Pipeline.checkpoint_response()
        • Pipeline.checkpoint_status()
        • Pipeline.checkpoints()
        • Pipeline.clear_storage()
        • Pipeline.commit_transaction()
        • Pipeline.completion_token_status()
        • Pipeline.created_at()
        • Pipeline.delete()
        • Pipeline.deployment_config()
        • Pipeline.deployment_desired_status()
        • Pipeline.deployment_error()
        • Pipeline.deployment_location()
        • Pipeline.deployment_resources_desired_status()
        • Pipeline.deployment_resources_status()
        • Pipeline.deployment_runtime_desired_status()
        • Pipeline.deployment_runtime_status()
        • Pipeline.deployment_runtime_status_details()
        • Pipeline.deployment_status_since()
        • Pipeline.description()
        • Pipeline.diff()
        • Pipeline.dismiss_error()
        • Pipeline.errors()
        • Pipeline.event()
        • Pipeline.events()
        • Pipeline.execute()
        • Pipeline.foreach_chunk()
        • Pipeline.generate_completion_token()
        • Pipeline.get()
        • Pipeline.get_samply_profile()
        • Pipeline.id()
        • Pipeline.input_connector_stats()
        • Pipeline.input_json()
        • Pipeline.input_pandas()
        • Pipeline.is_complete()
        • Pipeline.last_successful_checkpoint_sync()
        • Pipeline.listen()
        • Pipeline.logs()
        • Pipeline.metrics()
        • Pipeline.modify()
        • Pipeline.name
        • Pipeline.output_connector_stats()
        • Pipeline.pause()
        • Pipeline.pause_connector()
        • Pipeline.pause_input_connector()
        • Pipeline.pause_output_connector()
        • Pipeline.platform_version()
        • 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_arrow()
        • Pipeline.query_arrow_dicts()
        • Pipeline.query_hash()
        • Pipeline.query_parquet()
        • Pipeline.query_tabular()
        • Pipeline.rebalance()
        • Pipeline.refresh()
        • Pipeline.remote_checkpoints()
        • Pipeline.restart()
        • Pipeline.resume()
        • Pipeline.resume_connector()
        • Pipeline.resume_logs()
        • Pipeline.runtime_config()
        • Pipeline.set_runtime_config()
        • Pipeline.start()
        • Pipeline.start_compaction()
        • Pipeline.start_input_connector()
        • Pipeline.start_output_connector()
        • Pipeline.start_paused()
        • Pipeline.start_samply_profile()
        • Pipeline.start_standby()
        • Pipeline.start_transaction()
        • Pipeline.start_transaction_response()
        • Pipeline.stats()
        • Pipeline.status()
        • Pipeline.stop()
        • Pipeline.storage_status()
        • Pipeline.storage_status_details()
        • Pipeline.support_bundle()
        • Pipeline.sync_checkpoint()
        • Pipeline.sync_checkpoint_response()
        • Pipeline.sync_checkpoint_status()
        • Pipeline.tables()
        • Pipeline.tags()
        • Pipeline.testing_force_update_platform_version()
        • Pipeline.transaction_id()
        • Pipeline.transaction_status()
        • Pipeline.udf_rust()
        • Pipeline.udf_toml()
        • Pipeline.update_runtime()
        • Pipeline.version()
        • Pipeline.views()
        • Pipeline.wait_for_completion()
        • Pipeline.wait_for_idle()
        • Pipeline.wait_for_status()
        • Pipeline.wait_for_token()
    • feldera.enums module
      • BootstrapPolicy
        • BootstrapPolicy.ALLOW
        • BootstrapPolicy.AWAIT_APPROVAL
        • BootstrapPolicy.REJECT
        • BootstrapPolicy.from_str()
      • BuildMode
        • BuildMode.CREATE
        • BuildMode.GET
        • BuildMode.GET_OR_CREATE
      • CheckpointStatus
        • CheckpointStatus.Failure
        • CheckpointStatus.InProgress
        • CheckpointStatus.Success
        • CheckpointStatus.Unknown
        • CheckpointStatus.__init__()
        • CheckpointStatus.get_error()
      • CompilationProfile
        • CompilationProfile.DEV
        • CompilationProfile.OPTIMIZED
        • CompilationProfile.OPTIMIZED_SYMBOLS
        • CompilationProfile.SERVER_DEFAULT
        • CompilationProfile.UNOPTIMIZED
      • CompletionTokenStatus
        • CompletionTokenStatus.COMPLETE
        • CompletionTokenStatus.IN_PROGRESS
      • DeploymentDesiredStatus
        • DeploymentDesiredStatus.PAUSED
        • DeploymentDesiredStatus.RUNNING
        • DeploymentDesiredStatus.STANDBY
        • DeploymentDesiredStatus.STOPPED
        • DeploymentDesiredStatus.SUSPENDED
        • DeploymentDesiredStatus.UNAVAILABLE
        • DeploymentDesiredStatus.from_str()
      • DeploymentResourcesDesiredStatus
        • DeploymentResourcesDesiredStatus.PROVISIONED
        • DeploymentResourcesDesiredStatus.STOPPED
        • DeploymentResourcesDesiredStatus.from_str()
      • DeploymentResourcesStatus
        • DeploymentResourcesStatus.PROVISIONED
        • DeploymentResourcesStatus.PROVISIONING
        • DeploymentResourcesStatus.STOPPED
        • DeploymentResourcesStatus.STOPPING
        • DeploymentResourcesStatus.from_str()
      • DeploymentRuntimeDesiredStatus
        • DeploymentRuntimeDesiredStatus.PAUSED
        • DeploymentRuntimeDesiredStatus.RUNNING
        • DeploymentRuntimeDesiredStatus.STANDBY
        • DeploymentRuntimeDesiredStatus.SUSPENDED
        • DeploymentRuntimeDesiredStatus.UNAVAILABLE
        • DeploymentRuntimeDesiredStatus.from_str()
      • DeploymentRuntimeStatus
        • DeploymentRuntimeStatus.AWAITINGAPPROVAL
        • DeploymentRuntimeStatus.BOOTSTRAPPING
        • DeploymentRuntimeStatus.CONCURRENTBOOTSTRAPPING
        • DeploymentRuntimeStatus.INITIALIZING
        • DeploymentRuntimeStatus.PAUSED
        • DeploymentRuntimeStatus.REPLAYING
        • DeploymentRuntimeStatus.RUNNING
        • DeploymentRuntimeStatus.STANDBY
        • DeploymentRuntimeStatus.SUSPENDED
        • DeploymentRuntimeStatus.SYNCHRONIZING
        • DeploymentRuntimeStatus.UNAVAILABLE
        • DeploymentRuntimeStatus.from_str()
      • FaultToleranceModel
        • FaultToleranceModel.AtLeastOnce
        • FaultToleranceModel.ExactlyOnce
        • FaultToleranceModel.from_str()
      • PipelineFieldSelector
        • PipelineFieldSelector.ALL
        • PipelineFieldSelector.STATUS
      • PipelineStatus
        • PipelineStatus.AWAITINGAPPROVAL
        • PipelineStatus.BOOTSTRAPPING
        • PipelineStatus.CONCURRENTBOOTSTRAPPING
        • PipelineStatus.INITIALIZING
        • PipelineStatus.NOT_FOUND
        • PipelineStatus.PAUSED
        • PipelineStatus.PROVISIONING
        • PipelineStatus.REPLAYING
        • PipelineStatus.RUNNING
        • PipelineStatus.STANDBY
        • PipelineStatus.STOPPED
        • PipelineStatus.STOPPING
        • PipelineStatus.SUSPENDED
        • PipelineStatus.SYNCHRONIZING
        • PipelineStatus.UNAVAILABLE
        • PipelineStatus.from_str()
      • ProgramStatus
        • ProgramStatus.CompilingRust
        • ProgramStatus.CompilingSql
        • ProgramStatus.Pending
        • ProgramStatus.RustError
        • ProgramStatus.SqlCompiled
        • ProgramStatus.SqlError
        • ProgramStatus.Success
        • ProgramStatus.SystemError
        • ProgramStatus.__init__()
        • ProgramStatus.from_value()
        • ProgramStatus.get_error()
      • StorageStatus
        • StorageStatus.CLEARED
        • StorageStatus.CLEARING
        • StorageStatus.INUSE
        • StorageStatus.from_str()
      • TransactionStatus
        • TransactionStatus.CommitInProgress
        • TransactionStatus.NoTransaction
        • TransactionStatus.TransactionInProgress
        • TransactionStatus.from_str()
    • feldera.output_handler module
      • OutputHandler
        • OutputHandler.__init__()
        • OutputHandler.start()
        • OutputHandler.to_dict()
        • OutputHandler.to_pandas()
        • OutputHandler.wait_for_token()
    • feldera.runtime_config module
      • Resources
        • Resources.__init__()
        • Resources.memory_max
        • Resources.memory_mb_max
        • Resources.memory_mb_min
        • Resources.memory_min
        • Resources.storage_max
        • Resources.storage_mb_max
        • Resources.storage_mb_min
        • Resources.storage_min
      • RuntimeConfig
        • RuntimeConfig.__init__()
        • RuntimeConfig.clock_resolution
        • RuntimeConfig.clock_resolution_usecs
        • RuntimeConfig.datafusion_memory
        • RuntimeConfig.datafusion_memory_mb
        • RuntimeConfig.default()
        • RuntimeConfig.from_dict()
        • RuntimeConfig.max_buffering_delay
        • RuntimeConfig.max_buffering_delay_usecs
        • RuntimeConfig.max_rss
        • RuntimeConfig.max_rss_mb
        • RuntimeConfig.provisioning_timeout
        • RuntimeConfig.provisioning_timeout_secs
        • RuntimeConfig.to_dict()
      • Storage
        • Storage.__init__()
        • Storage.min_spill_size
        • Storage.min_storage_bytes
    • feldera.stats module
      • CommitProgressSummary
        • CommitProgressSummary.__init__()
        • CommitProgressSummary.from_dict()
      • CompletedWatermark
        • CompletedWatermark.__init__()
        • CompletedWatermark.from_dict()
      • ConnectorError
        • ConnectorError.__init__()
        • ConnectorError.from_dict()
      • ConnectorHealth
        • ConnectorHealth.HEALTHY
        • ConnectorHealth.UNHEALTHY
        • ConnectorHealth.__init__()
        • ConnectorHealth.from_dict()
      • ConnectorTransactionPhase
        • ConnectorTransactionPhase.__init__()
        • ConnectorTransactionPhase.from_dict()
      • GlobalPipelineMetrics
        • GlobalPipelineMetrics.__init__()
        • GlobalPipelineMetrics.from_dict()
        • GlobalPipelineMetrics.progress_summary()
      • InputEndpointMetrics
        • InputEndpointMetrics.__init__()
        • InputEndpointMetrics.from_dict()
      • InputEndpointStatus
        • InputEndpointStatus.__init__()
        • InputEndpointStatus.from_dict()
      • OutputEndpointMetrics
        • OutputEndpointMetrics.__init__()
        • OutputEndpointMetrics.from_dict()
      • OutputEndpointStatus
        • OutputEndpointStatus.__init__()
        • OutputEndpointStatus.from_dict()
      • PipelineStatistics
        • PipelineStatistics.__init__()
        • PipelineStatistics.from_dict()
      • TransactionInitiators
        • TransactionInitiators.__init__()
        • TransactionInitiators.from_dict()
    • 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.logs module
        • feldera.rest.pipeline module
        • feldera.rest.retry module
        • feldera.rest.sql_table module
        • feldera.rest.sql_view module
        • Module contents
You are visitor 01402503 — GeezerVison does not store the pages you look up.
Best viewed with Netscape Navigator 4.7 or Internet Explorer 6 at 800×600. No cookies required.