public class CoGbkResultSchema
extends java.lang.Object
implements java.io.Serializable
CoGroupByKey
. This maintains the full set of TupleTag
s for the results of a CoGroupByKey
and facilitates mapping between TupleTag
s and RawUnionValue
tags (which are used as secondary keys in the CoGroupByKey
).Constructor and Description |
---|
CoGbkResultSchema(TupleTagList tupleTagList)
Builds a schema from a tuple of
TupleTag<?> s. |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(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() |
public CoGbkResultSchema(TupleTagList tupleTagList)
TupleTag<?>
s.public static CoGbkResultSchema of(java.util.List<TupleTag<?>> tags)
public int getIndex(TupleTag<?> tag)
public TupleTag<?> getTag(int index)
public int size()
public TupleTagList getTupleTagList()
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object