public class BeamSqlReinterpretExpression extends BeamSqlExpression
BeamSqlExpression
for Reinterpret call.
Currently supported conversions:
- SqlTypeName#DATETIME_TYPES
to BIGINT
;
- SqlTypeName#INTEGER
to BIGINT
;
operands, outputType
Constructor and Description |
---|
BeamSqlReinterpretExpression(java.util.List<BeamSqlExpression> operands,
SqlTypeName outputType) |
Modifier and Type | Method and Description |
---|---|
boolean |
accept()
assertion to make sure the input and output are supported in this expression.
|
BeamSqlPrimitive |
evaluate(BeamRecord inputRow,
BoundedWindow window)
Apply input record
BeamRecord with BoundedWindow to this expression,
the output value is wrapped with BeamSqlPrimitive . |
getOperands, getOutputType, numberOfOperands, op, opType, opValueEvaluated
public BeamSqlReinterpretExpression(java.util.List<BeamSqlExpression> operands, SqlTypeName outputType)
public boolean accept()
BeamSqlExpression
accept
in class BeamSqlExpression
public BeamSqlPrimitive evaluate(BeamRecord inputRow, BoundedWindow window)
BeamSqlExpression
BeamRecord
with BoundedWindow
to this expression,
the output value is wrapped with BeamSqlPrimitive
.evaluate
in class BeamSqlExpression