class Join extends TBase[Join, _Fields] with Serializable with Cloneable with Comparable[Join]
Autogenerated by Thrift Compiler (0.13.0)
DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- Annotations
- @SuppressWarnings() @Generated()
- Alphabetic
- By Inheritance
- Join
- Cloneable
- TBase
- Serializable
- TSerializable
- Comparable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addToBootstrapParts(elem: BootstrapPart): Unit
- def addToDerivations(elem: Derivation): Unit
- def addToJoinParts(elem: JoinPart): Unit
- def addToOnlineExternalParts(elem: ExternalPart): Unit
- def addToRowIds(elem: String): Unit
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clear(): Unit
- Definition Classes
- Join → TBase
- Annotations
- @Override()
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def compareTo(other: Join): Int
- Definition Classes
- Join → Comparable
- Annotations
- @Override()
- def deepCopy(): Join
- Definition Classes
- Join → TBase
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(that: Join): Boolean
- def equals(that: AnyRef): Boolean
- Definition Classes
- Join → AnyRef → Any
- Annotations
- @Override()
- def fieldForId(fieldId: Int): _Fields
- Definition Classes
- Join → TBase
- Annotations
- @Nullable()
- def getBootstrapParts(): List[BootstrapPart]
- Annotations
- @Nullable()
- def getBootstrapPartsIterator(): Iterator[BootstrapPart]
- Annotations
- @Nullable()
- def getBootstrapPartsSize(): Int
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def getDerivations(): List[Derivation]
List of a struct with derived column name and the expression based on joinPart / externalPart columns The expression can be any valid Spark SQL select clause without aggregation functions.
List of a struct with derived column name and the expression based on joinPart / externalPart columns The expression can be any valid Spark SQL select clause without aggregation functions.
joinPart column names are automatically constructed according to the below convention
{join_part_prefix}_{group_by_name}_{input_column_name}_{aggregation_operation}_{window}_{by_bucket}prefix, window and bucket are optional. You can find the type information of columns using the analyzer tool.externalPart column names are automatically constructed according to the below convention
ext_{external_source_name}_{value_column}Types are defined along with the schema by users for external sources.Including a column with key "*" and value "*", means that every raw column will be included along with the derived columns.
- Annotations
- @Nullable()
- def getDerivationsIterator(): Iterator[Derivation]
- Annotations
- @Nullable()
- def getDerivationsSize(): Int
- def getFieldValue(field: _Fields): AnyRef
- Definition Classes
- Join → TBase
- Annotations
- @Nullable()
- def getJoinParts(): List[JoinPart]
- Annotations
- @Nullable()
- def getJoinPartsIterator(): Iterator[JoinPart]
- Annotations
- @Nullable()
- def getJoinPartsSize(): Int
- def getLabelPart(): LabelPart
- Annotations
- @Nullable()
- def getLeft(): Source
- Annotations
- @Nullable()
- def getMetaData(): MetaData
- Annotations
- @Nullable()
- def getModelTransforms(): ModelTransforms
(CHIP-9) A list of model_trnsforms that will convert derivations (raw data) into model outputs for each of the models in the list.
(CHIP-9) A list of model_trnsforms that will convert derivations (raw data) into model outputs for each of the models in the list. The union of the model outputs will become the final output of the join.
- Annotations
- @Nullable()
- def getOnlineExternalParts(): List[ExternalPart]
- Annotations
- @Nullable()
- def getOnlineExternalPartsIterator(): Iterator[ExternalPart]
- Annotations
- @Nullable()
- def getOnlineExternalPartsSize(): Int
- def getRowIds(): List[String]
- Annotations
- @Nullable()
- def getRowIdsIterator(): Iterator[String]
- Annotations
- @Nullable()
- def getRowIdsSize(): Int
- def getSkewKeys(): Map[String, List[String]]
- Annotations
- @Nullable()
- def getSkewKeysSize(): Int
- def hashCode(): Int
- Definition Classes
- Join → AnyRef → Any
- Annotations
- @Override()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isSet(field: _Fields): Boolean
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
- Definition Classes
- Join → TBase
- def isSetBootstrapParts(): Boolean
Returns true if field bootstrapParts is set (has been assigned a value) and false otherwise
- def isSetDerivations(): Boolean
Returns true if field derivations is set (has been assigned a value) and false otherwise
- def isSetJoinParts(): Boolean
Returns true if field joinParts is set (has been assigned a value) and false otherwise
- def isSetLabelPart(): Boolean
Returns true if field labelPart is set (has been assigned a value) and false otherwise
- def isSetLeft(): Boolean
Returns true if field left is set (has been assigned a value) and false otherwise
- def isSetMetaData(): Boolean
Returns true if field metaData is set (has been assigned a value) and false otherwise
- def isSetModelTransforms(): Boolean
Returns true if field modelTransforms is set (has been assigned a value) and false otherwise
- def isSetOnlineExternalParts(): Boolean
Returns true if field onlineExternalParts is set (has been assigned a value) and false otherwise
- def isSetRowIds(): Boolean
Returns true if field rowIds is set (has been assigned a value) and false otherwise
- def isSetSkewKeys(): Boolean
Returns true if field skewKeys is set (has been assigned a value) and false otherwise
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def putToSkewKeys(key: String, val: List[String]): Unit
- def read(iprot: TProtocol): Unit
- Definition Classes
- Join → TSerializable
- def setBootstrapParts(bootstrapParts: List[BootstrapPart]): Join
- def setBootstrapPartsIsSet(value: Boolean): Unit
- def setDerivations(derivations: List[Derivation]): Join
List of a struct with derived column name and the expression based on joinPart / externalPart columns The expression can be any valid Spark SQL select clause without aggregation functions.
List of a struct with derived column name and the expression based on joinPart / externalPart columns The expression can be any valid Spark SQL select clause without aggregation functions.
joinPart column names are automatically constructed according to the below convention
{join_part_prefix}_{group_by_name}_{input_column_name}_{aggregation_operation}_{window}_{by_bucket}prefix, window and bucket are optional. You can find the type information of columns using the analyzer tool.externalPart column names are automatically constructed according to the below convention
ext_{external_source_name}_{value_column}Types are defined along with the schema by users for external sources.Including a column with key "*" and value "*", means that every raw column will be included along with the derived columns.
- def setDerivationsIsSet(value: Boolean): Unit
- def setFieldValue(field: _Fields, value: AnyRef): Unit
- Definition Classes
- Join → TBase
- def setJoinParts(joinParts: List[JoinPart]): Join
- def setJoinPartsIsSet(value: Boolean): Unit
- def setLabelPart(labelPart: LabelPart): Join
- def setLabelPartIsSet(value: Boolean): Unit
- def setLeft(left: Source): Join
- def setLeftIsSet(value: Boolean): Unit
- def setMetaData(metaData: MetaData): Join
- def setMetaDataIsSet(value: Boolean): Unit
- def setModelTransforms(modelTransforms: ModelTransforms): Join
(CHIP-9) A list of model_trnsforms that will convert derivations (raw data) into model outputs for each of the models in the list.
(CHIP-9) A list of model_trnsforms that will convert derivations (raw data) into model outputs for each of the models in the list. The union of the model outputs will become the final output of the join.
- def setModelTransformsIsSet(value: Boolean): Unit
- def setOnlineExternalParts(onlineExternalParts: List[ExternalPart]): Join
- def setOnlineExternalPartsIsSet(value: Boolean): Unit
- def setRowIds(rowIds: List[String]): Join
- def setRowIdsIsSet(value: Boolean): Unit
- def setSkewKeys(skewKeys: Map[String, List[String]]): Join
- def setSkewKeysIsSet(value: Boolean): Unit
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- Join → AnyRef → Any
- Annotations
- @Override()
- def unsetBootstrapParts(): Unit
- def unsetDerivations(): Unit
- def unsetJoinParts(): Unit
- def unsetLabelPart(): Unit
- def unsetLeft(): Unit
- def unsetMetaData(): Unit
- def unsetModelTransforms(): Unit
- def unsetOnlineExternalParts(): Unit
- def unsetRowIds(): Unit
- def unsetSkewKeys(): Unit
- def validate(): Unit
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def write(oprot: TProtocol): Unit
- Definition Classes
- Join → TSerializable
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated