org.apache.beam.sdk.transforms.display

Interface HasDisplayData

All Known Subinterfaces:

ApplicationNameOptions, AwsOptions, AwsOptions, BeamSqlDataCatalogExample.DCExamplePipelineOptions, BeamSqlPipelineOptions, BigQueryOptions, BlobstoreOptions, CloudResourceManagerOptions, CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>, DataCatalogPipelineOptions, DataflowPipelineDebugOptions, DataflowPipelineOptions, DataflowPipelineWorkerPoolOptions, DataflowProfilingOptions, DataflowWorkerHarnessOptions, DataflowWorkerLoggingOptions, DirectOptions, DirectTestOptions, ExecutorOptions, ExpansionServiceOptions, ExperimentalOptions, FileStagingOptions, FirestoreOptions, FlinkPipelineOptions, GcpOptions, GcsOptions, GoogleApiDebugOptions, HadoopFileSystemOptions, JetPipelineOptions, KafkaIO.Read.FakeFlinkPipelineOptions, KinesisIOOptions, ManualDockerEnvironmentOptions, MetricsOptions, PipelineOptions, PortablePipelineOptions, PubsubOptions, PythonExternalTransformOptions, RemoteEnvironmentOptions, ResourceHintsOptions, S3Options, S3Options, SdkHarnessOptions, SnowflakePipelineOptions, SpannerIO.SpannerChangeStreamOptions, SparkCommonPipelineOptions, SparkContextOptions, SparkPipelineOptions, SparkPortableStreamingPipelineOptions, SparkStructuredStreamingPipelineOptions, StreamingOptions, TestBigQueryOptions, TestDataflowPipelineOptions, TestPipeline.TestValueProviderOptions, TestPipelineOptions, TestPortablePipelineOptions, TestPubsubOptions, TestSparkPipelineOptions, TestUniversalRunner.Options, Twister2PipelineOptions, WordCount.WordCountOptions

All Known Implementing Classes:

AddFields.Inner, AddUuidsTransform, AmqpIO.Read, AmqpIO.Write, AnnotateText, ApproximateCountDistinct.Globally, ApproximateCountDistinct.PerKey, ApproximateDistinct.ApproximateDistinctFn, ApproximateDistinct.GloballyDistinct, ApproximateDistinct.PerKeyDistinct, ApproximateQuantiles.ApproximateQuantilesCombineFn, ApproximateUnique.ApproximateUniqueCombineFn, ApproximateUnique.Globally, ApproximateUnique.PerKey, ArrayAgg.ArrayAggArray, AsJsons, AsJsons.AsJsonsWithFailures, AvroIO.Parse, AvroIO.Parse, AvroIO.ParseAll, AvroIO.ParseAll, AvroIO.ParseFiles, AvroIO.ParseFiles, AvroIO.Read, AvroIO.Read, AvroIO.ReadAll, AvroIO.ReadAll, AvroIO.ReadFiles, AvroIO.ReadFiles, AvroIO.TypedWrite, AvroIO.TypedWrite, AvroIO.Write, AvroIO.Write, AvroSink, AvroSink, AvroSource, AvroSource, BatchStatefulParDoOverrides.BatchStatefulDoFn, BeamBuiltinAggregations.BitXOr, BeamBuiltinAnalyticFunctions.PositionAwareCombineFn, BeamJoinTransforms.JoinAsLookup, BeamRowToBigtableMutation, BeamRowToBigtableMutation.ToBigtableRowFn, BeamSetOperatorRelBase, BeamSetOperatorsTransforms.BeamSqlRow2KvFn, BeamSetOperatorsTransforms.SetOperatorFilteringDoFn, BeamSqlOutputToConsoleFn, BigQueryIO.Read, BigQueryIO.TypedRead, BigQueryIO.Write, BigQueryStorageTableSource, BigtableIO.Read, BigtableIO.ReadChangeStream, BigtableIO.Write, BigtableIO.WriteWithResults, BigtableReadSchemaTransformProvider.BigtableRowToBeamRow, BigtableRowToBeamRow, BigtableRowToBeamRowFlat, BigtableWriteSchemaTransformProvider.GetMutationsFromBeamRow, BlockBasedSource, BoundedReadFromUnboundedSource, BoundedSource, CalendarWindows.DaysWindows, CalendarWindows.MonthsWindows, CalendarWindows.YearsWindows, CassandraIO.Read, CassandraIO.ReadAll, CassandraIO.Write, Cast, CdapIO.Read, CdapIO.Write, CleanUpReadChangeStreamDoFn, ClickHouseIO.Write, CloudVision.AnnotateImagesFromBytes, CloudVision.AnnotateImagesFromBytesWithContext, CloudVision.AnnotateImagesFromGcsUri, CloudVision.AnnotateImagesFromGcsUriWithContext, CoGroup.ExpandCrossProduct, CoGroup.Impl, CoGroupByKey, Combine.AccumulatingCombineFn, Combine.BinaryCombineDoubleFn, Combine.BinaryCombineFn, Combine.BinaryCombineIntegerFn, Combine.BinaryCombineLongFn, Combine.CombineFn, Combine.Globally, Combine.GloballyAsSingletonView, Combine.GroupedValues, Combine.IterableCombineFn, Combine.PerKey, Combine.PerKeyWithHotKeyFanout, Combine.SimpleCombineFn, CombineFns.ComposedCombineFn, CombineFns.ComposedCombineFnWithContext, CombineWithContext.CombineFnWithContext, CompressedSource, ConsoleIO.Write.Unbound, ContextualTextIO.ReadFiles, CountIf.CountIfFn, CovarianceFn, Create.OfValueProvider, Create.TimestampedValues, Create.Values, CreateDataflowView, CreateStream, CreateTables, CsvIO.Write, DataflowRunner.StreamingPCollectionViewWriterFn, DataframeTransform, DatastoreV1.DeleteEntity, DatastoreV1.DeleteKey, DatastoreV1.Read, DatastoreV1.Write, DeadLetteredTransform, DebeziumIO.Read, Deduplicate.KeyedValues, Deduplicate.Values, Deduplicate.WithRepresentativeValues, DetectNewPartitionsDoFn, DetectNewPartitionsDoFn, DicomIO.ReadStudyMetadata, Distinct, Distinct.WithRepresentativeValues, DLPDeidentifyText, DLPInspectText, DLPReidentifyText, DoFn, DropFields.Inner, DynamicAvroDestinations, DynamicAvroDestinations, DynamoDBIO.Read, DynamoDBIO.Read, DynamoDBIO.Write, DynamoDBIO.Write, ElasticsearchIO.BoundedElasticsearchSource, ElasticsearchIO.BulkIO, ElasticsearchIO.DocToBulk, ElasticsearchIO.Read, ElasticsearchIO.Write, EntityToRow, FhirIO.Deidentify, FhirIO.Deidentify.DeidentifyFn, FhirIO.ExecuteBundles, FhirIO.Export, FhirIO.Export.ExportResourcesFn, FhirIO.Import, FhirIO.Read, FhirIO.Search, FhirIO.Write, FhirIOPatientEverything, FileBasedSink, FileBasedSink.DynamicDestinations, FileBasedSource, FileIO.Match, FileIO.MatchAll, FileIO.MatchConfiguration, FileIO.ReadMatches, FileIO.Write, FillGaps, FillGaps.FillGapsDoFn, Filter, Filter.Inner, FilterForMutationDoFn, FirestoreV1.BatchGetDocuments, FirestoreV1.BatchWriteWithDeadLetterQueue, FirestoreV1.BatchWriteWithSummary, FirestoreV1.ListCollectionIds, FirestoreV1.ListDocuments, FirestoreV1.PartitionQuery, FirestoreV1.RunQuery, FixedWindows, FlatMapElements, FlatMapElements.FlatMapWithFailures, Flatten.Iterables, Flatten.PCollections, org.apache.beam.runners.core.construction.ForwardingPTransform, GenerateSequence, GlobalWindows, Group.AggregateCombiner, Group.ByFields, Group.CombineFieldsByFields, Group.CombineFieldsGlobally, Group.CombineGlobally, Group.Global, GroupByKey, GroupIntoBatches, GroupIntoBatches.WithShardedKey, HadoopFormatIO.HadoopInputFormatBoundedSource, HadoopFormatIO.Read, HadoopFormatIO.Write, HBaseIO.Read, HBaseIO.ReadAll, HBaseIO.Write, HBaseIO.WriteRowMutations, HCatalogIO.Read, HCatalogIO.Write, HL7v2IO.HL7v2Read, HL7v2IO.HL7v2Read.FetchHL7v2Message, HL7v2IO.HL7v2Read.FetchHL7v2Message.HL7v2MessageGetFn, HL7v2IO.ListHL7v2Messages, HL7v2IO.Read, HL7v2IO.Read.FetchHL7v2Message, HL7v2IO.Read.FetchHL7v2Message.HL7v2MessageGetFn, HL7v2IO.Write, Impulse, InferableFunction, InfluxDbIO.Read, InfluxDbIO.Write, InitializeDoFn, InitializeDoFn, JdbcIO.DataSourceProviderFromDataSourceConfiguration, JdbcIO.PoolableDataSourceProvider, JdbcIO.Read, JdbcIO.ReadAll, JdbcIO.ReadRows, JdbcIO.ReadWithPartitions, JdbcIO.Write, JdbcIO.WriteVoid, JdbcIO.WriteWithResults, JmsIO.Read, JmsIO.Write, Join.FullOuterJoin, Join.Impl, Join.InnerJoin, Join.LeftOuterJoin, Join.RightOuterJoin, JsonToRow.JsonToRowWithErrFn, JsonToRow.JsonToRowWithErrFn.ParseWithError, KafkaCommitOffset, KafkaIO.Read, KafkaIO.ReadSourceDescriptors, KafkaIO.TypedWithoutMetadata, KafkaIO.Write, KafkaIO.WriteRecords, KafkaReadSchemaTransformProvider.ErrorFn, KafkaSourceConsumerFn, Keys, KinesisIO.Read, KinesisIO.Read, KinesisIO.Write, KinesisIO.Write, KuduIO.Read, KuduIO.Write, KvSwap, LazyAggregateCombineFn, MapElements, MapElements.MapWithFailures, MapKeys, MapValues, MicrobatchSource, MongoDbGridFSIO.Read, MongoDbGridFSIO.Read.BoundedGridFSSource, MongoDbGridFSIO.Write, MongoDbIO.Read, MongoDbIO.Write, MongoDbTable.DocumentToRow, MongoDbTable.RowToDocument, MqttIO.Read, MqttIO.Write, Neo4jIO.DriverProviderFromDriverConfiguration, Neo4jIO.ReadAll, Neo4jIO.WriteUnwind, NonMergingWindowFn, OffsetBasedSource, ParDo.MultiOutput, ParDo.SingleOutput, ParquetIO.Parse, ParquetIO.ParseFiles, ParquetIO.Read, ParseJsons, ParseJsons.ParseJsonsWithFailures, Partition, PartitioningWindowFn, PAssert.DefaultConcludeTransform, PAssert.GroupThenAssert, PAssert.GroupThenAssertForSingleton, PAssert.OneSideInputAssert, PeriodicImpulse, PeriodicSequence, PostProcessingMetricsDoFn, PreparePubsubWriteDoFn, PrepareWrite, PrimitiveParDoSingleFactory.ParDoSingle, ProtoFromBytes, ProtoToBytes, PTransform, PubsubIO.Read, PubsubIO.Write, PubsubIO.Write.PubsubBoundedWriter, PubsubLiteReadSchemaTransformProvider.ErrorFn, PubsubLiteSink, PubsubLiteWriteSchemaTransformProvider.ErrorCounterFn, PubsubUnboundedSink, PubsubUnboundedSource, PulsarIO.Read, PulsarIO.Write, PythonExternalTransform, PythonMap, RabbitMqIO.Read, RabbitMqIO.Write, RampupThrottlingFn, Read.Bounded, Read.Unbounded, ReadAllViaFileBasedSource, ReadAllViaFileBasedSourceTransform, ReadAllViaFileBasedSourceTransform.AbstractReadFileRangesFn, ReadAllViaFileBasedSourceTransform.SplitIntoRangesFn, ReadAllViaFileBasedSourceWithFilename, ReadChangeStreamPartitionDoFn, ReadChangeStreamPartitionDoFn, ReadFromPulsarDoFn, ReadSpannerSchema, RecommendationAICreateCatalogItem, RecommendationAIImportCatalogItems, RecommendationAIImportUserEvents, RecommendationAIPredict, RecommendationAIWriteUserEvent, RedisIO.Read, RedisIO.ReadKeyPatterns, RedisIO.Write, RedisIO.WriteStreams, Regex.AllMatches, Regex.Find, Regex.FindAll, Regex.FindKV, Regex.FindName, Regex.FindNameKV, Regex.Matches, Regex.MatchesKV, Regex.MatchesName, Regex.MatchesNameKV, Regex.ReplaceAll, Regex.ReplaceFirst, Regex.Split, ReifyAsIterable, RenameFields.Inner, Reshuffle, Reshuffle.AssignShardFn, Reshuffle.ViaRandomKey, RowToEntity, RpcQosOptions, RunInference, Sample.FixedSizedSampleFn, Select.Fields, Select.Flattened, Sessions, SimpleFunction, SingleStoreIO.Read, SingleStoreIO.ReadWithPartitions, SingleStoreIO.Write, SketchFrequencies.CountMinSketchFn, SketchFrequencies.GlobalSketch, SketchFrequencies.PerKeySketch, SlidingWindows, SnowflakeIO.Concatenate, SnowflakeIO.DataSourceProviderFromDataSourceConfiguration, SnowflakeIO.Read, SnowflakeIO.Read.CleanTmpFilesFromGcsFn, SnowflakeIO.Read.MapCsvToStringArrayFn, SnowflakeIO.Write, SnsIO.Write, SnsIO.Write, SolrIO.Read, SolrIO.ReadAll, SolrIO.Write, SortValues, Source, SpannerChangestreamsReadSchemaTransformProvider.DataChangeRecordToRow, SpannerIO.CreateTransaction, SpannerIO.Read, SpannerIO.ReadAll, SpannerIO.ReadChangeStream, SpannerIO.Write, SpannerIO.WriteGrouped, SparkReceiverIO.Read, SplunkIO.Write, SqlTransform, SqsIO.Read, SqsIO.Read, SqsIO.Write, SqsIO.Write, StorageApiConvertMessages, StorageApiConvertMessages.ConvertMessagesDoFn, StorageApiFlushAndFinalizeDoFn, StorageApiLoads, StorageApiWriteRecordsInconsistent, StorageApiWritesShardedRecords, StorageApiWriteUnshardedRecords, StreamingInserts, StreamingWriteTables, StringAgg.StringAggByte, StringAgg.StringAggString, SubscribeTransform, TDigestQuantiles.GlobalDigest, TDigestQuantiles.PerKeyDigest, TDigestQuantiles.TDigestQuantilesFn, TestStream, TextIO.Read, TextIO.ReadAll, TextIO.ReadFiles, TextIO.TypedWrite, TextIO.Write, TextSource, TextTableProvider.CsvToRow, TextTableProvider.LinesReadConverter, TextTableProvider.LinesWriteConverter, TFRecordIO.Read, TFRecordIO.ReadFiles, TFRecordIO.Write, ThriftIO.ReadFiles, TikaIO.Parse, TikaIO.ParseFiles, ToJson, Top.TopCombineFn, TVFSlidingWindowFn, TypedCombineFnDelegate, UnboundedSource, UnboundedSourceImpl, UpdateSchemaDestination, UuidDeduplicationTransform, Values, ValueWithRecordId.StripIdsDoFn, VarianceFn, VideoIntelligence.AnnotateVideoFromBytes, VideoIntelligence.AnnotateVideoFromBytesWithContext, VideoIntelligence.AnnotateVideoFromUri, VideoIntelligence.AnnotateVideoFromURIWithContext, View.AsIterable, View.AsList, View.AsMap, View.AsMultimap, View.AsSingleton, View.CreatePCollectionView, View.ToListViewDoFn, Wait.OnSignal, Watch.Growth, Watch.WatchGrowthFn, Window, Window.Assign, WindowFn, WithFailures.ExceptionAsMapHandler, WithFailures.ThrowableHandler, WithKeys, WithKeys, WithTimestamps, WordCount.CountWords, WordCount.FormatAsTextFn, WriteFiles, WriteToPulsarDoFn, XmlIO.Read, XmlIO.ReadFiles, XmlIO.Write, XmlSource

public interface HasDisplayData

Marker interface for PTransforms and components to specify display data used within UIs and diagnostic tools.

Display data is registered by overriding populateDisplayData(DisplayData.Builder) in a component which implements HasDisplayData. Display data is available for PipelineOptions and PTransform implementations.

 @Override
 public void populateDisplayData(DisplayData.Builder builder) {
  super.populateDisplayData(builder);

  builder
     .include(subComponent)
     .add(DisplayData.item("minFilter", 42))
     .addIfNotDefault(DisplayData.item("useTransactions", this.txn), false)
     .add(DisplayData.item("topic", "projects/myproject/topics/mytopic")
       .withLabel("Pub/Sub Topic"))
     .add(DisplayData.item("serviceInstance", "myservice.com/fizzbang")
       .withLinkUrl("http://www.myservice.com/fizzbang"));
 }
 

Display data is optional and may be collected during pipeline construction. It should only be used for informational purposes. Tools and components should not assume that display data will always be collected, or that collected display data will always be displayed.

See Also:

populateDisplayData(DisplayData.Builder)

Method Summary

Modifier and Type	Method and Description
void	populateDisplayData(DisplayData.Builder builder) Register display data for the given transform or component.

Method Detail

populateDisplayData

void populateDisplayData(DisplayData.Builder builder)

Register display data for the given transform or component.

populateDisplayData(DisplayData.Builder) is invoked by Pipeline runners to collect display data via DisplayData.from(HasDisplayData). Implementations may call super.populateDisplayData(builder) in order to register display data in the current namespace, but should otherwise use subcomponent.populateDisplayData(builder) to use the namespace of the subcomponent.

Parameters:

builder - The builder to populate with display data.

See Also:

HasDisplayData