org.apache.beam.runners.spark.structuredstreaming.translation.helpers

Class EncoderHelpers.EncodeUsingBeamCoder<T>

java.lang.Object

org.apache.spark.sql.catalyst.trees.TreeNode<org.apache.spark.sql.catalyst.expressions.Expression>

org.apache.spark.sql.catalyst.expressions.Expression

org.apache.spark.sql.catalyst.expressions.UnaryExpression

org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.EncodeUsingBeamCoder<T>

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.sql.catalyst.expressions.NonSQLExpression, scala.Equals, scala.Product

Enclosing class:

EncoderHelpers

public static class EncoderHelpers.EncodeUsingBeamCoder<T>
extends org.apache.spark.sql.catalyst.expressions.UnaryExpression
implements org.apache.spark.sql.catalyst.expressions.NonSQLExpression, java.io.Serializable

Catalyst Expression that serializes elements using Beam Coder.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EncodeUsingBeamCoder(org.apache.spark.sql.catalyst.expressions.Expression child, Coder<T> coder)

Method Summary

Modifier and Type	Method and Description
boolean	canEqual(java.lang.Object that)
org.apache.spark.sql.catalyst.expressions.Expression	child()
org.apache.spark.sql.types.DataType	dataType()
org.apache.spark.sql.catalyst.expressions.codegen.ExprCode	doGenCode(org.apache.spark.sql.catalyst.expressions.codegen.CodegenContext ctx, org.apache.spark.sql.catalyst.expressions.codegen.ExprCode ev)
static <T> byte[]	encode(boolean isNull, T value, Coder<T> coder) Convert value to byte array (invoked by generated code in doGenCode(CodegenContext, ExprCode)).
boolean	equals(@Nullable java.lang.Object o)
int	hashCode()
int	productArity()
java.lang.Object	productElement(int n)

Methods inherited from class org.apache.spark.sql.catalyst.expressions.UnaryExpression

children, defineCodeGen, eval, foldable, nullable, nullSafeCodeGen, nullSafeEval

Methods inherited from class org.apache.spark.sql.catalyst.expressions.Expression

canonicalized, checkInputDataTypes, childrenResolved, deterministic, eval$default$1, flatArguments, genCode, org$apache$spark$sql$catalyst$expressions$Expression$$reduceCodeSize, prettyName, references, resolved, semanticEquals, semanticHash, simpleString, sql, toString, verboseString

Methods inherited from class org.apache.spark.sql.catalyst.trees.TreeNode

apply, argString, asCode, collect, collectFirst, collectLeaves, containsChild, fastEquals, find, flatMap, foreach, foreachUp, generateTreeString, generateTreeString$default$5, generateTreeString$default$6, innerChildren, jsonFields, makeCopy, map, mapChildren, mapProductIterator, nodeName, numberedTreeString, org$apache$spark$sql$catalyst$trees$TreeNode$$allChildren, org$apache$spark$sql$catalyst$trees$TreeNode$$collectJsonValue$1, org$apache$spark$sql$catalyst$trees$TreeNode$$getNodeNumbered, org$apache$spark$sql$catalyst$trees$TreeNode$$mapChild$1, org$apache$spark$sql$catalyst$trees$TreeNode$$mapChild$2, org$apache$spark$sql$catalyst$trees$TreeNode$$mapTreeNode$1, org$apache$spark$sql$catalyst$trees$TreeNode$$parseToJson, origin, otherCopyArgs, p, prettyJson, productIterator, productPrefix, stringArgs, toJSON, transform, transformDown, transformUp, treeString, treeString, treeString$default$2, verboseStringWithSuffix, withNewChildren

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.catalyst.expressions.NonSQLExpression

sql

Constructor Detail

EncodeUsingBeamCoder

public EncodeUsingBeamCoder(org.apache.spark.sql.catalyst.expressions.Expression child,
                            Coder<T> coder)

Method Detail

child

public org.apache.spark.sql.catalyst.expressions.Expression child()

Specified by:

child in class org.apache.spark.sql.catalyst.expressions.UnaryExpression

doGenCode

public org.apache.spark.sql.catalyst.expressions.codegen.ExprCode doGenCode(org.apache.spark.sql.catalyst.expressions.codegen.CodegenContext ctx,
                                                                            org.apache.spark.sql.catalyst.expressions.codegen.ExprCode ev)

Specified by:

doGenCode in class org.apache.spark.sql.catalyst.expressions.Expression

dataType

public org.apache.spark.sql.types.DataType dataType()

Specified by:

dataType in class org.apache.spark.sql.catalyst.expressions.Expression

productElement

public java.lang.Object productElement(int n)

Specified by:

productElement in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object that)

Specified by:

canEqual in interface scala.Equals

equals

public boolean equals(@Nullable java.lang.Object o)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class org.apache.spark.sql.catalyst.trees.TreeNode<org.apache.spark.sql.catalyst.expressions.Expression>

encode

public static <T> byte[] encode(boolean isNull,
                                T value,
                                Coder<T> coder)

Convert value to byte array (invoked by generated code in doGenCode(CodegenContext, ExprCode)).