Contents:
API Reference:
PipelineBuilder
PipelineBuilder.create()
PipelineBuilder.create_or_replace()
Pipeline
Pipeline.delete()
Pipeline.foreach_chunk()
Pipeline.get()
Pipeline.input_json()
Pipeline.input_pandas()
Pipeline.listen()
Pipeline.pause()
Pipeline.restart()
Pipeline.resume()
Pipeline.shutdown()
Pipeline.start()
Pipeline.status()
Pipeline.wait_for_completion()
Pipeline.wait_for_idle()
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.from_str()
OutputHandler
OutputHandler.start()
OutputHandler.to_dict()
OutputHandler.to_pandas()
Resources
RuntimeConfig
RuntimeConfig.from_dict()