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.


이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.