CoGbkResult (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.transforms.join

Class CoGbkResult



  • public class CoGbkResult
    extends Object
    A row result of a CoGroupByKey. This is a tuple of Iterables produced for a given key, and these can be accessed in different ways.
    • Constructor Detail

      • CoGbkResult

        public CoGbkResult(CoGbkResultSchema schema,
                           Iterable<RawUnionValue> taggedValues)
        A row in the PCollection resulting from a CoGroupByKey transform. Currently, this row must fit into memory.
        Parameters:
        schema - the set of tuple tags used to refer to input tables and result values
        taggedValues - the raw results from a group-by-key
    • Method Detail

      • isEmpty

        public boolean isEmpty()
      • getAll

        public <V> Iterable<V> getAll(TupleTag<V> tag)
        Returns the values from the table represented by the given TupleTag<V> as an Iterable<V> (which may be empty if there are no results).

        If tag was not part of the original CoGroupByKey, throws an IllegalArgumentException.

      • getOnly

        public <V> V getOnly(TupleTag<V> tag)
        If there is a singleton value for the given tag, returns it. Otherwise, throws an IllegalArgumentException.

        If tag was not part of the original CoGroupByKey, throws an IllegalArgumentException.

      • getOnly

        public <V> V getOnly(TupleTag<V> tag,
                             V defaultValue)
        If there is a singleton value for the given tag, returns it. If there is no value for the given tag, returns the defaultValue.

        If tag was not part of the original CoGroupByKey, throws an IllegalArgumentException.

      • of

        public static <V> CoGbkResult of(TupleTag<V> tag,
                                         List<V> data)
        Returns a new CoGbkResult that contains just the given tag and given data.


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Dataflow