apache_beam.portability.api.org.apache.beam.model.pipeline.v1 package¶
Submodules¶
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.beam_runner_api_pb2_grpc module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.beam_runner_api_pb2_urns module
BeamConstantsStandardArtifactsStandardCodersStandardCoders.EnumStandardCoders.Enum.BYTESStandardCoders.Enum.STRING_UTF8StandardCoders.Enum.KVStandardCoders.Enum.BOOLStandardCoders.Enum.VARINTStandardCoders.Enum.DOUBLEStandardCoders.Enum.ITERABLEStandardCoders.Enum.TIMERStandardCoders.Enum.INTERVAL_WINDOWStandardCoders.Enum.LENGTH_PREFIXStandardCoders.Enum.GLOBAL_WINDOWStandardCoders.Enum.WINDOWED_VALUEStandardCoders.Enum.PARAM_WINDOWED_VALUEStandardCoders.Enum.STATE_BACKED_ITERABLEStandardCoders.Enum.CUSTOM_WINDOWStandardCoders.Enum.ROWStandardCoders.Enum.SHARDED_KEYStandardCoders.Enum.NULLABLE
StandardDisplayDataStandardEnvironmentsStandardPTransformsStandardPTransforms.PrimitivesStandardPTransforms.Primitives.PAR_DOStandardPTransforms.Primitives.FLATTENStandardPTransforms.Primitives.GROUP_BY_KEYStandardPTransforms.Primitives.IMPULSEStandardPTransforms.Primitives.ASSIGN_WINDOWSStandardPTransforms.Primitives.TEST_STREAMStandardPTransforms.Primitives.MAP_WINDOWSStandardPTransforms.Primitives.MERGE_WINDOWSStandardPTransforms.Primitives.TO_STRING
StandardPTransforms.DeprecatedPrimitivesStandardPTransforms.CompositesStandardPTransforms.Composites.COMBINE_PER_KEYStandardPTransforms.Composites.COMBINE_GLOBALLYStandardPTransforms.Composites.RESHUFFLEStandardPTransforms.Composites.WRITE_FILESStandardPTransforms.Composites.PUBSUB_READStandardPTransforms.Composites.PUBSUB_WRITEStandardPTransforms.Composites.PUBSUB_WRITE_V2StandardPTransforms.Composites.GROUP_INTO_BATCHES_WITH_SHARDED_KEYStandardPTransforms.Composites.REDISTRIBUTE_BY_KEYStandardPTransforms.Composites.REDISTRIBUTE_ARBITRARILY
StandardPTransforms.CombineComponentsStandardPTransforms.CombineComponents.COMBINE_PER_KEY_PRECOMBINEStandardPTransforms.CombineComponents.COMBINE_PER_KEY_MERGE_ACCUMULATORSStandardPTransforms.CombineComponents.COMBINE_PER_KEY_EXTRACT_OUTPUTSStandardPTransforms.CombineComponents.COMBINE_GROUPED_VALUESStandardPTransforms.CombineComponents.COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS
StandardPTransforms.SplittableParDoComponentsStandardPTransforms.SplittableParDoComponents.PAIR_WITH_RESTRICTIONStandardPTransforms.SplittableParDoComponents.SPLIT_AND_SIZE_RESTRICTIONSStandardPTransforms.SplittableParDoComponents.PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONSStandardPTransforms.SplittableParDoComponents.TRUNCATE_SIZED_RESTRICTION
StandardPTransforms.GroupIntoBatchesComponents
StandardProtocolsStandardProtocols.EnumStandardProtocols.Enum.LEGACY_PROGRESS_REPORTINGStandardProtocols.Enum.PROGRESS_REPORTINGStandardProtocols.Enum.WORKER_STATUSStandardProtocols.Enum.MULTI_CORE_BUNDLE_PROCESSINGStandardProtocols.Enum.SIBLING_WORKERSStandardProtocols.Enum.HARNESS_MONITORING_INFOSStandardProtocols.Enum.CONTROL_REQUEST_ELEMENTS_EMBEDDINGStandardProtocols.Enum.STATE_CACHINGStandardProtocols.Enum.DATA_SAMPLINGStandardProtocols.Enum.SDK_CONSUMING_RECEIVED_DATAStandardProtocols.Enum.ORDERED_LIST_STATE
StandardRequirementsStandardRequirements.EnumStandardRequirements.Enum.REQUIRES_STATEFUL_PROCESSINGStandardRequirements.Enum.REQUIRES_BUNDLE_FINALIZATIONStandardRequirements.Enum.REQUIRES_STABLE_INPUTStandardRequirements.Enum.REQUIRES_TIME_SORTED_INPUTStandardRequirements.Enum.REQUIRES_SPLITTABLE_DOFNStandardRequirements.Enum.REQUIRES_ON_WINDOW_EXPIRATION
StandardResourceHintsStandardRunnerProtocolsStandardSideInputTypesStandardUserStateTypes
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.endpoints_pb2_grpc module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.external_transforms_pb2_grpc module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.external_transforms_pb2_urns module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.metrics_pb2_grpc module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.metrics_pb2_urns module
MonitoringInfoMonitoringInfo.MonitoringInfoLabelsMonitoringInfo.MonitoringInfoLabels.TRANSFORMMonitoringInfo.MonitoringInfoLabels.PCOLLECTIONMonitoringInfo.MonitoringInfoLabels.WINDOWING_STRATEGYMonitoringInfo.MonitoringInfoLabels.CODERMonitoringInfo.MonitoringInfoLabels.ENVIRONMENTMonitoringInfo.MonitoringInfoLabels.NAMESPACEMonitoringInfo.MonitoringInfoLabels.NAMEMonitoringInfo.MonitoringInfoLabels.SERVICEMonitoringInfo.MonitoringInfoLabels.METHODMonitoringInfo.MonitoringInfoLabels.RESOURCEMonitoringInfo.MonitoringInfoLabels.STATUSMonitoringInfo.MonitoringInfoLabels.BIGQUERY_PROJECT_IDMonitoringInfo.MonitoringInfoLabels.BIGQUERY_DATASETMonitoringInfo.MonitoringInfoLabels.BIGQUERY_TABLEMonitoringInfo.MonitoringInfoLabels.BIGQUERY_VIEWMonitoringInfo.MonitoringInfoLabels.BIGQUERY_QUERY_NAMEMonitoringInfo.MonitoringInfoLabels.GCS_BUCKETMonitoringInfo.MonitoringInfoLabels.GCS_PROJECT_IDMonitoringInfo.MonitoringInfoLabels.DATASTORE_PROJECTMonitoringInfo.MonitoringInfoLabels.DATASTORE_NAMESPACEMonitoringInfo.MonitoringInfoLabels.BIGTABLE_PROJECT_IDMonitoringInfo.MonitoringInfoLabels.INSTANCE_IDMonitoringInfo.MonitoringInfoLabels.TABLE_IDMonitoringInfo.MonitoringInfoLabels.SPANNER_PROJECT_IDMonitoringInfo.MonitoringInfoLabels.SPANNER_DATABASE_IDMonitoringInfo.MonitoringInfoLabels.SPANNER_TABLE_IDMonitoringInfo.MonitoringInfoLabels.SPANNER_INSTANCE_IDMonitoringInfo.MonitoringInfoLabels.SPANNER_QUERY_NAME
MonitoringInfoSpecsMonitoringInfoSpecs.EnumMonitoringInfoSpecs.Enum.USER_SUM_INT64MonitoringInfoSpecs.Enum.USER_SUM_DOUBLEMonitoringInfoSpecs.Enum.USER_DISTRIBUTION_INT64MonitoringInfoSpecs.Enum.USER_DISTRIBUTION_DOUBLEMonitoringInfoSpecs.Enum.USER_LATEST_INT64MonitoringInfoSpecs.Enum.USER_LATEST_DOUBLEMonitoringInfoSpecs.Enum.USER_TOP_N_INT64MonitoringInfoSpecs.Enum.USER_TOP_N_DOUBLEMonitoringInfoSpecs.Enum.USER_BOTTOM_N_INT64MonitoringInfoSpecs.Enum.USER_BOTTOM_N_DOUBLEMonitoringInfoSpecs.Enum.USER_SET_STRINGMonitoringInfoSpecs.Enum.ELEMENT_COUNTMonitoringInfoSpecs.Enum.SAMPLED_BYTE_SIZEMonitoringInfoSpecs.Enum.START_BUNDLE_MSECSMonitoringInfoSpecs.Enum.PROCESS_BUNDLE_MSECSMonitoringInfoSpecs.Enum.FINISH_BUNDLE_MSECSMonitoringInfoSpecs.Enum.TOTAL_MSECSMonitoringInfoSpecs.Enum.WORK_REMAININGMonitoringInfoSpecs.Enum.WORK_COMPLETEDMonitoringInfoSpecs.Enum.DATA_CHANNEL_READ_INDEXMonitoringInfoSpecs.Enum.API_REQUEST_COUNTMonitoringInfoSpecs.Enum.API_REQUEST_LATENCIES
MonitoringInfoTypeUrnsMonitoringInfoTypeUrns.EnumMonitoringInfoTypeUrns.Enum.SUM_INT64_TYPEMonitoringInfoTypeUrns.Enum.SUM_DOUBLE_TYPEMonitoringInfoTypeUrns.Enum.DISTRIBUTION_INT64_TYPEMonitoringInfoTypeUrns.Enum.DISTRIBUTION_DOUBLE_TYPEMonitoringInfoTypeUrns.Enum.LATEST_INT64_TYPEMonitoringInfoTypeUrns.Enum.LATEST_DOUBLE_TYPEMonitoringInfoTypeUrns.Enum.TOP_N_INT64_TYPEMonitoringInfoTypeUrns.Enum.TOP_N_DOUBLE_TYPEMonitoringInfoTypeUrns.Enum.BOTTOM_N_INT64_TYPEMonitoringInfoTypeUrns.Enum.BOTTOM_N_DOUBLE_TYPEMonitoringInfoTypeUrns.Enum.PROGRESS_TYPEMonitoringInfoTypeUrns.Enum.SET_STRING_TYPE
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.schema_pb2_grpc module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.schema_pb2_urns module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.standard_window_fns_pb2_grpc module
- apache_beam.portability.api.org.apache.beam.model.pipeline.v1.standard_window_fns_pb2_urns module