apache_beam.portability.api.org.apache.beam.model.job_management.v1 package

Submodules

• apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_artifact_api_pb2_grpc module
  • ArtifactRetrievalServiceStub
  • ArtifactRetrievalServiceServicer
    • ArtifactRetrievalServiceServicer.ResolveArtifacts()
    • ArtifactRetrievalServiceServicer.GetArtifact()
  • add_ArtifactRetrievalServiceServicer_to_server()
  • ArtifactRetrievalService
    • ArtifactRetrievalService.ResolveArtifacts()
    • ArtifactRetrievalService.GetArtifact()
  • ArtifactStagingServiceStub
  • ArtifactStagingServiceServicer
    • ArtifactStagingServiceServicer.ReverseArtifactRetrievalService()
  • add_ArtifactStagingServiceServicer_to_server()
  • ArtifactStagingService
    • ArtifactStagingService.ReverseArtifactRetrievalService()
  • LegacyArtifactStagingServiceStub
  • LegacyArtifactStagingServiceServicer
    • LegacyArtifactStagingServiceServicer.PutArtifact()
    • LegacyArtifactStagingServiceServicer.CommitManifest()
  • add_LegacyArtifactStagingServiceServicer_to_server()
  • LegacyArtifactStagingService
    • LegacyArtifactStagingService.PutArtifact()
    • LegacyArtifactStagingService.CommitManifest()
  • LegacyArtifactRetrievalServiceStub
  • LegacyArtifactRetrievalServiceServicer
    • LegacyArtifactRetrievalServiceServicer.GetManifest()
    • LegacyArtifactRetrievalServiceServicer.GetArtifact()
  • add_LegacyArtifactRetrievalServiceServicer_to_server()
  • LegacyArtifactRetrievalService
    • LegacyArtifactRetrievalService.GetManifest()
    • LegacyArtifactRetrievalService.GetArtifact()
• apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_artifact_api_pb2_urns module
  • CommitManifestResponse
    • CommitManifestResponse.Constants
      • CommitManifestResponse.Constants.NO_ARTIFACTS_STAGED_TOKEN
• apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_expansion_api_pb2_grpc module
  • ExpansionServiceStub
  • ExpansionServiceServicer
    • ExpansionServiceServicer.Expand()
    • ExpansionServiceServicer.DiscoverSchemaTransform()
  • add_ExpansionServiceServicer_to_server()
  • ExpansionService
    • ExpansionService.Expand()
    • ExpansionService.DiscoverSchemaTransform()
• apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_job_api_pb2_grpc module
  • JobServiceStub
  • JobServiceServicer
    • JobServiceServicer.Prepare()
    • JobServiceServicer.Run()
    • JobServiceServicer.GetJobs()
    • JobServiceServicer.GetState()
    • JobServiceServicer.GetPipeline()
    • JobServiceServicer.Cancel()
    • JobServiceServicer.Drain()
    • JobServiceServicer.GetStateStream()
    • JobServiceServicer.GetMessageStream()
    • JobServiceServicer.GetJobMetrics()
    • JobServiceServicer.DescribePipelineOptions()
  • add_JobServiceServicer_to_server()
  • JobService
    • JobService.Prepare()
    • JobService.Run()
    • JobService.GetJobs()
    • JobService.GetState()
    • JobService.GetPipeline()
    • JobService.Cancel()
    • JobService.Drain()
    • JobService.GetStateStream()
    • JobService.GetMessageStream()
    • JobService.GetJobMetrics()
    • JobService.DescribePipelineOptions()