public class BeamSqlCurrentTimeExpression extends BeamSqlExpression
BeamSqlExpression
for LOCALTIME and CURRENT_TIME.
Returns the current date and time in the session time zone in a value of datatype TIME, with precision digits of precision.
NOTE: for simplicity, we will ignore the precision
param.
operands, outputType
Constructor and Description |
---|
BeamSqlCurrentTimeExpression(java.util.List<BeamSqlExpression> operands) |
Modifier and Type | Method and Description |
---|---|
boolean |
accept()
assertion to make sure the input and output are supported in this expression.
|
BeamSqlPrimitive |
evaluate(Row inputRow,
BoundedWindow window,
BeamSqlExpressionEnvironment env)
Apply input record
Row with BoundedWindow to this expression, the output value
is wrapped with BeamSqlPrimitive . |
getOperands, getOutputType, numberOfOperands, op, opType, opValueEvaluated
public BeamSqlCurrentTimeExpression(java.util.List<BeamSqlExpression> operands)
public boolean accept()
BeamSqlExpression
accept
in class BeamSqlExpression
public BeamSqlPrimitive evaluate(Row inputRow, BoundedWindow window, BeamSqlExpressionEnvironment env)
BeamSqlExpression
Row
with BoundedWindow
to this expression, the output value
is wrapped with BeamSqlPrimitive
.evaluate
in class BeamSqlExpression