[SPARK-35889][SQL] Support adding TimestampWithoutTZ with Interval types
### What changes were proposed in this pull request? Supprot the following operations: - TimestampWithoutTZ + Calendar interval - TimestampWithoutTZ + Year-Month interval - TimestampWithoutTZ + Daytime interval ### Why are the changes needed? Support basic '+' operator for timestamp without time zone type. ### Does this PR introduce _any_ user-facing change? No, the timestamp without time zone type is not release yet. ### How was this patch tested? Unit tests Closes #33076 from gengliangwang/addForNewTS. Authored-by: Gengliang Wang <gengliang@apache.org> Signed-off-by: Gengliang Wang <gengliang@apache.org>
This commit is contained in:
Gengliang Wang
parent
f2029e7442
commit
9814cf8853
|
|
@ -357,8 +357,10 @@ class Analyzer(override val catalogManager: CatalogManager)
|
|||
case (_: DayTimeIntervalType, DateType) => TimeAdd(Cast(r, TimestampType), l)
|
||||
case (DateType, _: YearMonthIntervalType) => DateAddYMInterval(l, r)
|
||||
case (_: YearMonthIntervalType, DateType) => DateAddYMInterval(r, l)
|
||||
case (TimestampType, _: YearMonthIntervalType) => TimestampAddYMInterval(l, r)
|
||||
case (_: YearMonthIntervalType, TimestampType) => TimestampAddYMInterval(r, l)
|
||||
case (TimestampType | TimestampWithoutTZType, _: YearMonthIntervalType) =>
|
||||
TimestampAddYMInterval(l, r)
|
||||
case (_: YearMonthIntervalType, TimestampType | TimestampWithoutTZType) =>
|
||||
TimestampAddYMInterval(r, l)
|
||||
case (CalendarIntervalType, CalendarIntervalType) |
|
||||
(_: DayTimeIntervalType, _: DayTimeIntervalType) => a
|
||||
case (DateType, CalendarIntervalType) => DateAddInterval(l, r, ansiEnabled = f)
|
||||
|
|
|
|||
|
|
@ -59,6 +59,11 @@ trait TimeZoneAwareExpression extends Expression {
|
|||
def withTimeZone(timeZoneId: String): TimeZoneAwareExpression
|
||||
|
||||
@transient lazy val zoneId: ZoneId = DateTimeUtils.getZoneId(timeZoneId.get)
|
||||
|
||||
def zoneIdForType(dataType: DataType): ZoneId = dataType match {
|
||||
case _: TimestampWithoutTZType => java.time.ZoneOffset.UTC
|
||||
case _ => zoneId
|
||||
}
|
||||
}
|
||||
|
||||
trait TimestampFormatterHelper extends TimeZoneAwareExpression {
|
||||
|
|
@ -1446,23 +1451,25 @@ case class TimeAdd(start: Expression, interval: Expression, timeZoneId: Option[S
|
|||
override def toString: String = s"$left + $right"
|
||||
override def sql: String = s"${left.sql} + ${right.sql}"
|
||||
override def inputTypes: Seq[AbstractDataType] =
|
||||
Seq(TimestampType, TypeCollection(CalendarIntervalType, DayTimeIntervalType))
|
||||
Seq(TypeCollection.AllTimestampTypes, TypeCollection(CalendarIntervalType, DayTimeIntervalType))
|
||||
|
||||
override def dataType: DataType = TimestampType
|
||||
override def dataType: DataType = start.dataType
|
||||
|
||||
override def withTimeZone(timeZoneId: String): TimeZoneAwareExpression =
|
||||
copy(timeZoneId = Option(timeZoneId))
|
||||
|
||||
@transient private lazy val zoneIdInEval: ZoneId = zoneIdForType(left.dataType)
|
||||
|
||||
override def nullSafeEval(start: Any, interval: Any): Any = right.dataType match {
|
||||
case _: DayTimeIntervalType =>
|
||||
timestampAddDayTime(start.asInstanceOf[Long], interval.asInstanceOf[Long], zoneId)
|
||||
timestampAddDayTime(start.asInstanceOf[Long], interval.asInstanceOf[Long], zoneIdInEval)
|
||||
case CalendarIntervalType =>
|
||||
val i = interval.asInstanceOf[CalendarInterval]
|
||||
timestampAddInterval(start.asInstanceOf[Long], i.months, i.days, i.microseconds, zoneId)
|
||||
timestampAddInterval(start.asInstanceOf[Long], i.months, i.days, i.microseconds, zoneIdInEval)
|
||||
}
|
||||
|
||||
override def doGenCode(ctx: CodegenContext, ev: ExprCode): ExprCode = {
|
||||
val zid = ctx.addReferenceObj("zoneId", zoneId, classOf[ZoneId].getName)
|
||||
val zid = ctx.addReferenceObj("zoneId", zoneIdInEval, classOf[ZoneId].getName)
|
||||
val dtu = DateTimeUtils.getClass.getName.stripSuffix("$")
|
||||
interval.dataType match {
|
||||
case _: DayTimeIntervalType =>
|
||||
|
|
@ -1749,19 +1756,22 @@ case class TimestampAddYMInterval(
|
|||
|
||||
override def toString: String = s"$left + $right"
|
||||
override def sql: String = s"${left.sql} + ${right.sql}"
|
||||
override def inputTypes: Seq[AbstractDataType] = Seq(TimestampType, YearMonthIntervalType)
|
||||
override def inputTypes: Seq[AbstractDataType] =
|
||||
Seq(TypeCollection.AllTimestampTypes, YearMonthIntervalType)
|
||||
|
||||
override def dataType: DataType = TimestampType
|
||||
override def dataType: DataType = timestamp.dataType
|
||||
|
||||
override def withTimeZone(timeZoneId: String): TimeZoneAwareExpression =
|
||||
copy(timeZoneId = Option(timeZoneId))
|
||||
|
||||
@transient private lazy val zoneIdInEval: ZoneId = zoneIdForType(left.dataType)
|
||||
|
||||
override def nullSafeEval(micros: Any, months: Any): Any = {
|
||||
timestampAddMonths(micros.asInstanceOf[Long], months.asInstanceOf[Int], zoneId)
|
||||
timestampAddMonths(micros.asInstanceOf[Long], months.asInstanceOf[Int], zoneIdInEval)
|
||||
}
|
||||
|
||||
override def doGenCode(ctx: CodegenContext, ev: ExprCode): ExprCode = {
|
||||
val zid = ctx.addReferenceObj("zoneId", zoneId, classOf[ZoneId].getName)
|
||||
val zid = ctx.addReferenceObj("zoneId", zoneIdInEval, classOf[ZoneId].getName)
|
||||
val dtu = DateTimeUtils.getClass.getName.stripSuffix("$")
|
||||
defineCodeGen(ctx, ev, (micros, months) => {
|
||||
s"""$dtu.timestampAddMonths($micros, $months, $zid)"""
|
||||
|
|
|
|||
|
|
@ -88,6 +88,14 @@ private[sql] object TypeCollection {
|
|||
DayTimeIntervalType,
|
||||
YearMonthIntervalType)
|
||||
|
||||
/**
|
||||
* All the supported timestamp data types
|
||||
*/
|
||||
val AllTimestampTypes = TypeCollection(
|
||||
TimestampType,
|
||||
TimestampWithoutTZType
|
||||
)
|
||||
|
||||
def apply(types: AbstractDataType*): TypeCollection = new TypeCollection(types)
|
||||
|
||||
def unapply(typ: AbstractDataType): Option[Seq[AbstractDataType]] = typ match {
|
||||
|
|
|
|||
|
|
@ -55,6 +55,27 @@ class DateExpressionsSuite extends SparkFunSuite with ExpressionEvalHelper {
|
|||
val time = "2013-11-08 13:10:15"
|
||||
val ts = new Timestamp(toMillis(time))
|
||||
|
||||
private def timestampLiteral(s: String, sdf: SimpleDateFormat, dt: DataType): Literal = {
|
||||
dt match {
|
||||
case _: TimestampType =>
|
||||
Literal(new Timestamp(sdf.parse(s).getTime))
|
||||
|
||||
case _: TimestampWithoutTZType =>
|
||||
Literal(LocalDateTime.parse(s.replace(" ", "T")))
|
||||
}
|
||||
}
|
||||
|
||||
private def timestampAnswer(s: String, sdf: SimpleDateFormat, dt: DataType): Any = {
|
||||
dt match {
|
||||
case _: TimestampType =>
|
||||
DateTimeUtils.fromJavaTimestamp(
|
||||
new Timestamp(sdf.parse(s).getTime))
|
||||
|
||||
case _: TimestampWithoutTZType =>
|
||||
LocalDateTime.parse(s.replace(" ", "T"))
|
||||
}
|
||||
}
|
||||
|
||||
test("datetime function current_date") {
|
||||
val d0 = DateTimeUtils.currentDate(UTC)
|
||||
val cd = CurrentDate(UTC_OPT).eval(EmptyRow).asInstanceOf[Int]
|
||||
|
|
@ -428,39 +449,39 @@ class DateExpressionsSuite extends SparkFunSuite with ExpressionEvalHelper {
|
|||
|
||||
test("time_add") {
|
||||
val sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS", Locale.US)
|
||||
for (zid <- outstandingZoneIds) {
|
||||
val timeZoneId = Option(zid.getId)
|
||||
sdf.setTimeZone(TimeZone.getTimeZone(zid))
|
||||
Seq(TimestampType, TimestampWithoutTZType).foreach { dt =>
|
||||
for (zid <- outstandingZoneIds) {
|
||||
val timeZoneId = Option(zid.getId)
|
||||
sdf.setTimeZone(TimeZone.getTimeZone(zid))
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
timestampLiteral("2016-01-29 10:00:00.000", sdf, dt),
|
||||
Literal(new CalendarInterval(1, 2, 123000L)),
|
||||
timeZoneId),
|
||||
timestampAnswer("2016-03-02 10:00:00.123", sdf, dt))
|
||||
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal(new Timestamp(sdf.parse("2016-01-29 10:00:00.000").getTime)),
|
||||
Literal(new CalendarInterval(1, 2, 123000L)),
|
||||
timeZoneId),
|
||||
DateTimeUtils.fromJavaTimestamp(
|
||||
new Timestamp(sdf.parse("2016-03-02 10:00:00.123").getTime)))
|
||||
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, TimestampType),
|
||||
Literal(new CalendarInterval(1, 2, 123000L)),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal(new Timestamp(sdf.parse("2016-01-29 10:00:00.000").getTime)),
|
||||
Literal.create(null, CalendarIntervalType),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, TimestampType),
|
||||
Literal.create(null, CalendarIntervalType),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkConsistencyBetweenInterpretedAndCodegen(
|
||||
(start: Expression, interval: Expression) => TimeAdd(start, interval, timeZoneId),
|
||||
TimestampType, CalendarIntervalType)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, dt),
|
||||
Literal(new CalendarInterval(1, 2, 123000L)),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
timestampLiteral("2016-01-29 10:00:00.000", sdf, dt),
|
||||
Literal.create(null, CalendarIntervalType),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, dt),
|
||||
Literal.create(null, CalendarIntervalType),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkConsistencyBetweenInterpretedAndCodegen(
|
||||
(start: Expression, interval: Expression) => TimeAdd(start, interval, timeZoneId),
|
||||
dt, CalendarIntervalType)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -1600,99 +1621,99 @@ class DateExpressionsSuite extends SparkFunSuite with ExpressionEvalHelper {
|
|||
}
|
||||
}
|
||||
|
||||
test("SPARK-34739: add a year-month interval to a timestamp") {
|
||||
test("SPARK-34739,SPARK-35889: add a year-month interval to a timestamp") {
|
||||
val sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS", Locale.US)
|
||||
for (zid <- outstandingZoneIds) {
|
||||
val timeZoneId = Option(zid.getId)
|
||||
sdf.setTimeZone(TimeZone.getTimeZone(zid))
|
||||
Seq(TimestampType, TimestampWithoutTZType).foreach { dt =>
|
||||
for (zid <- outstandingZoneIds) {
|
||||
val timeZoneId = Option(zid.getId)
|
||||
sdf.setTimeZone(TimeZone.getTimeZone(zid))
|
||||
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
Literal(new Timestamp(sdf.parse("2016-01-29 10:11:12.123").getTime)),
|
||||
Literal(Period.ofMonths(2)),
|
||||
timeZoneId),
|
||||
DateTimeUtils.fromJavaTimestamp(
|
||||
new Timestamp(sdf.parse("2016-03-29 10:11:12.123").getTime)))
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
timestampLiteral("2016-01-29 10:11:12.123", sdf, dt),
|
||||
Literal(Period.ofMonths(2)),
|
||||
timeZoneId),
|
||||
timestampAnswer("2016-03-29 10:11:12.123", sdf, dt))
|
||||
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
Literal.create(null, TimestampType),
|
||||
Literal(Period.ofMonths(1)),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
Literal(new Timestamp(sdf.parse("2016-01-29 10:00:00.000").getTime)),
|
||||
Literal.create(null, YearMonthIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
Literal.create(null, TimestampType),
|
||||
Literal.create(null, YearMonthIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
yearMonthIntervalTypes.foreach { it =>
|
||||
checkConsistencyBetweenInterpretedAndCodegen(
|
||||
(ts: Expression, interval: Expression) =>
|
||||
TimestampAddYMInterval(ts, interval, timeZoneId),
|
||||
TimestampType, it)
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
Literal.create(null, dt),
|
||||
Literal(Period.ofMonths(1)),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
timestampLiteral("2016-01-29 10:00:00.000", sdf, dt),
|
||||
Literal.create(null, YearMonthIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimestampAddYMInterval(
|
||||
Literal.create(null, dt),
|
||||
Literal.create(null, YearMonthIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
yearMonthIntervalTypes.foreach { it =>
|
||||
checkConsistencyBetweenInterpretedAndCodegen(
|
||||
(ts: Expression, interval: Expression) =>
|
||||
TimestampAddYMInterval(ts, interval, timeZoneId), dt, it)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
test("SPARK-34761: add a day-time interval to a timestamp") {
|
||||
test("SPARK-34761,SPARK-35889: add a day-time interval to a timestamp") {
|
||||
val sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS", Locale.US)
|
||||
for (zid <- outstandingZoneIds) {
|
||||
val timeZoneId = Option(zid.getId)
|
||||
sdf.setTimeZone(TimeZone.getTimeZone(zid))
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal(new Timestamp(sdf.parse("2021-01-01 00:00:00.123").getTime)),
|
||||
Literal(Duration.ofDays(10).plusMinutes(10).plusMillis(321)),
|
||||
timeZoneId),
|
||||
DateTimeUtils.fromJavaTimestamp(
|
||||
new Timestamp(sdf.parse("2021-01-11 00:10:00.444").getTime)))
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal(new Timestamp(sdf.parse("2021-01-01 00:10:00.123").getTime)),
|
||||
Literal(Duration.ofDays(-10).minusMinutes(9).minusMillis(120)),
|
||||
timeZoneId),
|
||||
DateTimeUtils.fromJavaTimestamp(
|
||||
new Timestamp(sdf.parse("2020-12-22 00:01:00.003").getTime)))
|
||||
|
||||
val e = intercept[Exception] {
|
||||
Seq(TimestampType, TimestampWithoutTZType).foreach { dt =>
|
||||
for (zid <- outstandingZoneIds) {
|
||||
val timeZoneId = Option(zid.getId)
|
||||
sdf.setTimeZone(TimeZone.getTimeZone(zid))
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal(new Timestamp(sdf.parse("2021-01-01 00:00:00.123").getTime)),
|
||||
Literal(Duration.of(Long.MaxValue, ChronoUnit.MICROS)),
|
||||
timestampLiteral("2021-01-01 00:00:00.123", sdf, dt),
|
||||
Literal(Duration.ofDays(10).plusMinutes(10).plusMillis(321)),
|
||||
timeZoneId),
|
||||
timestampAnswer("2021-01-11 00:10:00.444", sdf, dt))
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
timestampLiteral("2021-01-01 00:10:00.123", sdf, dt),
|
||||
Literal(Duration.ofDays(-10).minusMinutes(9).minusMillis(120)),
|
||||
timeZoneId),
|
||||
timestampAnswer("2020-12-22 00:01:00.003", sdf, dt))
|
||||
|
||||
val e = intercept[Exception] {
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
timestampLiteral("2021-01-01 00:00:00.123", sdf, dt),
|
||||
Literal(Duration.of(Long.MaxValue, ChronoUnit.MICROS)),
|
||||
timeZoneId),
|
||||
null)
|
||||
}.getCause
|
||||
assert(e.isInstanceOf[ArithmeticException])
|
||||
assert(e.getMessage.contains("long overflow"))
|
||||
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, dt),
|
||||
Literal(Duration.ofDays(1)),
|
||||
timeZoneId),
|
||||
null)
|
||||
}.getCause
|
||||
assert(e.isInstanceOf[ArithmeticException])
|
||||
assert(e.getMessage.contains("long overflow"))
|
||||
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, TimestampType),
|
||||
Literal(Duration.ofDays(1)),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal(new Timestamp(sdf.parse("2021-01-01 00:00:00.123").getTime)),
|
||||
Literal.create(null, DayTimeIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, TimestampType),
|
||||
Literal.create(null, DayTimeIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
dayTimeIntervalTypes.foreach { it =>
|
||||
checkConsistencyBetweenInterpretedAndCodegen((ts: Expression, interval: Expression) =>
|
||||
TimeAdd(ts, interval, timeZoneId), TimestampType, it)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
timestampLiteral("2021-01-01 00:00:00.123", sdf, dt),
|
||||
Literal.create(null, DayTimeIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
checkEvaluation(
|
||||
TimeAdd(
|
||||
Literal.create(null, dt),
|
||||
Literal.create(null, DayTimeIntervalType()),
|
||||
timeZoneId),
|
||||
null)
|
||||
dayTimeIntervalTypes.foreach { it =>
|
||||
checkConsistencyBetweenInterpretedAndCodegen((ts: Expression, interval: Expression) =>
|
||||
TimeAdd(ts, interval, timeZoneId), dt, it)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -225,3 +225,14 @@ select next_day("2015-07-23", "xx");
|
|||
select next_day("xx", "Mon");
|
||||
select next_day(null, "Mon");
|
||||
select next_day(null, "xx");
|
||||
|
||||
-- TimestampWithoutTZ + Intervals
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval 2 day;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0-0' year to month;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '1-2' year to month;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0' day to second;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0.1' day to second;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '10-9' year to month;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15' day to hour;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40' day to minute;
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40:32.99899999' day to second;
|
||||
|
|
|
|||
|
|
@ -1,5 +1,5 @@
|
|||
-- Automatically generated by SQLQueryTestSuite
|
||||
-- Number of queries: 167
|
||||
-- Number of queries: 176
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -377,7 +377,7 @@ select 1 - interval '2' second
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve '1 + (- INTERVAL '2 seconds')' due to data type mismatch: argument 1 requires timestamp type, however, '1' is of int type.; line 1 pos 7
|
||||
cannot resolve '1 + (- INTERVAL '2 seconds')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, '1' is of int type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -1434,3 +1434,75 @@ select next_day(null, "xx")
|
|||
struct<next_day(NULL, xx):date>
|
||||
-- !query output
|
||||
NULL
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval 2 day
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '2 days':timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-27 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0-0' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0-0' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '1-2' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '1-2' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2022-08-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0 00:00:00' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0.1' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0 00:00:00.1' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12.1
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '10-9' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '10-9' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2032-03-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15' day to hour
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15' DAY TO HOUR:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40' day to minute
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15:40' DAY TO MINUTE:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:51:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40:32.99899999' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15:40:32.998999' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:51:44.998999
|
||||
|
|
|
|||
|
|
@ -1,5 +1,5 @@
|
|||
-- Automatically generated by SQLQueryTestSuite
|
||||
-- Number of queries: 167
|
||||
-- Number of queries: 176
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -354,7 +354,7 @@ select 1 - interval '2' second
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve '1 + (- INTERVAL '2 seconds')' due to data type mismatch: argument 1 requires timestamp type, however, '1' is of int type.; line 1 pos 7
|
||||
cannot resolve '1 + (- INTERVAL '2 seconds')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, '1' is of int type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -1376,3 +1376,75 @@ select next_day(null, "xx")
|
|||
struct<next_day(NULL, xx):date>
|
||||
-- !query output
|
||||
NULL
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval 2 day
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '2 days':timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-27 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0-0' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0-0' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '1-2' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '1-2' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2022-08-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0 00:00:00' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0.1' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0 00:00:00.1' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12.1
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '10-9' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '10-9' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2032-03-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15' day to hour
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15' DAY TO HOUR:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40' day to minute
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15:40' DAY TO MINUTE:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:51:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40:32.99899999' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15:40:32.998999' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:51:44.998999
|
||||
|
|
|
|||
|
|
@ -1,5 +1,5 @@
|
|||
-- Automatically generated by SQLQueryTestSuite
|
||||
-- Number of queries: 167
|
||||
-- Number of queries: 176
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -354,7 +354,7 @@ select 1 - interval '2' second
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve '1 + (- INTERVAL '2 seconds')' due to data type mismatch: argument 1 requires timestamp type, however, '1' is of int type.; line 1 pos 7
|
||||
cannot resolve '1 + (- INTERVAL '2 seconds')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, '1' is of int type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -1384,3 +1384,75 @@ select next_day(null, "xx")
|
|||
struct<next_day(NULL, xx):date>
|
||||
-- !query output
|
||||
NULL
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval 2 day
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '2 days':timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-27 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0-0' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0-0' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '1-2' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '1-2' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2022-08-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0 00:00:00' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '0 0:0:0.1' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '0 00:00:00.1' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-06-25 10:11:12.1
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '10-9' year to month
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '10-9' YEAR TO MONTH:timestamp without time zone>
|
||||
-- !query output
|
||||
2032-03-25 10:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15' day to hour
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15' DAY TO HOUR:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:11:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40' day to minute
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15:40' DAY TO MINUTE:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:51:12
|
||||
|
||||
|
||||
-- !query
|
||||
select to_timestamp_ntz('2021-06-25 10:11:12') + interval '20 15:40:32.99899999' day to second
|
||||
-- !query schema
|
||||
struct<to_timestamp_ntz(2021-06-25 10:11:12) + INTERVAL '20 15:40:32.998999' DAY TO SECOND:timestamp without time zone>
|
||||
-- !query output
|
||||
2021-07-16 01:51:44.998999
|
||||
|
|
|
|||
|
|
@ -16,7 +16,7 @@ select cast(1 as tinyint) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS TINYINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS TINYINT)' is of tinyint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS TINYINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS TINYINT)' is of tinyint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -25,7 +25,7 @@ select cast(1 as smallint) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS SMALLINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS SMALLINT)' is of smallint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS SMALLINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS SMALLINT)' is of smallint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -34,7 +34,7 @@ select cast(1 as int) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS INT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS INT)' is of int type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS INT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS INT)' is of int type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -43,7 +43,7 @@ select cast(1 as bigint) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS BIGINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS BIGINT)' is of bigint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS BIGINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS BIGINT)' is of bigint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -52,7 +52,7 @@ select cast(1 as float) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS FLOAT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS FLOAT)' is of float type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS FLOAT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS FLOAT)' is of float type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -61,7 +61,7 @@ select cast(1 as double) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS DOUBLE) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS DOUBLE)' is of double type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS DOUBLE) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS DOUBLE)' is of double type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -70,7 +70,7 @@ select cast(1 as decimal(10, 0)) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS DECIMAL(10,0)) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS DECIMAL(10,0))' is of decimal(10,0) type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS DECIMAL(10,0)) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS DECIMAL(10,0))' is of decimal(10,0) type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -95,7 +95,7 @@ select cast('1' as binary) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST('1' AS BINARY) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST('1' AS BINARY)' is of binary type.; line 1 pos 7
|
||||
cannot resolve 'CAST('1' AS BINARY) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST('1' AS BINARY)' is of binary type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -104,7 +104,7 @@ select cast(1 as boolean) + interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS BOOLEAN) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS BOOLEAN)' is of boolean type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS BOOLEAN) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS BOOLEAN)' is of boolean type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -129,7 +129,7 @@ select interval 2 day + cast(1 as tinyint)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS TINYINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS TINYINT)' is of tinyint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS TINYINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS TINYINT)' is of tinyint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -138,7 +138,7 @@ select interval 2 day + cast(1 as smallint)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS SMALLINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS SMALLINT)' is of smallint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS SMALLINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS SMALLINT)' is of smallint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -147,7 +147,7 @@ select interval 2 day + cast(1 as int)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS INT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS INT)' is of int type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS INT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS INT)' is of int type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -156,7 +156,7 @@ select interval 2 day + cast(1 as bigint)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS BIGINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS BIGINT)' is of bigint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS BIGINT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS BIGINT)' is of bigint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -165,7 +165,7 @@ select interval 2 day + cast(1 as float)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS FLOAT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS FLOAT)' is of float type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS FLOAT) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS FLOAT)' is of float type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -174,7 +174,7 @@ select interval 2 day + cast(1 as double)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS DOUBLE) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS DOUBLE)' is of double type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS DOUBLE) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS DOUBLE)' is of double type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -183,7 +183,7 @@ select interval 2 day + cast(1 as decimal(10, 0))
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS DECIMAL(10,0)) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS DECIMAL(10,0))' is of decimal(10,0) type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS DECIMAL(10,0)) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS DECIMAL(10,0))' is of decimal(10,0) type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -208,7 +208,7 @@ select interval 2 day + cast('1' as binary)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST('1' AS BINARY) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST('1' AS BINARY)' is of binary type.; line 1 pos 7
|
||||
cannot resolve 'CAST('1' AS BINARY) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST('1' AS BINARY)' is of binary type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -217,7 +217,7 @@ select interval 2 day + cast(1 as boolean)
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS BOOLEAN) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS BOOLEAN)' is of boolean type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS BOOLEAN) + INTERVAL '2 days'' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS BOOLEAN)' is of boolean type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -242,7 +242,7 @@ select cast(1 as tinyint) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS TINYINT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS TINYINT)' is of tinyint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS TINYINT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS TINYINT)' is of tinyint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -251,7 +251,7 @@ select cast(1 as smallint) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS SMALLINT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS SMALLINT)' is of smallint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS SMALLINT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS SMALLINT)' is of smallint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -260,7 +260,7 @@ select cast(1 as int) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS INT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS INT)' is of int type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS INT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS INT)' is of int type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -269,7 +269,7 @@ select cast(1 as bigint) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS BIGINT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS BIGINT)' is of bigint type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS BIGINT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS BIGINT)' is of bigint type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -278,7 +278,7 @@ select cast(1 as float) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS FLOAT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS FLOAT)' is of float type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS FLOAT) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS FLOAT)' is of float type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -287,7 +287,7 @@ select cast(1 as double) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS DOUBLE) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS DOUBLE)' is of double type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS DOUBLE) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS DOUBLE)' is of double type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -296,7 +296,7 @@ select cast(1 as decimal(10, 0)) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS DECIMAL(10,0)) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS DECIMAL(10,0))' is of decimal(10,0) type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS DECIMAL(10,0)) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS DECIMAL(10,0))' is of decimal(10,0) type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -321,7 +321,7 @@ select cast('1' as binary) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST('1' AS BINARY) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST('1' AS BINARY)' is of binary type.; line 1 pos 7
|
||||
cannot resolve 'CAST('1' AS BINARY) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST('1' AS BINARY)' is of binary type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
@ -330,7 +330,7 @@ select cast(1 as boolean) - interval 2 day
|
|||
struct<>
|
||||
-- !query output
|
||||
org.apache.spark.sql.AnalysisException
|
||||
cannot resolve 'CAST(1 AS BOOLEAN) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires timestamp type, however, 'CAST(1 AS BOOLEAN)' is of boolean type.; line 1 pos 7
|
||||
cannot resolve 'CAST(1 AS BOOLEAN) + (- INTERVAL '2 days')' due to data type mismatch: argument 1 requires (timestamp or timestamp without time zone) type, however, 'CAST(1 AS BOOLEAN)' is of boolean type.; line 1 pos 7
|
||||
|
||||
|
||||
-- !query
|
||||
|
|
|
|||
Loading…
Reference in a new issue