Class CoGbkResultSchema
- java.lang.Object
-
- org.apache.beam.sdk.transforms.join.CoGbkResultSchema
-
- All Implemented Interfaces:
java.io.Serializable
public class CoGbkResultSchema extends java.lang.Object implements java.io.Serializable
A schema for the results of aCoGroupByKey
. This maintains the full set ofTupleTag
s for the results of aCoGroupByKey
and facilitates mapping betweenTupleTag
s andRawUnionValue
tags (which are used as secondary keys in theCoGroupByKey
).- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CoGbkResultSchema(TupleTagList tupleTagList)
Builds a schema from a tuple ofTupleTag<?>
s.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(@Nullable java.lang.Object obj)
int
getIndex(TupleTag<?> tag)
Returns the index for the given tuple tag, if the tag is present in this schema, -1 if it isn't.TupleTag<?>
getTag(int index)
Returns the tuple tag at the given index.TupleTagList
getTupleTagList()
Returns the TupleTagList tuple associated with this schema.int
hashCode()
static CoGbkResultSchema
of(java.util.List<TupleTag<?>> tags)
int
size()
Returns the number of columns for this schema.java.lang.String
toString()
-
-
-
Constructor Detail
-
CoGbkResultSchema
public CoGbkResultSchema(TupleTagList tupleTagList)
Builds a schema from a tuple ofTupleTag<?>
s.
-
-
Method Detail
-
of
public static CoGbkResultSchema of(java.util.List<TupleTag<?>> tags)
-
getIndex
public int getIndex(TupleTag<?> tag)
Returns the index for the given tuple tag, if the tag is present in this schema, -1 if it isn't.
-
getTag
public TupleTag<?> getTag(int index)
Returns the tuple tag at the given index.
-
size
public int size()
Returns the number of columns for this schema.
-
getTupleTagList
public TupleTagList getTupleTagList()
Returns the TupleTagList tuple associated with this schema.
-
equals
public boolean equals(@Nullable java.lang.Object obj)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-