Last active
November 4, 2022 11:15
-
-
Save maropu/5f1ef1f4967b887e539a78cdbba98040 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Spark session available as 'spark'. | |
Welcome to | |
____ __ | |
/ __/__ ___ _____/ /__ | |
_\ \/ _ \/ _ `/ __/ '_/ | |
/___/ .__/\_,_/_/ /_/\_\ version 3.2.0-SNAPSHOT | |
/_/ | |
Using Scala version 2.12.10 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_181) | |
Type in expressions to have them evaluated. | |
Type :help for more information. | |
scala> val df = Seq(("2016-03-27 19:39:34", 1, "a"), ("2016-03-27 19:39:56", 2, "a"), ("2016-03-27 19:39:27", 4, "b")).toDF("time", "value", "id") | |
scala> val rdf = df.select(window($"time", "10 seconds", "3 seconds", "0 second"), $"value").orderBy($"window.start".asc, $"value".desc).select("value") | |
scala> rdf.show() | |
21/04/26 23:11:07 ERROR CodeGenerator: failed to compile: org.codehaus.commons.compiler.InternalCompilerException: Compiling "GeneratedClass" in File 'generated.java', Line 1, Column 1: File 'generated.java', Line 32, Column 16: Compiling "processNext()": File 'generated.java', Line 2010, Column 6: Compiling "filter_isNull_3": Invalid local variable index 249 | |
org.codehaus.commons.compiler.InternalCompilerException: Compiling "GeneratedClass" in File 'generated.java', Line 1, Column 1: File 'generated.java', Line 32, Column 16: Compiling "processNext()": File 'generated.java', Line 2010, Column 6: Compiling "filter_isNull_3": Invalid local variable index 249 | |
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:369) | |
at org.codehaus.janino.UnitCompiler.access$000(UnitCompiler.java:231) | |
at org.codehaus.janino.UnitCompiler$1.visitCompilationUnit(UnitCompiler.java:333) | |
at org.codehaus.janino.UnitCompiler$1.visitCompilationUnit(UnitCompiler.java:330) | |
at org.codehaus.janino.Java$CompilationUnit.accept(Java.java:367) | |
at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:330) | |
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:245) | |
at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:294) | |
at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:288) | |
at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:267) | |
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:82) | |
at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.org$apache$spark$sql$catalyst$expressions$codegen$CodeGenerator$$doCompile(CodeGenerator.scala:1403) | |
at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$$anon$1.load(CodeGenerator.scala:1501) | |
at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$$anon$1.load(CodeGenerator.scala:1498) | |
... | |
Caused by: org.codehaus.commons.compiler.InternalCompilerException: Invalid local variable index 249 | |
at org.codehaus.janino.UnitCompiler.getLocalVariableTypeInfo(UnitCompiler.java:13204) | |
at org.codehaus.janino.UnitCompiler.load(UnitCompiler.java:12229) | |
at org.codehaus.janino.UnitCompiler.load(UnitCompiler.java:12206) | |
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4681) | |
at org.codehaus.janino.UnitCompiler.access$7900(UnitCompiler.java:231) | |
at org.codehaus.janino.UnitCompiler$15$1.visitLocalVariableAccess(UnitCompiler.java:4618) | |
at org.codehaus.janino.UnitCompiler$15$1.visitLocalVariableAccess(UnitCompiler.java:4610) | |
at org.codehaus.janino.Java$LocalVariableAccess.accept(Java.java:4632) | |
at org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4610) | |
at org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4606) | |
at org.codehaus.janino.Java$Lvalue.accept(Java.java:4498) | |
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4606) | |
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4677) | |
at org.codehaus.janino.UnitCompiler.access$7400(UnitCompiler.java:231) | |
at org.codehaus.janino.UnitCompiler$15$1.visitAmbiguousName(UnitCompiler.java:4613) | |
at org.codehaus.janino.UnitCompiler$15$1.visitAmbiguousName(UnitCompiler.java:4610) | |
at org.codehaus.janino.Java$AmbiguousName.accept(Java.java:4574) | |
at org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4610) | |
at org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4606) | |
at org.codehaus.janino.Java$Lvalue.accept(Java.java:4498) | |
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4606) | |
at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5731) | |
... 173 more | |
/* 001 */ public Object generate(Object[] references) { | |
/* 002 */ return new GeneratedIteratorForCodegenStage1(references); | |
/* 003 */ } | |
/* 004 */ | |
/* 005 */ // codegenStageId=1 | |
/* 006 */ final class GeneratedIteratorForCodegenStage1 extends org.apache.spark.sql.execution.BufferedRowIterator { | |
/* 007 */ private Object[] references; | |
/* 008 */ private scala.collection.Iterator[] inputs; | |
/* 009 */ private scala.collection.Iterator localtablescan_input_0; | |
/* 010 */ private boolean expand_resultIsNull_0; | |
/* 011 */ private InternalRow[] expand_mutableStateArray_0 = new InternalRow[1]; | |
/* 012 */ private org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter[] expand_mutableStateArray_1 = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter[5]; | |
/* 013 */ | |
/* 014 */ public GeneratedIteratorForCodegenStage1(Object[] references) { | |
/* 015 */ this.references = references; | |
/* 016 */ } | |
/* 017 */ | |
/* 018 */ public void init(int index, scala.collection.Iterator[] inputs) { | |
/* 019 */ partitionIndex = index; | |
/* 020 */ this.inputs = inputs; | |
/* 021 */ localtablescan_input_0 = inputs[0]; | |
/* 022 */ expand_resultIsNull_0 = true; | |
/* 023 */ expand_mutableStateArray_0[0] = null; | |
/* 024 */ expand_mutableStateArray_1[0] = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(3, 64); | |
/* 025 */ expand_mutableStateArray_1[1] = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(expand_mutableStateArray_1[0], 2); | |
/* 026 */ expand_mutableStateArray_1[2] = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(3, 64); | |
/* 027 */ expand_mutableStateArray_1[3] = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(expand_mutableStateArray_1[2], 2); | |
/* 028 */ expand_mutableStateArray_1[4] = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(2, 0); | |
/* 029 */ | |
/* 030 */ } | |
/* 031 */ | |
/* 032 */ protected void processNext() throws java.io.IOException { | |
/* 033 */ while ( localtablescan_input_0.hasNext()) { | |
/* 034 */ InternalRow localtablescan_row_0 = (InternalRow) localtablescan_input_0.next(); | |
/* 035 */ ((org.apache.spark.sql.execution.metric.SQLMetric) references[0] /* numOutputRows */).add(1); | |
/* 036 */ boolean localtablescan_isNull_0 = localtablescan_row_0.isNullAt(0); | |
/* 037 */ UTF8String localtablescan_value_0 = localtablescan_isNull_0 ? | |
/* 038 */ null : (localtablescan_row_0.getUTF8String(0)); | |
/* 039 */ int localtablescan_value_1 = localtablescan_row_0.getInt(1); | |
/* 040 */ | |
/* 041 */ for (int expand_i_0 = 0; expand_i_0 < 4; expand_i_0 ++) { | |
/* 042 */ switch (expand_i_0) { | |
/* 043 */ case 0: | |
/* 044 */ | |
/* 045 */ Object[] expand_values_0 = new Object[2]; | |
/* 046 */ | |
/* 047 */ boolean expand_isNull_4 = true; | |
/* 048 */ long expand_value_4 = -1L; | |
/* 049 */ boolean expand_isNull_5 = true; | |
/* 050 */ long expand_value_5 = -1L; | |
/* 051 */ boolean expand_isNull_6 = true; | |
/* 052 */ long expand_value_6 = -1L; | |
/* 053 */ boolean expand_isNull_7 = true; | |
/* 054 */ long expand_value_7 = -1L; | |
/* 055 */ boolean expand_isNull_9 = true; | |
/* 056 */ boolean expand_value_9 = false; | |
/* 057 */ boolean expand_isNull_12 = false; | |
/* 058 */ double expand_value_12 = -1.0; | |
/* 059 */ if (false || 3000000.0D == 0) { | |
/* 060 */ expand_isNull_12 = true; | |
/* 061 */ } else { | |
/* 062 */ boolean expand_isNull_14 = true; | |
/* 063 */ long expand_value_14 = -1L; | |
/* 064 */ boolean expand_isNull_16 = localtablescan_isNull_0; | |
/* 065 */ long expand_value_16 = -1L; | |
/* 066 */ if (!localtablescan_isNull_0) { | |
/* 067 */ scala.Option<Long> expand_longOpt_0 = | |
/* 068 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[1] /* zoneId */)); | |
/* 069 */ if (expand_longOpt_0.isDefined()) { | |
/* 070 */ expand_value_16 = ((Long) expand_longOpt_0.get()).longValue(); | |
/* 071 */ } else { | |
/* 072 */ expand_isNull_16 = true; | |
/* 073 */ } | |
/* 074 */ } | |
/* 075 */ boolean expand_isNull_15 = expand_isNull_16; | |
/* 076 */ long expand_value_15 = expand_value_16; | |
/* 077 */ if (!expand_isNull_15) { | |
/* 078 */ expand_isNull_14 = false; // resultCode could change nullability. | |
/* 079 */ | |
/* 080 */ expand_value_14 = expand_value_15 - 0L; | |
/* 081 */ | |
/* 082 */ } | |
/* 083 */ boolean expand_isNull_13 = expand_isNull_14; | |
/* 084 */ double expand_value_13 = -1.0; | |
/* 085 */ if (!expand_isNull_14) { | |
/* 086 */ expand_value_13 = (double) expand_value_14; | |
/* 087 */ } | |
/* 088 */ if (expand_isNull_13) { | |
/* 089 */ expand_isNull_12 = true; | |
/* 090 */ } else { | |
/* 091 */ expand_value_12 = (double)(expand_value_13 / 3000000.0D); | |
/* 092 */ } | |
/* 093 */ } | |
/* 094 */ boolean expand_isNull_11 = expand_isNull_12; | |
/* 095 */ long expand_value_11 = -1L; | |
/* 096 */ | |
/* 097 */ if (!expand_isNull_12) { | |
/* 098 */ expand_value_11 = (long)(java.lang.Math.ceil(expand_value_12)); | |
/* 099 */ } | |
/* 100 */ boolean expand_isNull_10 = expand_isNull_11; | |
/* 101 */ double expand_value_10 = -1.0; | |
/* 102 */ if (!expand_isNull_11) { | |
/* 103 */ expand_value_10 = (double) expand_value_11; | |
/* 104 */ } | |
/* 105 */ if (!expand_isNull_10) { | |
/* 106 */ boolean expand_isNull_20 = false; | |
/* 107 */ double expand_value_20 = -1.0; | |
/* 108 */ if (false || 3000000.0D == 0) { | |
/* 109 */ expand_isNull_20 = true; | |
/* 110 */ } else { | |
/* 111 */ boolean expand_isNull_22 = true; | |
/* 112 */ long expand_value_22 = -1L; | |
/* 113 */ boolean expand_isNull_24 = localtablescan_isNull_0; | |
/* 114 */ long expand_value_24 = -1L; | |
/* 115 */ if (!localtablescan_isNull_0) { | |
/* 116 */ scala.Option<Long> expand_longOpt_1 = | |
/* 117 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[2] /* zoneId */)); | |
/* 118 */ if (expand_longOpt_1.isDefined()) { | |
/* 119 */ expand_value_24 = ((Long) expand_longOpt_1.get()).longValue(); | |
/* 120 */ } else { | |
/* 121 */ expand_isNull_24 = true; | |
/* 122 */ } | |
/* 123 */ } | |
/* 124 */ boolean expand_isNull_23 = expand_isNull_24; | |
/* 125 */ long expand_value_23 = expand_value_24; | |
/* 126 */ if (!expand_isNull_23) { | |
/* 127 */ expand_isNull_22 = false; // resultCode could change nullability. | |
/* 128 */ | |
/* 129 */ expand_value_22 = expand_value_23 - 0L; | |
/* 130 */ | |
/* 131 */ } | |
/* 132 */ boolean expand_isNull_21 = expand_isNull_22; | |
/* 133 */ double expand_value_21 = -1.0; | |
/* 134 */ if (!expand_isNull_22) { | |
/* 135 */ expand_value_21 = (double) expand_value_22; | |
/* 136 */ } | |
/* 137 */ if (expand_isNull_21) { | |
/* 138 */ expand_isNull_20 = true; | |
/* 139 */ } else { | |
/* 140 */ expand_value_20 = (double)(expand_value_21 / 3000000.0D); | |
/* 141 */ } | |
/* 142 */ } | |
/* 143 */ if (!expand_isNull_20) { | |
/* 144 */ expand_isNull_9 = false; // resultCode could change nullability. | |
/* 145 */ expand_value_9 = ((java.lang.Double.isNaN(expand_value_10) && java.lang.Double.isNaN(expand_value_20)) || expand_value_10 == expand_value_20); | |
/* 146 */ | |
/* 147 */ } | |
/* 148 */ | |
/* 149 */ } | |
/* 150 */ boolean expand_isNull_8 = false; | |
/* 151 */ long expand_value_8 = -1L; | |
/* 152 */ if (!expand_isNull_9 && expand_value_9) { | |
/* 153 */ boolean expand_isNull_28 = true; | |
/* 154 */ long expand_value_28 = -1L; | |
/* 155 */ boolean expand_isNull_30 = false; | |
/* 156 */ double expand_value_30 = -1.0; | |
/* 157 */ if (false || 3000000.0D == 0) { | |
/* 158 */ expand_isNull_30 = true; | |
/* 159 */ } else { | |
/* 160 */ boolean expand_isNull_32 = true; | |
/* 161 */ long expand_value_32 = -1L; | |
/* 162 */ boolean expand_isNull_34 = localtablescan_isNull_0; | |
/* 163 */ long expand_value_34 = -1L; | |
/* 164 */ if (!localtablescan_isNull_0) { | |
/* 165 */ scala.Option<Long> expand_longOpt_2 = | |
/* 166 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[3] /* zoneId */)); | |
/* 167 */ if (expand_longOpt_2.isDefined()) { | |
/* 168 */ expand_value_34 = ((Long) expand_longOpt_2.get()).longValue(); | |
/* 169 */ } else { | |
/* 170 */ expand_isNull_34 = true; | |
/* 171 */ } | |
/* 172 */ } | |
/* 173 */ boolean expand_isNull_33 = expand_isNull_34; | |
/* 174 */ long expand_value_33 = expand_value_34; | |
/* 175 */ if (!expand_isNull_33) { | |
/* 176 */ expand_isNull_32 = false; // resultCode could change nullability. | |
/* 177 */ | |
/* 178 */ expand_value_32 = expand_value_33 - 0L; | |
/* 179 */ | |
/* 180 */ } | |
/* 181 */ boolean expand_isNull_31 = expand_isNull_32; | |
/* 182 */ double expand_value_31 = -1.0; | |
/* 183 */ if (!expand_isNull_32) { | |
/* 184 */ expand_value_31 = (double) expand_value_32; | |
/* 185 */ } | |
/* 186 */ if (expand_isNull_31) { | |
/* 187 */ expand_isNull_30 = true; | |
/* 188 */ } else { | |
/* 189 */ expand_value_30 = (double)(expand_value_31 / 3000000.0D); | |
/* 190 */ } | |
/* 191 */ } | |
/* 192 */ boolean expand_isNull_29 = expand_isNull_30; | |
/* 193 */ long expand_value_29 = -1L; | |
/* 194 */ | |
/* 195 */ if (!expand_isNull_30) { | |
/* 196 */ expand_value_29 = (long)(java.lang.Math.ceil(expand_value_30)); | |
/* 197 */ } | |
/* 198 */ if (!expand_isNull_29) { | |
/* 199 */ expand_isNull_28 = false; // resultCode could change nullability. | |
/* 200 */ | |
/* 201 */ expand_value_28 = expand_value_29 + 1L; | |
/* 202 */ | |
/* 203 */ } | |
/* 204 */ expand_isNull_8 = expand_isNull_28; | |
/* 205 */ expand_value_8 = expand_value_28; | |
/* 206 */ } else { | |
/* 207 */ boolean expand_isNull_40 = false; | |
/* 208 */ double expand_value_40 = -1.0; | |
/* 209 */ if (false || 3000000.0D == 0) { | |
/* 210 */ expand_isNull_40 = true; | |
/* 211 */ } else { | |
/* 212 */ boolean expand_isNull_42 = true; | |
/* 213 */ long expand_value_42 = -1L; | |
/* 214 */ boolean expand_isNull_44 = localtablescan_isNull_0; | |
/* 215 */ long expand_value_44 = -1L; | |
/* 216 */ if (!localtablescan_isNull_0) { | |
/* 217 */ scala.Option<Long> expand_longOpt_3 = | |
/* 218 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[4] /* zoneId */)); | |
/* 219 */ if (expand_longOpt_3.isDefined()) { | |
/* 220 */ expand_value_44 = ((Long) expand_longOpt_3.get()).longValue(); | |
/* 221 */ } else { | |
/* 222 */ expand_isNull_44 = true; | |
/* 223 */ } | |
/* 224 */ } | |
/* 225 */ boolean expand_isNull_43 = expand_isNull_44; | |
/* 226 */ long expand_value_43 = expand_value_44; | |
/* 227 */ if (!expand_isNull_43) { | |
/* 228 */ expand_isNull_42 = false; // resultCode could change nullability. | |
/* 229 */ | |
/* 230 */ expand_value_42 = expand_value_43 - 0L; | |
/* 231 */ | |
/* 232 */ } | |
/* 233 */ boolean expand_isNull_41 = expand_isNull_42; | |
/* 234 */ double expand_value_41 = -1.0; | |
/* 235 */ if (!expand_isNull_42) { | |
/* 236 */ expand_value_41 = (double) expand_value_42; | |
/* 237 */ } | |
/* 238 */ if (expand_isNull_41) { | |
/* 239 */ expand_isNull_40 = true; | |
/* 240 */ } else { | |
/* 241 */ expand_value_40 = (double)(expand_value_41 / 3000000.0D); | |
/* 242 */ } | |
/* 243 */ } | |
/* 244 */ boolean expand_isNull_39 = expand_isNull_40; | |
/* 245 */ long expand_value_39 = -1L; | |
/* 246 */ | |
/* 247 */ if (!expand_isNull_40) { | |
/* 248 */ expand_value_39 = (long)(java.lang.Math.ceil(expand_value_40)); | |
/* 249 */ } | |
/* 250 */ expand_isNull_8 = expand_isNull_39; | |
/* 251 */ expand_value_8 = expand_value_39; | |
/* 252 */ } | |
/* 253 */ if (!expand_isNull_8) { | |
/* 254 */ expand_isNull_7 = false; // resultCode could change nullability. | |
/* 255 */ | |
/* 256 */ expand_value_7 = expand_value_8 + 0L; | |
/* 257 */ | |
/* 258 */ } | |
/* 259 */ if (!expand_isNull_7) { | |
/* 260 */ expand_isNull_6 = false; // resultCode could change nullability. | |
/* 261 */ | |
/* 262 */ expand_value_6 = expand_value_7 - 4L; | |
/* 263 */ | |
/* 264 */ } | |
/* 265 */ if (!expand_isNull_6) { | |
/* 266 */ expand_isNull_5 = false; // resultCode could change nullability. | |
/* 267 */ | |
/* 268 */ expand_value_5 = expand_value_6 * 3000000L; | |
/* 269 */ | |
/* 270 */ } | |
/* 271 */ if (!expand_isNull_5) { | |
/* 272 */ expand_isNull_4 = false; // resultCode could change nullability. | |
/* 273 */ | |
/* 274 */ expand_value_4 = expand_value_5 + 0L; | |
/* 275 */ | |
/* 276 */ } | |
/* 277 */ boolean expand_isNull_3 = expand_isNull_4; | |
/* 278 */ long expand_value_3 = expand_value_4; | |
/* 279 */ if (expand_isNull_3) { | |
/* 280 */ expand_values_0[0] = null; | |
/* 281 */ } else { | |
/* 282 */ expand_values_0[0] = expand_value_3; | |
/* 283 */ } | |
/* 284 */ | |
/* 285 */ boolean expand_isNull_53 = true; | |
/* 286 */ long expand_value_53 = -1L; | |
/* 287 */ boolean expand_isNull_54 = true; | |
/* 288 */ long expand_value_54 = -1L; | |
/* 289 */ boolean expand_isNull_55 = true; | |
/* 290 */ long expand_value_55 = -1L; | |
/* 291 */ boolean expand_isNull_56 = true; | |
/* 292 */ long expand_value_56 = -1L; | |
/* 293 */ boolean expand_isNull_58 = true; | |
/* 294 */ boolean expand_value_58 = false; | |
/* 295 */ boolean expand_isNull_61 = false; | |
/* 296 */ double expand_value_61 = -1.0; | |
/* 297 */ if (false || 3000000.0D == 0) { | |
/* 298 */ expand_isNull_61 = true; | |
/* 299 */ } else { | |
/* 300 */ boolean expand_isNull_63 = true; | |
/* 301 */ long expand_value_63 = -1L; | |
/* 302 */ boolean expand_isNull_65 = localtablescan_isNull_0; | |
/* 303 */ long expand_value_65 = -1L; | |
/* 304 */ if (!localtablescan_isNull_0) { | |
/* 305 */ scala.Option<Long> expand_longOpt_4 = | |
/* 306 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[5] /* zoneId */)); | |
/* 307 */ if (expand_longOpt_4.isDefined()) { | |
/* 308 */ expand_value_65 = ((Long) expand_longOpt_4.get()).longValue(); | |
/* 309 */ } else { | |
/* 310 */ expand_isNull_65 = true; | |
/* 311 */ } | |
/* 312 */ } | |
/* 313 */ boolean expand_isNull_64 = expand_isNull_65; | |
/* 314 */ long expand_value_64 = expand_value_65; | |
/* 315 */ if (!expand_isNull_64) { | |
/* 316 */ expand_isNull_63 = false; // resultCode could change nullability. | |
/* 317 */ | |
/* 318 */ expand_value_63 = expand_value_64 - 0L; | |
/* 319 */ | |
/* 320 */ } | |
/* 321 */ boolean expand_isNull_62 = expand_isNull_63; | |
/* 322 */ double expand_value_62 = -1.0; | |
/* 323 */ if (!expand_isNull_63) { | |
/* 324 */ expand_value_62 = (double) expand_value_63; | |
/* 325 */ } | |
/* 326 */ if (expand_isNull_62) { | |
/* 327 */ expand_isNull_61 = true; | |
/* 328 */ } else { | |
/* 329 */ expand_value_61 = (double)(expand_value_62 / 3000000.0D); | |
/* 330 */ } | |
/* 331 */ } | |
/* 332 */ boolean expand_isNull_60 = expand_isNull_61; | |
/* 333 */ long expand_value_60 = -1L; | |
/* 334 */ | |
/* 335 */ if (!expand_isNull_61) { | |
/* 336 */ expand_value_60 = (long)(java.lang.Math.ceil(expand_value_61)); | |
/* 337 */ } | |
/* 338 */ boolean expand_isNull_59 = expand_isNull_60; | |
/* 339 */ double expand_value_59 = -1.0; | |
/* 340 */ if (!expand_isNull_60) { | |
/* 341 */ expand_value_59 = (double) expand_value_60; | |
/* 342 */ } | |
/* 343 */ if (!expand_isNull_59) { | |
/* 344 */ boolean expand_isNull_69 = false; | |
/* 345 */ double expand_value_69 = -1.0; | |
/* 346 */ if (false || 3000000.0D == 0) { | |
/* 347 */ expand_isNull_69 = true; | |
/* 348 */ } else { | |
/* 349 */ boolean expand_isNull_71 = true; | |
/* 350 */ long expand_value_71 = -1L; | |
/* 351 */ boolean expand_isNull_73 = localtablescan_isNull_0; | |
/* 352 */ long expand_value_73 = -1L; | |
/* 353 */ if (!localtablescan_isNull_0) { | |
/* 354 */ scala.Option<Long> expand_longOpt_5 = | |
/* 355 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[6] /* zoneId */)); | |
/* 356 */ if (expand_longOpt_5.isDefined()) { | |
/* 357 */ expand_value_73 = ((Long) expand_longOpt_5.get()).longValue(); | |
/* 358 */ } else { | |
/* 359 */ expand_isNull_73 = true; | |
/* 360 */ } | |
/* 361 */ } | |
/* 362 */ boolean expand_isNull_72 = expand_isNull_73; | |
/* 363 */ long expand_value_72 = expand_value_73; | |
/* 364 */ if (!expand_isNull_72) { | |
/* 365 */ expand_isNull_71 = false; // resultCode could change nullability. | |
/* 366 */ | |
/* 367 */ expand_value_71 = expand_value_72 - 0L; | |
/* 368 */ | |
/* 369 */ } | |
/* 370 */ boolean expand_isNull_70 = expand_isNull_71; | |
/* 371 */ double expand_value_70 = -1.0; | |
/* 372 */ if (!expand_isNull_71) { | |
/* 373 */ expand_value_70 = (double) expand_value_71; | |
/* 374 */ } | |
/* 375 */ if (expand_isNull_70) { | |
/* 376 */ expand_isNull_69 = true; | |
/* 377 */ } else { | |
/* 378 */ expand_value_69 = (double)(expand_value_70 / 3000000.0D); | |
/* 379 */ } | |
/* 380 */ } | |
/* 381 */ if (!expand_isNull_69) { | |
/* 382 */ expand_isNull_58 = false; // resultCode could change nullability. | |
/* 383 */ expand_value_58 = ((java.lang.Double.isNaN(expand_value_59) && java.lang.Double.isNaN(expand_value_69)) || expand_value_59 == expand_value_69); | |
/* 384 */ | |
/* 385 */ } | |
/* 386 */ | |
/* 387 */ } | |
/* 388 */ boolean expand_isNull_57 = false; | |
/* 389 */ long expand_value_57 = -1L; | |
/* 390 */ if (!expand_isNull_58 && expand_value_58) { | |
/* 391 */ boolean expand_isNull_77 = true; | |
/* 392 */ long expand_value_77 = -1L; | |
/* 393 */ boolean expand_isNull_79 = false; | |
/* 394 */ double expand_value_79 = -1.0; | |
/* 395 */ if (false || 3000000.0D == 0) { | |
/* 396 */ expand_isNull_79 = true; | |
/* 397 */ } else { | |
/* 398 */ boolean expand_isNull_81 = true; | |
/* 399 */ long expand_value_81 = -1L; | |
/* 400 */ boolean expand_isNull_83 = localtablescan_isNull_0; | |
/* 401 */ long expand_value_83 = -1L; | |
/* 402 */ if (!localtablescan_isNull_0) { | |
/* 403 */ scala.Option<Long> expand_longOpt_6 = | |
/* 404 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[7] /* zoneId */)); | |
/* 405 */ if (expand_longOpt_6.isDefined()) { | |
/* 406 */ expand_value_83 = ((Long) expand_longOpt_6.get()).longValue(); | |
/* 407 */ } else { | |
/* 408 */ expand_isNull_83 = true; | |
/* 409 */ } | |
/* 410 */ } | |
/* 411 */ boolean expand_isNull_82 = expand_isNull_83; | |
/* 412 */ long expand_value_82 = expand_value_83; | |
/* 413 */ if (!expand_isNull_82) { | |
/* 414 */ expand_isNull_81 = false; // resultCode could change nullability. | |
/* 415 */ | |
/* 416 */ expand_value_81 = expand_value_82 - 0L; | |
/* 417 */ | |
/* 418 */ } | |
/* 419 */ boolean expand_isNull_80 = expand_isNull_81; | |
/* 420 */ double expand_value_80 = -1.0; | |
/* 421 */ if (!expand_isNull_81) { | |
/* 422 */ expand_value_80 = (double) expand_value_81; | |
/* 423 */ } | |
/* 424 */ if (expand_isNull_80) { | |
/* 425 */ expand_isNull_79 = true; | |
/* 426 */ } else { | |
/* 427 */ expand_value_79 = (double)(expand_value_80 / 3000000.0D); | |
/* 428 */ } | |
/* 429 */ } | |
/* 430 */ boolean expand_isNull_78 = expand_isNull_79; | |
/* 431 */ long expand_value_78 = -1L; | |
/* 432 */ | |
/* 433 */ if (!expand_isNull_79) { | |
/* 434 */ expand_value_78 = (long)(java.lang.Math.ceil(expand_value_79)); | |
/* 435 */ } | |
/* 436 */ if (!expand_isNull_78) { | |
/* 437 */ expand_isNull_77 = false; // resultCode could change nullability. | |
/* 438 */ | |
/* 439 */ expand_value_77 = expand_value_78 + 1L; | |
/* 440 */ | |
/* 441 */ } | |
/* 442 */ expand_isNull_57 = expand_isNull_77; | |
/* 443 */ expand_value_57 = expand_value_77; | |
/* 444 */ } else { | |
/* 445 */ boolean expand_isNull_89 = false; | |
/* 446 */ double expand_value_89 = -1.0; | |
/* 447 */ if (false || 3000000.0D == 0) { | |
/* 448 */ expand_isNull_89 = true; | |
/* 449 */ } else { | |
/* 450 */ boolean expand_isNull_91 = true; | |
/* 451 */ long expand_value_91 = -1L; | |
/* 452 */ boolean expand_isNull_93 = localtablescan_isNull_0; | |
/* 453 */ long expand_value_93 = -1L; | |
/* 454 */ if (!localtablescan_isNull_0) { | |
/* 455 */ scala.Option<Long> expand_longOpt_7 = | |
/* 456 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[8] /* zoneId */)); | |
/* 457 */ if (expand_longOpt_7.isDefined()) { | |
/* 458 */ expand_value_93 = ((Long) expand_longOpt_7.get()).longValue(); | |
/* 459 */ } else { | |
/* 460 */ expand_isNull_93 = true; | |
/* 461 */ } | |
/* 462 */ } | |
/* 463 */ boolean expand_isNull_92 = expand_isNull_93; | |
/* 464 */ long expand_value_92 = expand_value_93; | |
/* 465 */ if (!expand_isNull_92) { | |
/* 466 */ expand_isNull_91 = false; // resultCode could change nullability. | |
/* 467 */ | |
/* 468 */ expand_value_91 = expand_value_92 - 0L; | |
/* 469 */ | |
/* 470 */ } | |
/* 471 */ boolean expand_isNull_90 = expand_isNull_91; | |
/* 472 */ double expand_value_90 = -1.0; | |
/* 473 */ if (!expand_isNull_91) { | |
/* 474 */ expand_value_90 = (double) expand_value_91; | |
/* 475 */ } | |
/* 476 */ if (expand_isNull_90) { | |
/* 477 */ expand_isNull_89 = true; | |
/* 478 */ } else { | |
/* 479 */ expand_value_89 = (double)(expand_value_90 / 3000000.0D); | |
/* 480 */ } | |
/* 481 */ } | |
/* 482 */ boolean expand_isNull_88 = expand_isNull_89; | |
/* 483 */ long expand_value_88 = -1L; | |
/* 484 */ | |
/* 485 */ if (!expand_isNull_89) { | |
/* 486 */ expand_value_88 = (long)(java.lang.Math.ceil(expand_value_89)); | |
/* 487 */ } | |
/* 488 */ expand_isNull_57 = expand_isNull_88; | |
/* 489 */ expand_value_57 = expand_value_88; | |
/* 490 */ } | |
/* 491 */ if (!expand_isNull_57) { | |
/* 492 */ expand_isNull_56 = false; // resultCode could change nullability. | |
/* 493 */ | |
/* 494 */ expand_value_56 = expand_value_57 + 0L; | |
/* 495 */ | |
/* 496 */ } | |
/* 497 */ if (!expand_isNull_56) { | |
/* 498 */ expand_isNull_55 = false; // resultCode could change nullability. | |
/* 499 */ | |
/* 500 */ expand_value_55 = expand_value_56 - 4L; | |
/* 501 */ | |
/* 502 */ } | |
/* 503 */ if (!expand_isNull_55) { | |
/* 504 */ expand_isNull_54 = false; // resultCode could change nullability. | |
/* 505 */ | |
/* 506 */ expand_value_54 = expand_value_55 * 3000000L; | |
/* 507 */ | |
/* 508 */ } | |
/* 509 */ if (!expand_isNull_54) { | |
/* 510 */ expand_isNull_53 = false; // resultCode could change nullability. | |
/* 511 */ | |
/* 512 */ expand_value_53 = expand_value_54 + 10000000L; | |
/* 513 */ | |
/* 514 */ } | |
/* 515 */ boolean expand_isNull_52 = expand_isNull_53; | |
/* 516 */ long expand_value_52 = expand_value_53; | |
/* 517 */ if (expand_isNull_52) { | |
/* 518 */ expand_values_0[1] = null; | |
/* 519 */ } else { | |
/* 520 */ expand_values_0[1] = expand_value_52; | |
/* 521 */ } | |
/* 522 */ | |
/* 523 */ final InternalRow expand_value_2 = new org.apache.spark.sql.catalyst.expressions.GenericInternalRow(expand_values_0); | |
/* 524 */ expand_values_0 = null; | |
/* 525 */ expand_resultIsNull_0 = false; | |
/* 526 */ expand_mutableStateArray_0[0] = expand_value_2; | |
/* 527 */ | |
/* 528 */ break; | |
/* 529 */ | |
/* 530 */ case 1: | |
/* 531 */ | |
/* 532 */ Object[] expand_values_1 = new Object[2]; | |
/* 533 */ | |
/* 534 */ boolean expand_isNull_103 = true; | |
/* 535 */ long expand_value_103 = -1L; | |
/* 536 */ boolean expand_isNull_104 = true; | |
/* 537 */ long expand_value_104 = -1L; | |
/* 538 */ boolean expand_isNull_105 = true; | |
/* 539 */ long expand_value_105 = -1L; | |
/* 540 */ boolean expand_isNull_106 = true; | |
/* 541 */ long expand_value_106 = -1L; | |
/* 542 */ boolean expand_isNull_108 = true; | |
/* 543 */ boolean expand_value_108 = false; | |
/* 544 */ boolean expand_isNull_111 = false; | |
/* 545 */ double expand_value_111 = -1.0; | |
/* 546 */ if (false || 3000000.0D == 0) { | |
/* 547 */ expand_isNull_111 = true; | |
/* 548 */ } else { | |
/* 549 */ boolean expand_isNull_113 = true; | |
/* 550 */ long expand_value_113 = -1L; | |
/* 551 */ boolean expand_isNull_115 = localtablescan_isNull_0; | |
/* 552 */ long expand_value_115 = -1L; | |
/* 553 */ if (!localtablescan_isNull_0) { | |
/* 554 */ scala.Option<Long> expand_longOpt_8 = | |
/* 555 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[9] /* zoneId */)); | |
/* 556 */ if (expand_longOpt_8.isDefined()) { | |
/* 557 */ expand_value_115 = ((Long) expand_longOpt_8.get()).longValue(); | |
/* 558 */ } else { | |
/* 559 */ expand_isNull_115 = true; | |
/* 560 */ } | |
/* 561 */ } | |
/* 562 */ boolean expand_isNull_114 = expand_isNull_115; | |
/* 563 */ long expand_value_114 = expand_value_115; | |
/* 564 */ if (!expand_isNull_114) { | |
/* 565 */ expand_isNull_113 = false; // resultCode could change nullability. | |
/* 566 */ | |
/* 567 */ expand_value_113 = expand_value_114 - 0L; | |
/* 568 */ | |
/* 569 */ } | |
/* 570 */ boolean expand_isNull_112 = expand_isNull_113; | |
/* 571 */ double expand_value_112 = -1.0; | |
/* 572 */ if (!expand_isNull_113) { | |
/* 573 */ expand_value_112 = (double) expand_value_113; | |
/* 574 */ } | |
/* 575 */ if (expand_isNull_112) { | |
/* 576 */ expand_isNull_111 = true; | |
/* 577 */ } else { | |
/* 578 */ expand_value_111 = (double)(expand_value_112 / 3000000.0D); | |
/* 579 */ } | |
/* 580 */ } | |
/* 581 */ boolean expand_isNull_110 = expand_isNull_111; | |
/* 582 */ long expand_value_110 = -1L; | |
/* 583 */ | |
/* 584 */ if (!expand_isNull_111) { | |
/* 585 */ expand_value_110 = (long)(java.lang.Math.ceil(expand_value_111)); | |
/* 586 */ } | |
/* 587 */ boolean expand_isNull_109 = expand_isNull_110; | |
/* 588 */ double expand_value_109 = -1.0; | |
/* 589 */ if (!expand_isNull_110) { | |
/* 590 */ expand_value_109 = (double) expand_value_110; | |
/* 591 */ } | |
/* 592 */ if (!expand_isNull_109) { | |
/* 593 */ boolean expand_isNull_119 = false; | |
/* 594 */ double expand_value_119 = -1.0; | |
/* 595 */ if (false || 3000000.0D == 0) { | |
/* 596 */ expand_isNull_119 = true; | |
/* 597 */ } else { | |
/* 598 */ boolean expand_isNull_121 = true; | |
/* 599 */ long expand_value_121 = -1L; | |
/* 600 */ boolean expand_isNull_123 = localtablescan_isNull_0; | |
/* 601 */ long expand_value_123 = -1L; | |
/* 602 */ if (!localtablescan_isNull_0) { | |
/* 603 */ scala.Option<Long> expand_longOpt_9 = | |
/* 604 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[10] /* zoneId */)); | |
/* 605 */ if (expand_longOpt_9.isDefined()) { | |
/* 606 */ expand_value_123 = ((Long) expand_longOpt_9.get()).longValue(); | |
/* 607 */ } else { | |
/* 608 */ expand_isNull_123 = true; | |
/* 609 */ } | |
/* 610 */ } | |
/* 611 */ boolean expand_isNull_122 = expand_isNull_123; | |
/* 612 */ long expand_value_122 = expand_value_123; | |
/* 613 */ if (!expand_isNull_122) { | |
/* 614 */ expand_isNull_121 = false; // resultCode could change nullability. | |
/* 615 */ | |
/* 616 */ expand_value_121 = expand_value_122 - 0L; | |
/* 617 */ | |
/* 618 */ } | |
/* 619 */ boolean expand_isNull_120 = expand_isNull_121; | |
/* 620 */ double expand_value_120 = -1.0; | |
/* 621 */ if (!expand_isNull_121) { | |
/* 622 */ expand_value_120 = (double) expand_value_121; | |
/* 623 */ } | |
/* 624 */ if (expand_isNull_120) { | |
/* 625 */ expand_isNull_119 = true; | |
/* 626 */ } else { | |
/* 627 */ expand_value_119 = (double)(expand_value_120 / 3000000.0D); | |
/* 628 */ } | |
/* 629 */ } | |
/* 630 */ if (!expand_isNull_119) { | |
/* 631 */ expand_isNull_108 = false; // resultCode could change nullability. | |
/* 632 */ expand_value_108 = ((java.lang.Double.isNaN(expand_value_109) && java.lang.Double.isNaN(expand_value_119)) || expand_value_109 == expand_value_119); | |
/* 633 */ | |
/* 634 */ } | |
/* 635 */ | |
/* 636 */ } | |
/* 637 */ boolean expand_isNull_107 = false; | |
/* 638 */ long expand_value_107 = -1L; | |
/* 639 */ if (!expand_isNull_108 && expand_value_108) { | |
/* 640 */ boolean expand_isNull_127 = true; | |
/* 641 */ long expand_value_127 = -1L; | |
/* 642 */ boolean expand_isNull_129 = false; | |
/* 643 */ double expand_value_129 = -1.0; | |
/* 644 */ if (false || 3000000.0D == 0) { | |
/* 645 */ expand_isNull_129 = true; | |
/* 646 */ } else { | |
/* 647 */ boolean expand_isNull_131 = true; | |
/* 648 */ long expand_value_131 = -1L; | |
/* 649 */ boolean expand_isNull_133 = localtablescan_isNull_0; | |
/* 650 */ long expand_value_133 = -1L; | |
/* 651 */ if (!localtablescan_isNull_0) { | |
/* 652 */ scala.Option<Long> expand_longOpt_10 = | |
/* 653 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[11] /* zoneId */)); | |
/* 654 */ if (expand_longOpt_10.isDefined()) { | |
/* 655 */ expand_value_133 = ((Long) expand_longOpt_10.get()).longValue(); | |
/* 656 */ } else { | |
/* 657 */ expand_isNull_133 = true; | |
/* 658 */ } | |
/* 659 */ } | |
/* 660 */ boolean expand_isNull_132 = expand_isNull_133; | |
/* 661 */ long expand_value_132 = expand_value_133; | |
/* 662 */ if (!expand_isNull_132) { | |
/* 663 */ expand_isNull_131 = false; // resultCode could change nullability. | |
/* 664 */ | |
/* 665 */ expand_value_131 = expand_value_132 - 0L; | |
/* 666 */ | |
/* 667 */ } | |
/* 668 */ boolean expand_isNull_130 = expand_isNull_131; | |
/* 669 */ double expand_value_130 = -1.0; | |
/* 670 */ if (!expand_isNull_131) { | |
/* 671 */ expand_value_130 = (double) expand_value_131; | |
/* 672 */ } | |
/* 673 */ if (expand_isNull_130) { | |
/* 674 */ expand_isNull_129 = true; | |
/* 675 */ } else { | |
/* 676 */ expand_value_129 = (double)(expand_value_130 / 3000000.0D); | |
/* 677 */ } | |
/* 678 */ } | |
/* 679 */ boolean expand_isNull_128 = expand_isNull_129; | |
/* 680 */ long expand_value_128 = -1L; | |
/* 681 */ | |
/* 682 */ if (!expand_isNull_129) { | |
/* 683 */ expand_value_128 = (long)(java.lang.Math.ceil(expand_value_129)); | |
/* 684 */ } | |
/* 685 */ if (!expand_isNull_128) { | |
/* 686 */ expand_isNull_127 = false; // resultCode could change nullability. | |
/* 687 */ | |
/* 688 */ expand_value_127 = expand_value_128 + 1L; | |
/* 689 */ | |
/* 690 */ } | |
/* 691 */ expand_isNull_107 = expand_isNull_127; | |
/* 692 */ expand_value_107 = expand_value_127; | |
/* 693 */ } else { | |
/* 694 */ boolean expand_isNull_139 = false; | |
/* 695 */ double expand_value_139 = -1.0; | |
/* 696 */ if (false || 3000000.0D == 0) { | |
/* 697 */ expand_isNull_139 = true; | |
/* 698 */ } else { | |
/* 699 */ boolean expand_isNull_141 = true; | |
/* 700 */ long expand_value_141 = -1L; | |
/* 701 */ boolean expand_isNull_143 = localtablescan_isNull_0; | |
/* 702 */ long expand_value_143 = -1L; | |
/* 703 */ if (!localtablescan_isNull_0) { | |
/* 704 */ scala.Option<Long> expand_longOpt_11 = | |
/* 705 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[12] /* zoneId */)); | |
/* 706 */ if (expand_longOpt_11.isDefined()) { | |
/* 707 */ expand_value_143 = ((Long) expand_longOpt_11.get()).longValue(); | |
/* 708 */ } else { | |
/* 709 */ expand_isNull_143 = true; | |
/* 710 */ } | |
/* 711 */ } | |
/* 712 */ boolean expand_isNull_142 = expand_isNull_143; | |
/* 713 */ long expand_value_142 = expand_value_143; | |
/* 714 */ if (!expand_isNull_142) { | |
/* 715 */ expand_isNull_141 = false; // resultCode could change nullability. | |
/* 716 */ | |
/* 717 */ expand_value_141 = expand_value_142 - 0L; | |
/* 718 */ | |
/* 719 */ } | |
/* 720 */ boolean expand_isNull_140 = expand_isNull_141; | |
/* 721 */ double expand_value_140 = -1.0; | |
/* 722 */ if (!expand_isNull_141) { | |
/* 723 */ expand_value_140 = (double) expand_value_141; | |
/* 724 */ } | |
/* 725 */ if (expand_isNull_140) { | |
/* 726 */ expand_isNull_139 = true; | |
/* 727 */ } else { | |
/* 728 */ expand_value_139 = (double)(expand_value_140 / 3000000.0D); | |
/* 729 */ } | |
/* 730 */ } | |
/* 731 */ boolean expand_isNull_138 = expand_isNull_139; | |
/* 732 */ long expand_value_138 = -1L; | |
/* 733 */ | |
/* 734 */ if (!expand_isNull_139) { | |
/* 735 */ expand_value_138 = (long)(java.lang.Math.ceil(expand_value_139)); | |
/* 736 */ } | |
/* 737 */ expand_isNull_107 = expand_isNull_138; | |
/* 738 */ expand_value_107 = expand_value_138; | |
/* 739 */ } | |
/* 740 */ if (!expand_isNull_107) { | |
/* 741 */ expand_isNull_106 = false; // resultCode could change nullability. | |
/* 742 */ | |
/* 743 */ expand_value_106 = expand_value_107 + 1L; | |
/* 744 */ | |
/* 745 */ } | |
/* 746 */ if (!expand_isNull_106) { | |
/* 747 */ expand_isNull_105 = false; // resultCode could change nullability. | |
/* 748 */ | |
/* 749 */ expand_value_105 = expand_value_106 - 4L; | |
/* 750 */ | |
/* 751 */ } | |
/* 752 */ if (!expand_isNull_105) { | |
/* 753 */ expand_isNull_104 = false; // resultCode could change nullability. | |
/* 754 */ | |
/* 755 */ expand_value_104 = expand_value_105 * 3000000L; | |
/* 756 */ | |
/* 757 */ } | |
/* 758 */ if (!expand_isNull_104) { | |
/* 759 */ expand_isNull_103 = false; // resultCode could change nullability. | |
/* 760 */ | |
/* 761 */ expand_value_103 = expand_value_104 + 0L; | |
/* 762 */ | |
/* 763 */ } | |
/* 764 */ boolean expand_isNull_102 = expand_isNull_103; | |
/* 765 */ long expand_value_102 = expand_value_103; | |
/* 766 */ if (expand_isNull_102) { | |
/* 767 */ expand_values_1[0] = null; | |
/* 768 */ } else { | |
/* 769 */ expand_values_1[0] = expand_value_102; | |
/* 770 */ } | |
/* 771 */ | |
/* 772 */ boolean expand_isNull_152 = true; | |
/* 773 */ long expand_value_152 = -1L; | |
/* 774 */ boolean expand_isNull_153 = true; | |
/* 775 */ long expand_value_153 = -1L; | |
/* 776 */ boolean expand_isNull_154 = true; | |
/* 777 */ long expand_value_154 = -1L; | |
/* 778 */ boolean expand_isNull_155 = true; | |
/* 779 */ long expand_value_155 = -1L; | |
/* 780 */ boolean expand_isNull_157 = true; | |
/* 781 */ boolean expand_value_157 = false; | |
/* 782 */ boolean expand_isNull_160 = false; | |
/* 783 */ double expand_value_160 = -1.0; | |
/* 784 */ if (false || 3000000.0D == 0) { | |
/* 785 */ expand_isNull_160 = true; | |
/* 786 */ } else { | |
/* 787 */ boolean expand_isNull_162 = true; | |
/* 788 */ long expand_value_162 = -1L; | |
/* 789 */ boolean expand_isNull_164 = localtablescan_isNull_0; | |
/* 790 */ long expand_value_164 = -1L; | |
/* 791 */ if (!localtablescan_isNull_0) { | |
/* 792 */ scala.Option<Long> expand_longOpt_12 = | |
/* 793 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[13] /* zoneId */)); | |
/* 794 */ if (expand_longOpt_12.isDefined()) { | |
/* 795 */ expand_value_164 = ((Long) expand_longOpt_12.get()).longValue(); | |
/* 796 */ } else { | |
/* 797 */ expand_isNull_164 = true; | |
/* 798 */ } | |
/* 799 */ } | |
/* 800 */ boolean expand_isNull_163 = expand_isNull_164; | |
/* 801 */ long expand_value_163 = expand_value_164; | |
/* 802 */ if (!expand_isNull_163) { | |
/* 803 */ expand_isNull_162 = false; // resultCode could change nullability. | |
/* 804 */ | |
/* 805 */ expand_value_162 = expand_value_163 - 0L; | |
/* 806 */ | |
/* 807 */ } | |
/* 808 */ boolean expand_isNull_161 = expand_isNull_162; | |
/* 809 */ double expand_value_161 = -1.0; | |
/* 810 */ if (!expand_isNull_162) { | |
/* 811 */ expand_value_161 = (double) expand_value_162; | |
/* 812 */ } | |
/* 813 */ if (expand_isNull_161) { | |
/* 814 */ expand_isNull_160 = true; | |
/* 815 */ } else { | |
/* 816 */ expand_value_160 = (double)(expand_value_161 / 3000000.0D); | |
/* 817 */ } | |
/* 818 */ } | |
/* 819 */ boolean expand_isNull_159 = expand_isNull_160; | |
/* 820 */ long expand_value_159 = -1L; | |
/* 821 */ | |
/* 822 */ if (!expand_isNull_160) { | |
/* 823 */ expand_value_159 = (long)(java.lang.Math.ceil(expand_value_160)); | |
/* 824 */ } | |
/* 825 */ boolean expand_isNull_158 = expand_isNull_159; | |
/* 826 */ double expand_value_158 = -1.0; | |
/* 827 */ if (!expand_isNull_159) { | |
/* 828 */ expand_value_158 = (double) expand_value_159; | |
/* 829 */ } | |
/* 830 */ if (!expand_isNull_158) { | |
/* 831 */ boolean expand_isNull_168 = false; | |
/* 832 */ double expand_value_168 = -1.0; | |
/* 833 */ if (false || 3000000.0D == 0) { | |
/* 834 */ expand_isNull_168 = true; | |
/* 835 */ } else { | |
/* 836 */ boolean expand_isNull_170 = true; | |
/* 837 */ long expand_value_170 = -1L; | |
/* 838 */ boolean expand_isNull_172 = localtablescan_isNull_0; | |
/* 839 */ long expand_value_172 = -1L; | |
/* 840 */ if (!localtablescan_isNull_0) { | |
/* 841 */ scala.Option<Long> expand_longOpt_13 = | |
/* 842 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[14] /* zoneId */)); | |
/* 843 */ if (expand_longOpt_13.isDefined()) { | |
/* 844 */ expand_value_172 = ((Long) expand_longOpt_13.get()).longValue(); | |
/* 845 */ } else { | |
/* 846 */ expand_isNull_172 = true; | |
/* 847 */ } | |
/* 848 */ } | |
/* 849 */ boolean expand_isNull_171 = expand_isNull_172; | |
/* 850 */ long expand_value_171 = expand_value_172; | |
/* 851 */ if (!expand_isNull_171) { | |
/* 852 */ expand_isNull_170 = false; // resultCode could change nullability. | |
/* 853 */ | |
/* 854 */ expand_value_170 = expand_value_171 - 0L; | |
/* 855 */ | |
/* 856 */ } | |
/* 857 */ boolean expand_isNull_169 = expand_isNull_170; | |
/* 858 */ double expand_value_169 = -1.0; | |
/* 859 */ if (!expand_isNull_170) { | |
/* 860 */ expand_value_169 = (double) expand_value_170; | |
/* 861 */ } | |
/* 862 */ if (expand_isNull_169) { | |
/* 863 */ expand_isNull_168 = true; | |
/* 864 */ } else { | |
/* 865 */ expand_value_168 = (double)(expand_value_169 / 3000000.0D); | |
/* 866 */ } | |
/* 867 */ } | |
/* 868 */ if (!expand_isNull_168) { | |
/* 869 */ expand_isNull_157 = false; // resultCode could change nullability. | |
/* 870 */ expand_value_157 = ((java.lang.Double.isNaN(expand_value_158) && java.lang.Double.isNaN(expand_value_168)) || expand_value_158 == expand_value_168); | |
/* 871 */ | |
/* 872 */ } | |
/* 873 */ | |
/* 874 */ } | |
/* 875 */ boolean expand_isNull_156 = false; | |
/* 876 */ long expand_value_156 = -1L; | |
/* 877 */ if (!expand_isNull_157 && expand_value_157) { | |
/* 878 */ boolean expand_isNull_176 = true; | |
/* 879 */ long expand_value_176 = -1L; | |
/* 880 */ boolean expand_isNull_178 = false; | |
/* 881 */ double expand_value_178 = -1.0; | |
/* 882 */ if (false || 3000000.0D == 0) { | |
/* 883 */ expand_isNull_178 = true; | |
/* 884 */ } else { | |
/* 885 */ boolean expand_isNull_180 = true; | |
/* 886 */ long expand_value_180 = -1L; | |
/* 887 */ boolean expand_isNull_182 = localtablescan_isNull_0; | |
/* 888 */ long expand_value_182 = -1L; | |
/* 889 */ if (!localtablescan_isNull_0) { | |
/* 890 */ scala.Option<Long> expand_longOpt_14 = | |
/* 891 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[15] /* zoneId */)); | |
/* 892 */ if (expand_longOpt_14.isDefined()) { | |
/* 893 */ expand_value_182 = ((Long) expand_longOpt_14.get()).longValue(); | |
/* 894 */ } else { | |
/* 895 */ expand_isNull_182 = true; | |
/* 896 */ } | |
/* 897 */ } | |
/* 898 */ boolean expand_isNull_181 = expand_isNull_182; | |
/* 899 */ long expand_value_181 = expand_value_182; | |
/* 900 */ if (!expand_isNull_181) { | |
/* 901 */ expand_isNull_180 = false; // resultCode could change nullability. | |
/* 902 */ | |
/* 903 */ expand_value_180 = expand_value_181 - 0L; | |
/* 904 */ | |
/* 905 */ } | |
/* 906 */ boolean expand_isNull_179 = expand_isNull_180; | |
/* 907 */ double expand_value_179 = -1.0; | |
/* 908 */ if (!expand_isNull_180) { | |
/* 909 */ expand_value_179 = (double) expand_value_180; | |
/* 910 */ } | |
/* 911 */ if (expand_isNull_179) { | |
/* 912 */ expand_isNull_178 = true; | |
/* 913 */ } else { | |
/* 914 */ expand_value_178 = (double)(expand_value_179 / 3000000.0D); | |
/* 915 */ } | |
/* 916 */ } | |
/* 917 */ boolean expand_isNull_177 = expand_isNull_178; | |
/* 918 */ long expand_value_177 = -1L; | |
/* 919 */ | |
/* 920 */ if (!expand_isNull_178) { | |
/* 921 */ expand_value_177 = (long)(java.lang.Math.ceil(expand_value_178)); | |
/* 922 */ } | |
/* 923 */ if (!expand_isNull_177) { | |
/* 924 */ expand_isNull_176 = false; // resultCode could change nullability. | |
/* 925 */ | |
/* 926 */ expand_value_176 = expand_value_177 + 1L; | |
/* 927 */ | |
/* 928 */ } | |
/* 929 */ expand_isNull_156 = expand_isNull_176; | |
/* 930 */ expand_value_156 = expand_value_176; | |
/* 931 */ } else { | |
/* 932 */ boolean expand_isNull_188 = false; | |
/* 933 */ double expand_value_188 = -1.0; | |
/* 934 */ if (false || 3000000.0D == 0) { | |
/* 935 */ expand_isNull_188 = true; | |
/* 936 */ } else { | |
/* 937 */ boolean expand_isNull_190 = true; | |
/* 938 */ long expand_value_190 = -1L; | |
/* 939 */ boolean expand_isNull_192 = localtablescan_isNull_0; | |
/* 940 */ long expand_value_192 = -1L; | |
/* 941 */ if (!localtablescan_isNull_0) { | |
/* 942 */ scala.Option<Long> expand_longOpt_15 = | |
/* 943 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[16] /* zoneId */)); | |
/* 944 */ if (expand_longOpt_15.isDefined()) { | |
/* 945 */ expand_value_192 = ((Long) expand_longOpt_15.get()).longValue(); | |
/* 946 */ } else { | |
/* 947 */ expand_isNull_192 = true; | |
/* 948 */ } | |
/* 949 */ } | |
/* 950 */ boolean expand_isNull_191 = expand_isNull_192; | |
/* 951 */ long expand_value_191 = expand_value_192; | |
/* 952 */ if (!expand_isNull_191) { | |
/* 953 */ expand_isNull_190 = false; // resultCode could change nullability. | |
/* 954 */ | |
/* 955 */ expand_value_190 = expand_value_191 - 0L; | |
/* 956 */ | |
/* 957 */ } | |
/* 958 */ boolean expand_isNull_189 = expand_isNull_190; | |
/* 959 */ double expand_value_189 = -1.0; | |
/* 960 */ if (!expand_isNull_190) { | |
/* 961 */ expand_value_189 = (double) expand_value_190; | |
/* 962 */ } | |
/* 963 */ if (expand_isNull_189) { | |
/* 964 */ expand_isNull_188 = true; | |
/* 965 */ } else { | |
/* 966 */ expand_value_188 = (double)(expand_value_189 / 3000000.0D); | |
/* 967 */ } | |
/* 968 */ } | |
/* 969 */ boolean expand_isNull_187 = expand_isNull_188; | |
/* 970 */ long expand_value_187 = -1L; | |
/* 971 */ | |
/* 972 */ if (!expand_isNull_188) { | |
/* 973 */ expand_value_187 = (long)(java.lang.Math.ceil(expand_value_188)); | |
/* 974 */ } | |
/* 975 */ expand_isNull_156 = expand_isNull_187; | |
/* 976 */ expand_value_156 = expand_value_187; | |
/* 977 */ } | |
/* 978 */ if (!expand_isNull_156) { | |
/* 979 */ expand_isNull_155 = false; // resultCode could change nullability. | |
/* 980 */ | |
/* 981 */ expand_value_155 = expand_value_156 + 1L; | |
/* 982 */ | |
/* 983 */ } | |
/* 984 */ if (!expand_isNull_155) { | |
/* 985 */ expand_isNull_154 = false; // resultCode could change nullability. | |
/* 986 */ | |
/* 987 */ expand_value_154 = expand_value_155 - 4L; | |
/* 988 */ | |
/* 989 */ } | |
/* 990 */ if (!expand_isNull_154) { | |
/* 991 */ expand_isNull_153 = false; // resultCode could change nullability. | |
/* 992 */ | |
/* 993 */ expand_value_153 = expand_value_154 * 3000000L; | |
/* 994 */ | |
/* 995 */ } | |
/* 996 */ if (!expand_isNull_153) { | |
/* 997 */ expand_isNull_152 = false; // resultCode could change nullability. | |
/* 998 */ | |
/* 999 */ expand_value_152 = expand_value_153 + 10000000L; | |
/* 1000 */ | |
/* 1001 */ } | |
/* 1002 */ boolean expand_isNull_151 = expand_isNull_152; | |
/* 1003 */ long expand_value_151 = expand_value_152; | |
/* 1004 */ if (expand_isNull_151) { | |
/* 1005 */ expand_values_1[1] = null; | |
/* 1006 */ } else { | |
/* 1007 */ expand_values_1[1] = expand_value_151; | |
/* 1008 */ } | |
/* 1009 */ | |
/* 1010 */ final InternalRow expand_value_101 = new org.apache.spark.sql.catalyst.expressions.GenericInternalRow(expand_values_1); | |
/* 1011 */ expand_values_1 = null; | |
/* 1012 */ expand_resultIsNull_0 = false; | |
/* 1013 */ expand_mutableStateArray_0[0] = expand_value_101; | |
/* 1014 */ | |
/* 1015 */ break; | |
/* 1016 */ | |
/* 1017 */ case 2: | |
/* 1018 */ | |
/* 1019 */ Object[] expand_values_2 = new Object[2]; | |
/* 1020 */ | |
/* 1021 */ boolean expand_isNull_202 = true; | |
/* 1022 */ long expand_value_202 = -1L; | |
/* 1023 */ boolean expand_isNull_203 = true; | |
/* 1024 */ long expand_value_203 = -1L; | |
/* 1025 */ boolean expand_isNull_204 = true; | |
/* 1026 */ long expand_value_204 = -1L; | |
/* 1027 */ boolean expand_isNull_205 = true; | |
/* 1028 */ long expand_value_205 = -1L; | |
/* 1029 */ boolean expand_isNull_207 = true; | |
/* 1030 */ boolean expand_value_207 = false; | |
/* 1031 */ boolean expand_isNull_210 = false; | |
/* 1032 */ double expand_value_210 = -1.0; | |
/* 1033 */ if (false || 3000000.0D == 0) { | |
/* 1034 */ expand_isNull_210 = true; | |
/* 1035 */ } else { | |
/* 1036 */ boolean expand_isNull_212 = true; | |
/* 1037 */ long expand_value_212 = -1L; | |
/* 1038 */ boolean expand_isNull_214 = localtablescan_isNull_0; | |
/* 1039 */ long expand_value_214 = -1L; | |
/* 1040 */ if (!localtablescan_isNull_0) { | |
/* 1041 */ scala.Option<Long> expand_longOpt_16 = | |
/* 1042 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[17] /* zoneId */)); | |
/* 1043 */ if (expand_longOpt_16.isDefined()) { | |
/* 1044 */ expand_value_214 = ((Long) expand_longOpt_16.get()).longValue(); | |
/* 1045 */ } else { | |
/* 1046 */ expand_isNull_214 = true; | |
/* 1047 */ } | |
/* 1048 */ } | |
/* 1049 */ boolean expand_isNull_213 = expand_isNull_214; | |
/* 1050 */ long expand_value_213 = expand_value_214; | |
/* 1051 */ if (!expand_isNull_213) { | |
/* 1052 */ expand_isNull_212 = false; // resultCode could change nullability. | |
/* 1053 */ | |
/* 1054 */ expand_value_212 = expand_value_213 - 0L; | |
/* 1055 */ | |
/* 1056 */ } | |
/* 1057 */ boolean expand_isNull_211 = expand_isNull_212; | |
/* 1058 */ double expand_value_211 = -1.0; | |
/* 1059 */ if (!expand_isNull_212) { | |
/* 1060 */ expand_value_211 = (double) expand_value_212; | |
/* 1061 */ } | |
/* 1062 */ if (expand_isNull_211) { | |
/* 1063 */ expand_isNull_210 = true; | |
/* 1064 */ } else { | |
/* 1065 */ expand_value_210 = (double)(expand_value_211 / 3000000.0D); | |
/* 1066 */ } | |
/* 1067 */ } | |
/* 1068 */ boolean expand_isNull_209 = expand_isNull_210; | |
/* 1069 */ long expand_value_209 = -1L; | |
/* 1070 */ | |
/* 1071 */ if (!expand_isNull_210) { | |
/* 1072 */ expand_value_209 = (long)(java.lang.Math.ceil(expand_value_210)); | |
/* 1073 */ } | |
/* 1074 */ boolean expand_isNull_208 = expand_isNull_209; | |
/* 1075 */ double expand_value_208 = -1.0; | |
/* 1076 */ if (!expand_isNull_209) { | |
/* 1077 */ expand_value_208 = (double) expand_value_209; | |
/* 1078 */ } | |
/* 1079 */ if (!expand_isNull_208) { | |
/* 1080 */ boolean expand_isNull_218 = false; | |
/* 1081 */ double expand_value_218 = -1.0; | |
/* 1082 */ if (false || 3000000.0D == 0) { | |
/* 1083 */ expand_isNull_218 = true; | |
/* 1084 */ } else { | |
/* 1085 */ boolean expand_isNull_220 = true; | |
/* 1086 */ long expand_value_220 = -1L; | |
/* 1087 */ boolean expand_isNull_222 = localtablescan_isNull_0; | |
/* 1088 */ long expand_value_222 = -1L; | |
/* 1089 */ if (!localtablescan_isNull_0) { | |
/* 1090 */ scala.Option<Long> expand_longOpt_17 = | |
/* 1091 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[18] /* zoneId */)); | |
/* 1092 */ if (expand_longOpt_17.isDefined()) { | |
/* 1093 */ expand_value_222 = ((Long) expand_longOpt_17.get()).longValue(); | |
/* 1094 */ } else { | |
/* 1095 */ expand_isNull_222 = true; | |
/* 1096 */ } | |
/* 1097 */ } | |
/* 1098 */ boolean expand_isNull_221 = expand_isNull_222; | |
/* 1099 */ long expand_value_221 = expand_value_222; | |
/* 1100 */ if (!expand_isNull_221) { | |
/* 1101 */ expand_isNull_220 = false; // resultCode could change nullability. | |
/* 1102 */ | |
/* 1103 */ expand_value_220 = expand_value_221 - 0L; | |
/* 1104 */ | |
/* 1105 */ } | |
/* 1106 */ boolean expand_isNull_219 = expand_isNull_220; | |
/* 1107 */ double expand_value_219 = -1.0; | |
/* 1108 */ if (!expand_isNull_220) { | |
/* 1109 */ expand_value_219 = (double) expand_value_220; | |
/* 1110 */ } | |
/* 1111 */ if (expand_isNull_219) { | |
/* 1112 */ expand_isNull_218 = true; | |
/* 1113 */ } else { | |
/* 1114 */ expand_value_218 = (double)(expand_value_219 / 3000000.0D); | |
/* 1115 */ } | |
/* 1116 */ } | |
/* 1117 */ if (!expand_isNull_218) { | |
/* 1118 */ expand_isNull_207 = false; // resultCode could change nullability. | |
/* 1119 */ expand_value_207 = ((java.lang.Double.isNaN(expand_value_208) && java.lang.Double.isNaN(expand_value_218)) || expand_value_208 == expand_value_218); | |
/* 1120 */ | |
/* 1121 */ } | |
/* 1122 */ | |
/* 1123 */ } | |
/* 1124 */ boolean expand_isNull_206 = false; | |
/* 1125 */ long expand_value_206 = -1L; | |
/* 1126 */ if (!expand_isNull_207 && expand_value_207) { | |
/* 1127 */ boolean expand_isNull_226 = true; | |
/* 1128 */ long expand_value_226 = -1L; | |
/* 1129 */ boolean expand_isNull_228 = false; | |
/* 1130 */ double expand_value_228 = -1.0; | |
/* 1131 */ if (false || 3000000.0D == 0) { | |
/* 1132 */ expand_isNull_228 = true; | |
/* 1133 */ } else { | |
/* 1134 */ boolean expand_isNull_230 = true; | |
/* 1135 */ long expand_value_230 = -1L; | |
/* 1136 */ boolean expand_isNull_232 = localtablescan_isNull_0; | |
/* 1137 */ long expand_value_232 = -1L; | |
/* 1138 */ if (!localtablescan_isNull_0) { | |
/* 1139 */ scala.Option<Long> expand_longOpt_18 = | |
/* 1140 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[19] /* zoneId */)); | |
/* 1141 */ if (expand_longOpt_18.isDefined()) { | |
/* 1142 */ expand_value_232 = ((Long) expand_longOpt_18.get()).longValue(); | |
/* 1143 */ } else { | |
/* 1144 */ expand_isNull_232 = true; | |
/* 1145 */ } | |
/* 1146 */ } | |
/* 1147 */ boolean expand_isNull_231 = expand_isNull_232; | |
/* 1148 */ long expand_value_231 = expand_value_232; | |
/* 1149 */ if (!expand_isNull_231) { | |
/* 1150 */ expand_isNull_230 = false; // resultCode could change nullability. | |
/* 1151 */ | |
/* 1152 */ expand_value_230 = expand_value_231 - 0L; | |
/* 1153 */ | |
/* 1154 */ } | |
/* 1155 */ boolean expand_isNull_229 = expand_isNull_230; | |
/* 1156 */ double expand_value_229 = -1.0; | |
/* 1157 */ if (!expand_isNull_230) { | |
/* 1158 */ expand_value_229 = (double) expand_value_230; | |
/* 1159 */ } | |
/* 1160 */ if (expand_isNull_229) { | |
/* 1161 */ expand_isNull_228 = true; | |
/* 1162 */ } else { | |
/* 1163 */ expand_value_228 = (double)(expand_value_229 / 3000000.0D); | |
/* 1164 */ } | |
/* 1165 */ } | |
/* 1166 */ boolean expand_isNull_227 = expand_isNull_228; | |
/* 1167 */ long expand_value_227 = -1L; | |
/* 1168 */ | |
/* 1169 */ if (!expand_isNull_228) { | |
/* 1170 */ expand_value_227 = (long)(java.lang.Math.ceil(expand_value_228)); | |
/* 1171 */ } | |
/* 1172 */ if (!expand_isNull_227) { | |
/* 1173 */ expand_isNull_226 = false; // resultCode could change nullability. | |
/* 1174 */ | |
/* 1175 */ expand_value_226 = expand_value_227 + 1L; | |
/* 1176 */ | |
/* 1177 */ } | |
/* 1178 */ expand_isNull_206 = expand_isNull_226; | |
/* 1179 */ expand_value_206 = expand_value_226; | |
/* 1180 */ } else { | |
/* 1181 */ boolean expand_isNull_238 = false; | |
/* 1182 */ double expand_value_238 = -1.0; | |
/* 1183 */ if (false || 3000000.0D == 0) { | |
/* 1184 */ expand_isNull_238 = true; | |
/* 1185 */ } else { | |
/* 1186 */ boolean expand_isNull_240 = true; | |
/* 1187 */ long expand_value_240 = -1L; | |
/* 1188 */ boolean expand_isNull_242 = localtablescan_isNull_0; | |
/* 1189 */ long expand_value_242 = -1L; | |
/* 1190 */ if (!localtablescan_isNull_0) { | |
/* 1191 */ scala.Option<Long> expand_longOpt_19 = | |
/* 1192 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[20] /* zoneId */)); | |
/* 1193 */ if (expand_longOpt_19.isDefined()) { | |
/* 1194 */ expand_value_242 = ((Long) expand_longOpt_19.get()).longValue(); | |
/* 1195 */ } else { | |
/* 1196 */ expand_isNull_242 = true; | |
/* 1197 */ } | |
/* 1198 */ } | |
/* 1199 */ boolean expand_isNull_241 = expand_isNull_242; | |
/* 1200 */ long expand_value_241 = expand_value_242; | |
/* 1201 */ if (!expand_isNull_241) { | |
/* 1202 */ expand_isNull_240 = false; // resultCode could change nullability. | |
/* 1203 */ | |
/* 1204 */ expand_value_240 = expand_value_241 - 0L; | |
/* 1205 */ | |
/* 1206 */ } | |
/* 1207 */ boolean expand_isNull_239 = expand_isNull_240; | |
/* 1208 */ double expand_value_239 = -1.0; | |
/* 1209 */ if (!expand_isNull_240) { | |
/* 1210 */ expand_value_239 = (double) expand_value_240; | |
/* 1211 */ } | |
/* 1212 */ if (expand_isNull_239) { | |
/* 1213 */ expand_isNull_238 = true; | |
/* 1214 */ } else { | |
/* 1215 */ expand_value_238 = (double)(expand_value_239 / 3000000.0D); | |
/* 1216 */ } | |
/* 1217 */ } | |
/* 1218 */ boolean expand_isNull_237 = expand_isNull_238; | |
/* 1219 */ long expand_value_237 = -1L; | |
/* 1220 */ | |
/* 1221 */ if (!expand_isNull_238) { | |
/* 1222 */ expand_value_237 = (long)(java.lang.Math.ceil(expand_value_238)); | |
/* 1223 */ } | |
/* 1224 */ expand_isNull_206 = expand_isNull_237; | |
/* 1225 */ expand_value_206 = expand_value_237; | |
/* 1226 */ } | |
/* 1227 */ if (!expand_isNull_206) { | |
/* 1228 */ expand_isNull_205 = false; // resultCode could change nullability. | |
/* 1229 */ | |
/* 1230 */ expand_value_205 = expand_value_206 + 2L; | |
/* 1231 */ | |
/* 1232 */ } | |
/* 1233 */ if (!expand_isNull_205) { | |
/* 1234 */ expand_isNull_204 = false; // resultCode could change nullability. | |
/* 1235 */ | |
/* 1236 */ expand_value_204 = expand_value_205 - 4L; | |
/* 1237 */ | |
/* 1238 */ } | |
/* 1239 */ if (!expand_isNull_204) { | |
/* 1240 */ expand_isNull_203 = false; // resultCode could change nullability. | |
/* 1241 */ | |
/* 1242 */ expand_value_203 = expand_value_204 * 3000000L; | |
/* 1243 */ | |
/* 1244 */ } | |
/* 1245 */ if (!expand_isNull_203) { | |
/* 1246 */ expand_isNull_202 = false; // resultCode could change nullability. | |
/* 1247 */ | |
/* 1248 */ expand_value_202 = expand_value_203 + 0L; | |
/* 1249 */ | |
/* 1250 */ } | |
/* 1251 */ boolean expand_isNull_201 = expand_isNull_202; | |
/* 1252 */ long expand_value_201 = expand_value_202; | |
/* 1253 */ if (expand_isNull_201) { | |
/* 1254 */ expand_values_2[0] = null; | |
/* 1255 */ } else { | |
/* 1256 */ expand_values_2[0] = expand_value_201; | |
/* 1257 */ } | |
/* 1258 */ | |
/* 1259 */ boolean expand_isNull_251 = true; | |
/* 1260 */ long expand_value_251 = -1L; | |
/* 1261 */ boolean expand_isNull_252 = true; | |
/* 1262 */ long expand_value_252 = -1L; | |
/* 1263 */ boolean expand_isNull_253 = true; | |
/* 1264 */ long expand_value_253 = -1L; | |
/* 1265 */ boolean expand_isNull_254 = true; | |
/* 1266 */ long expand_value_254 = -1L; | |
/* 1267 */ boolean expand_isNull_256 = true; | |
/* 1268 */ boolean expand_value_256 = false; | |
/* 1269 */ boolean expand_isNull_259 = false; | |
/* 1270 */ double expand_value_259 = -1.0; | |
/* 1271 */ if (false || 3000000.0D == 0) { | |
/* 1272 */ expand_isNull_259 = true; | |
/* 1273 */ } else { | |
/* 1274 */ boolean expand_isNull_261 = true; | |
/* 1275 */ long expand_value_261 = -1L; | |
/* 1276 */ boolean expand_isNull_263 = localtablescan_isNull_0; | |
/* 1277 */ long expand_value_263 = -1L; | |
/* 1278 */ if (!localtablescan_isNull_0) { | |
/* 1279 */ scala.Option<Long> expand_longOpt_20 = | |
/* 1280 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[21] /* zoneId */)); | |
/* 1281 */ if (expand_longOpt_20.isDefined()) { | |
/* 1282 */ expand_value_263 = ((Long) expand_longOpt_20.get()).longValue(); | |
/* 1283 */ } else { | |
/* 1284 */ expand_isNull_263 = true; | |
/* 1285 */ } | |
/* 1286 */ } | |
/* 1287 */ boolean expand_isNull_262 = expand_isNull_263; | |
/* 1288 */ long expand_value_262 = expand_value_263; | |
/* 1289 */ if (!expand_isNull_262) { | |
/* 1290 */ expand_isNull_261 = false; // resultCode could change nullability. | |
/* 1291 */ | |
/* 1292 */ expand_value_261 = expand_value_262 - 0L; | |
/* 1293 */ | |
/* 1294 */ } | |
/* 1295 */ boolean expand_isNull_260 = expand_isNull_261; | |
/* 1296 */ double expand_value_260 = -1.0; | |
/* 1297 */ if (!expand_isNull_261) { | |
/* 1298 */ expand_value_260 = (double) expand_value_261; | |
/* 1299 */ } | |
/* 1300 */ if (expand_isNull_260) { | |
/* 1301 */ expand_isNull_259 = true; | |
/* 1302 */ } else { | |
/* 1303 */ expand_value_259 = (double)(expand_value_260 / 3000000.0D); | |
/* 1304 */ } | |
/* 1305 */ } | |
/* 1306 */ boolean expand_isNull_258 = expand_isNull_259; | |
/* 1307 */ long expand_value_258 = -1L; | |
/* 1308 */ | |
/* 1309 */ if (!expand_isNull_259) { | |
/* 1310 */ expand_value_258 = (long)(java.lang.Math.ceil(expand_value_259)); | |
/* 1311 */ } | |
/* 1312 */ boolean expand_isNull_257 = expand_isNull_258; | |
/* 1313 */ double expand_value_257 = -1.0; | |
/* 1314 */ if (!expand_isNull_258) { | |
/* 1315 */ expand_value_257 = (double) expand_value_258; | |
/* 1316 */ } | |
/* 1317 */ if (!expand_isNull_257) { | |
/* 1318 */ boolean expand_isNull_267 = false; | |
/* 1319 */ double expand_value_267 = -1.0; | |
/* 1320 */ if (false || 3000000.0D == 0) { | |
/* 1321 */ expand_isNull_267 = true; | |
/* 1322 */ } else { | |
/* 1323 */ boolean expand_isNull_269 = true; | |
/* 1324 */ long expand_value_269 = -1L; | |
/* 1325 */ boolean expand_isNull_271 = localtablescan_isNull_0; | |
/* 1326 */ long expand_value_271 = -1L; | |
/* 1327 */ if (!localtablescan_isNull_0) { | |
/* 1328 */ scala.Option<Long> expand_longOpt_21 = | |
/* 1329 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[22] /* zoneId */)); | |
/* 1330 */ if (expand_longOpt_21.isDefined()) { | |
/* 1331 */ expand_value_271 = ((Long) expand_longOpt_21.get()).longValue(); | |
/* 1332 */ } else { | |
/* 1333 */ expand_isNull_271 = true; | |
/* 1334 */ } | |
/* 1335 */ } | |
/* 1336 */ boolean expand_isNull_270 = expand_isNull_271; | |
/* 1337 */ long expand_value_270 = expand_value_271; | |
/* 1338 */ if (!expand_isNull_270) { | |
/* 1339 */ expand_isNull_269 = false; // resultCode could change nullability. | |
/* 1340 */ | |
/* 1341 */ expand_value_269 = expand_value_270 - 0L; | |
/* 1342 */ | |
/* 1343 */ } | |
/* 1344 */ boolean expand_isNull_268 = expand_isNull_269; | |
/* 1345 */ double expand_value_268 = -1.0; | |
/* 1346 */ if (!expand_isNull_269) { | |
/* 1347 */ expand_value_268 = (double) expand_value_269; | |
/* 1348 */ } | |
/* 1349 */ if (expand_isNull_268) { | |
/* 1350 */ expand_isNull_267 = true; | |
/* 1351 */ } else { | |
/* 1352 */ expand_value_267 = (double)(expand_value_268 / 3000000.0D); | |
/* 1353 */ } | |
/* 1354 */ } | |
/* 1355 */ if (!expand_isNull_267) { | |
/* 1356 */ expand_isNull_256 = false; // resultCode could change nullability. | |
/* 1357 */ expand_value_256 = ((java.lang.Double.isNaN(expand_value_257) && java.lang.Double.isNaN(expand_value_267)) || expand_value_257 == expand_value_267); | |
/* 1358 */ | |
/* 1359 */ } | |
/* 1360 */ | |
/* 1361 */ } | |
/* 1362 */ boolean expand_isNull_255 = false; | |
/* 1363 */ long expand_value_255 = -1L; | |
/* 1364 */ if (!expand_isNull_256 && expand_value_256) { | |
/* 1365 */ boolean expand_isNull_275 = true; | |
/* 1366 */ long expand_value_275 = -1L; | |
/* 1367 */ boolean expand_isNull_277 = false; | |
/* 1368 */ double expand_value_277 = -1.0; | |
/* 1369 */ if (false || 3000000.0D == 0) { | |
/* 1370 */ expand_isNull_277 = true; | |
/* 1371 */ } else { | |
/* 1372 */ boolean expand_isNull_279 = true; | |
/* 1373 */ long expand_value_279 = -1L; | |
/* 1374 */ boolean expand_isNull_281 = localtablescan_isNull_0; | |
/* 1375 */ long expand_value_281 = -1L; | |
/* 1376 */ if (!localtablescan_isNull_0) { | |
/* 1377 */ scala.Option<Long> expand_longOpt_22 = | |
/* 1378 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[23] /* zoneId */)); | |
/* 1379 */ if (expand_longOpt_22.isDefined()) { | |
/* 1380 */ expand_value_281 = ((Long) expand_longOpt_22.get()).longValue(); | |
/* 1381 */ } else { | |
/* 1382 */ expand_isNull_281 = true; | |
/* 1383 */ } | |
/* 1384 */ } | |
/* 1385 */ boolean expand_isNull_280 = expand_isNull_281; | |
/* 1386 */ long expand_value_280 = expand_value_281; | |
/* 1387 */ if (!expand_isNull_280) { | |
/* 1388 */ expand_isNull_279 = false; // resultCode could change nullability. | |
/* 1389 */ | |
/* 1390 */ expand_value_279 = expand_value_280 - 0L; | |
/* 1391 */ | |
/* 1392 */ } | |
/* 1393 */ boolean expand_isNull_278 = expand_isNull_279; | |
/* 1394 */ double expand_value_278 = -1.0; | |
/* 1395 */ if (!expand_isNull_279) { | |
/* 1396 */ expand_value_278 = (double) expand_value_279; | |
/* 1397 */ } | |
/* 1398 */ if (expand_isNull_278) { | |
/* 1399 */ expand_isNull_277 = true; | |
/* 1400 */ } else { | |
/* 1401 */ expand_value_277 = (double)(expand_value_278 / 3000000.0D); | |
/* 1402 */ } | |
/* 1403 */ } | |
/* 1404 */ boolean expand_isNull_276 = expand_isNull_277; | |
/* 1405 */ long expand_value_276 = -1L; | |
/* 1406 */ | |
/* 1407 */ if (!expand_isNull_277) { | |
/* 1408 */ expand_value_276 = (long)(java.lang.Math.ceil(expand_value_277)); | |
/* 1409 */ } | |
/* 1410 */ if (!expand_isNull_276) { | |
/* 1411 */ expand_isNull_275 = false; // resultCode could change nullability. | |
/* 1412 */ | |
/* 1413 */ expand_value_275 = expand_value_276 + 1L; | |
/* 1414 */ | |
/* 1415 */ } | |
/* 1416 */ expand_isNull_255 = expand_isNull_275; | |
/* 1417 */ expand_value_255 = expand_value_275; | |
/* 1418 */ } else { | |
/* 1419 */ boolean expand_isNull_287 = false; | |
/* 1420 */ double expand_value_287 = -1.0; | |
/* 1421 */ if (false || 3000000.0D == 0) { | |
/* 1422 */ expand_isNull_287 = true; | |
/* 1423 */ } else { | |
/* 1424 */ boolean expand_isNull_289 = true; | |
/* 1425 */ long expand_value_289 = -1L; | |
/* 1426 */ boolean expand_isNull_291 = localtablescan_isNull_0; | |
/* 1427 */ long expand_value_291 = -1L; | |
/* 1428 */ if (!localtablescan_isNull_0) { | |
/* 1429 */ scala.Option<Long> expand_longOpt_23 = | |
/* 1430 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[24] /* zoneId */)); | |
/* 1431 */ if (expand_longOpt_23.isDefined()) { | |
/* 1432 */ expand_value_291 = ((Long) expand_longOpt_23.get()).longValue(); | |
/* 1433 */ } else { | |
/* 1434 */ expand_isNull_291 = true; | |
/* 1435 */ } | |
/* 1436 */ } | |
/* 1437 */ boolean expand_isNull_290 = expand_isNull_291; | |
/* 1438 */ long expand_value_290 = expand_value_291; | |
/* 1439 */ if (!expand_isNull_290) { | |
/* 1440 */ expand_isNull_289 = false; // resultCode could change nullability. | |
/* 1441 */ | |
/* 1442 */ expand_value_289 = expand_value_290 - 0L; | |
/* 1443 */ | |
/* 1444 */ } | |
/* 1445 */ boolean expand_isNull_288 = expand_isNull_289; | |
/* 1446 */ double expand_value_288 = -1.0; | |
/* 1447 */ if (!expand_isNull_289) { | |
/* 1448 */ expand_value_288 = (double) expand_value_289; | |
/* 1449 */ } | |
/* 1450 */ if (expand_isNull_288) { | |
/* 1451 */ expand_isNull_287 = true; | |
/* 1452 */ } else { | |
/* 1453 */ expand_value_287 = (double)(expand_value_288 / 3000000.0D); | |
/* 1454 */ } | |
/* 1455 */ } | |
/* 1456 */ boolean expand_isNull_286 = expand_isNull_287; | |
/* 1457 */ long expand_value_286 = -1L; | |
/* 1458 */ | |
/* 1459 */ if (!expand_isNull_287) { | |
/* 1460 */ expand_value_286 = (long)(java.lang.Math.ceil(expand_value_287)); | |
/* 1461 */ } | |
/* 1462 */ expand_isNull_255 = expand_isNull_286; | |
/* 1463 */ expand_value_255 = expand_value_286; | |
/* 1464 */ } | |
/* 1465 */ if (!expand_isNull_255) { | |
/* 1466 */ expand_isNull_254 = false; // resultCode could change nullability. | |
/* 1467 */ | |
/* 1468 */ expand_value_254 = expand_value_255 + 2L; | |
/* 1469 */ | |
/* 1470 */ } | |
/* 1471 */ if (!expand_isNull_254) { | |
/* 1472 */ expand_isNull_253 = false; // resultCode could change nullability. | |
/* 1473 */ | |
/* 1474 */ expand_value_253 = expand_value_254 - 4L; | |
/* 1475 */ | |
/* 1476 */ } | |
/* 1477 */ if (!expand_isNull_253) { | |
/* 1478 */ expand_isNull_252 = false; // resultCode could change nullability. | |
/* 1479 */ | |
/* 1480 */ expand_value_252 = expand_value_253 * 3000000L; | |
/* 1481 */ | |
/* 1482 */ } | |
/* 1483 */ if (!expand_isNull_252) { | |
/* 1484 */ expand_isNull_251 = false; // resultCode could change nullability. | |
/* 1485 */ | |
/* 1486 */ expand_value_251 = expand_value_252 + 10000000L; | |
/* 1487 */ | |
/* 1488 */ } | |
/* 1489 */ boolean expand_isNull_250 = expand_isNull_251; | |
/* 1490 */ long expand_value_250 = expand_value_251; | |
/* 1491 */ if (expand_isNull_250) { | |
/* 1492 */ expand_values_2[1] = null; | |
/* 1493 */ } else { | |
/* 1494 */ expand_values_2[1] = expand_value_250; | |
/* 1495 */ } | |
/* 1496 */ | |
/* 1497 */ final InternalRow expand_value_200 = new org.apache.spark.sql.catalyst.expressions.GenericInternalRow(expand_values_2); | |
/* 1498 */ expand_values_2 = null; | |
/* 1499 */ expand_resultIsNull_0 = false; | |
/* 1500 */ expand_mutableStateArray_0[0] = expand_value_200; | |
/* 1501 */ | |
/* 1502 */ break; | |
/* 1503 */ | |
/* 1504 */ case 3: | |
/* 1505 */ | |
/* 1506 */ Object[] expand_values_3 = new Object[2]; | |
/* 1507 */ | |
/* 1508 */ boolean expand_isNull_301 = true; | |
/* 1509 */ long expand_value_301 = -1L; | |
/* 1510 */ boolean expand_isNull_302 = true; | |
/* 1511 */ long expand_value_302 = -1L; | |
/* 1512 */ boolean expand_isNull_303 = true; | |
/* 1513 */ long expand_value_303 = -1L; | |
/* 1514 */ boolean expand_isNull_304 = true; | |
/* 1515 */ long expand_value_304 = -1L; | |
/* 1516 */ boolean expand_isNull_306 = true; | |
/* 1517 */ boolean expand_value_306 = false; | |
/* 1518 */ boolean expand_isNull_309 = false; | |
/* 1519 */ double expand_value_309 = -1.0; | |
/* 1520 */ if (false || 3000000.0D == 0) { | |
/* 1521 */ expand_isNull_309 = true; | |
/* 1522 */ } else { | |
/* 1523 */ boolean expand_isNull_311 = true; | |
/* 1524 */ long expand_value_311 = -1L; | |
/* 1525 */ boolean expand_isNull_313 = localtablescan_isNull_0; | |
/* 1526 */ long expand_value_313 = -1L; | |
/* 1527 */ if (!localtablescan_isNull_0) { | |
/* 1528 */ scala.Option<Long> expand_longOpt_24 = | |
/* 1529 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[25] /* zoneId */)); | |
/* 1530 */ if (expand_longOpt_24.isDefined()) { | |
/* 1531 */ expand_value_313 = ((Long) expand_longOpt_24.get()).longValue(); | |
/* 1532 */ } else { | |
/* 1533 */ expand_isNull_313 = true; | |
/* 1534 */ } | |
/* 1535 */ } | |
/* 1536 */ boolean expand_isNull_312 = expand_isNull_313; | |
/* 1537 */ long expand_value_312 = expand_value_313; | |
/* 1538 */ if (!expand_isNull_312) { | |
/* 1539 */ expand_isNull_311 = false; // resultCode could change nullability. | |
/* 1540 */ | |
/* 1541 */ expand_value_311 = expand_value_312 - 0L; | |
/* 1542 */ | |
/* 1543 */ } | |
/* 1544 */ boolean expand_isNull_310 = expand_isNull_311; | |
/* 1545 */ double expand_value_310 = -1.0; | |
/* 1546 */ if (!expand_isNull_311) { | |
/* 1547 */ expand_value_310 = (double) expand_value_311; | |
/* 1548 */ } | |
/* 1549 */ if (expand_isNull_310) { | |
/* 1550 */ expand_isNull_309 = true; | |
/* 1551 */ } else { | |
/* 1552 */ expand_value_309 = (double)(expand_value_310 / 3000000.0D); | |
/* 1553 */ } | |
/* 1554 */ } | |
/* 1555 */ boolean expand_isNull_308 = expand_isNull_309; | |
/* 1556 */ long expand_value_308 = -1L; | |
/* 1557 */ | |
/* 1558 */ if (!expand_isNull_309) { | |
/* 1559 */ expand_value_308 = (long)(java.lang.Math.ceil(expand_value_309)); | |
/* 1560 */ } | |
/* 1561 */ boolean expand_isNull_307 = expand_isNull_308; | |
/* 1562 */ double expand_value_307 = -1.0; | |
/* 1563 */ if (!expand_isNull_308) { | |
/* 1564 */ expand_value_307 = (double) expand_value_308; | |
/* 1565 */ } | |
/* 1566 */ if (!expand_isNull_307) { | |
/* 1567 */ boolean expand_isNull_317 = false; | |
/* 1568 */ double expand_value_317 = -1.0; | |
/* 1569 */ if (false || 3000000.0D == 0) { | |
/* 1570 */ expand_isNull_317 = true; | |
/* 1571 */ } else { | |
/* 1572 */ boolean expand_isNull_319 = true; | |
/* 1573 */ long expand_value_319 = -1L; | |
/* 1574 */ boolean expand_isNull_321 = localtablescan_isNull_0; | |
/* 1575 */ long expand_value_321 = -1L; | |
/* 1576 */ if (!localtablescan_isNull_0) { | |
/* 1577 */ scala.Option<Long> expand_longOpt_25 = | |
/* 1578 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[26] /* zoneId */)); | |
/* 1579 */ if (expand_longOpt_25.isDefined()) { | |
/* 1580 */ expand_value_321 = ((Long) expand_longOpt_25.get()).longValue(); | |
/* 1581 */ } else { | |
/* 1582 */ expand_isNull_321 = true; | |
/* 1583 */ } | |
/* 1584 */ } | |
/* 1585 */ boolean expand_isNull_320 = expand_isNull_321; | |
/* 1586 */ long expand_value_320 = expand_value_321; | |
/* 1587 */ if (!expand_isNull_320) { | |
/* 1588 */ expand_isNull_319 = false; // resultCode could change nullability. | |
/* 1589 */ | |
/* 1590 */ expand_value_319 = expand_value_320 - 0L; | |
/* 1591 */ | |
/* 1592 */ } | |
/* 1593 */ boolean expand_isNull_318 = expand_isNull_319; | |
/* 1594 */ double expand_value_318 = -1.0; | |
/* 1595 */ if (!expand_isNull_319) { | |
/* 1596 */ expand_value_318 = (double) expand_value_319; | |
/* 1597 */ } | |
/* 1598 */ if (expand_isNull_318) { | |
/* 1599 */ expand_isNull_317 = true; | |
/* 1600 */ } else { | |
/* 1601 */ expand_value_317 = (double)(expand_value_318 / 3000000.0D); | |
/* 1602 */ } | |
/* 1603 */ } | |
/* 1604 */ if (!expand_isNull_317) { | |
/* 1605 */ expand_isNull_306 = false; // resultCode could change nullability. | |
/* 1606 */ expand_value_306 = ((java.lang.Double.isNaN(expand_value_307) && java.lang.Double.isNaN(expand_value_317)) || expand_value_307 == expand_value_317); | |
/* 1607 */ | |
/* 1608 */ } | |
/* 1609 */ | |
/* 1610 */ } | |
/* 1611 */ boolean expand_isNull_305 = false; | |
/* 1612 */ long expand_value_305 = -1L; | |
/* 1613 */ if (!expand_isNull_306 && expand_value_306) { | |
/* 1614 */ boolean expand_isNull_325 = true; | |
/* 1615 */ long expand_value_325 = -1L; | |
/* 1616 */ boolean expand_isNull_327 = false; | |
/* 1617 */ double expand_value_327 = -1.0; | |
/* 1618 */ if (false || 3000000.0D == 0) { | |
/* 1619 */ expand_isNull_327 = true; | |
/* 1620 */ } else { | |
/* 1621 */ boolean expand_isNull_329 = true; | |
/* 1622 */ long expand_value_329 = -1L; | |
/* 1623 */ boolean expand_isNull_331 = localtablescan_isNull_0; | |
/* 1624 */ long expand_value_331 = -1L; | |
/* 1625 */ if (!localtablescan_isNull_0) { | |
/* 1626 */ scala.Option<Long> expand_longOpt_26 = | |
/* 1627 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[27] /* zoneId */)); | |
/* 1628 */ if (expand_longOpt_26.isDefined()) { | |
/* 1629 */ expand_value_331 = ((Long) expand_longOpt_26.get()).longValue(); | |
/* 1630 */ } else { | |
/* 1631 */ expand_isNull_331 = true; | |
/* 1632 */ } | |
/* 1633 */ } | |
/* 1634 */ boolean expand_isNull_330 = expand_isNull_331; | |
/* 1635 */ long expand_value_330 = expand_value_331; | |
/* 1636 */ if (!expand_isNull_330) { | |
/* 1637 */ expand_isNull_329 = false; // resultCode could change nullability. | |
/* 1638 */ | |
/* 1639 */ expand_value_329 = expand_value_330 - 0L; | |
/* 1640 */ | |
/* 1641 */ } | |
/* 1642 */ boolean expand_isNull_328 = expand_isNull_329; | |
/* 1643 */ double expand_value_328 = -1.0; | |
/* 1644 */ if (!expand_isNull_329) { | |
/* 1645 */ expand_value_328 = (double) expand_value_329; | |
/* 1646 */ } | |
/* 1647 */ if (expand_isNull_328) { | |
/* 1648 */ expand_isNull_327 = true; | |
/* 1649 */ } else { | |
/* 1650 */ expand_value_327 = (double)(expand_value_328 / 3000000.0D); | |
/* 1651 */ } | |
/* 1652 */ } | |
/* 1653 */ boolean expand_isNull_326 = expand_isNull_327; | |
/* 1654 */ long expand_value_326 = -1L; | |
/* 1655 */ | |
/* 1656 */ if (!expand_isNull_327) { | |
/* 1657 */ expand_value_326 = (long)(java.lang.Math.ceil(expand_value_327)); | |
/* 1658 */ } | |
/* 1659 */ if (!expand_isNull_326) { | |
/* 1660 */ expand_isNull_325 = false; // resultCode could change nullability. | |
/* 1661 */ | |
/* 1662 */ expand_value_325 = expand_value_326 + 1L; | |
/* 1663 */ | |
/* 1664 */ } | |
/* 1665 */ expand_isNull_305 = expand_isNull_325; | |
/* 1666 */ expand_value_305 = expand_value_325; | |
/* 1667 */ } else { | |
/* 1668 */ boolean expand_isNull_337 = false; | |
/* 1669 */ double expand_value_337 = -1.0; | |
/* 1670 */ if (false || 3000000.0D == 0) { | |
/* 1671 */ expand_isNull_337 = true; | |
/* 1672 */ } else { | |
/* 1673 */ boolean expand_isNull_339 = true; | |
/* 1674 */ long expand_value_339 = -1L; | |
/* 1675 */ boolean expand_isNull_341 = localtablescan_isNull_0; | |
/* 1676 */ long expand_value_341 = -1L; | |
/* 1677 */ if (!localtablescan_isNull_0) { | |
/* 1678 */ scala.Option<Long> expand_longOpt_27 = | |
/* 1679 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[28] /* zoneId */)); | |
/* 1680 */ if (expand_longOpt_27.isDefined()) { | |
/* 1681 */ expand_value_341 = ((Long) expand_longOpt_27.get()).longValue(); | |
/* 1682 */ } else { | |
/* 1683 */ expand_isNull_341 = true; | |
/* 1684 */ } | |
/* 1685 */ } | |
/* 1686 */ boolean expand_isNull_340 = expand_isNull_341; | |
/* 1687 */ long expand_value_340 = expand_value_341; | |
/* 1688 */ if (!expand_isNull_340) { | |
/* 1689 */ expand_isNull_339 = false; // resultCode could change nullability. | |
/* 1690 */ | |
/* 1691 */ expand_value_339 = expand_value_340 - 0L; | |
/* 1692 */ | |
/* 1693 */ } | |
/* 1694 */ boolean expand_isNull_338 = expand_isNull_339; | |
/* 1695 */ double expand_value_338 = -1.0; | |
/* 1696 */ if (!expand_isNull_339) { | |
/* 1697 */ expand_value_338 = (double) expand_value_339; | |
/* 1698 */ } | |
/* 1699 */ if (expand_isNull_338) { | |
/* 1700 */ expand_isNull_337 = true; | |
/* 1701 */ } else { | |
/* 1702 */ expand_value_337 = (double)(expand_value_338 / 3000000.0D); | |
/* 1703 */ } | |
/* 1704 */ } | |
/* 1705 */ boolean expand_isNull_336 = expand_isNull_337; | |
/* 1706 */ long expand_value_336 = -1L; | |
/* 1707 */ | |
/* 1708 */ if (!expand_isNull_337) { | |
/* 1709 */ expand_value_336 = (long)(java.lang.Math.ceil(expand_value_337)); | |
/* 1710 */ } | |
/* 1711 */ expand_isNull_305 = expand_isNull_336; | |
/* 1712 */ expand_value_305 = expand_value_336; | |
/* 1713 */ } | |
/* 1714 */ if (!expand_isNull_305) { | |
/* 1715 */ expand_isNull_304 = false; // resultCode could change nullability. | |
/* 1716 */ | |
/* 1717 */ expand_value_304 = expand_value_305 + 3L; | |
/* 1718 */ | |
/* 1719 */ } | |
/* 1720 */ if (!expand_isNull_304) { | |
/* 1721 */ expand_isNull_303 = false; // resultCode could change nullability. | |
/* 1722 */ | |
/* 1723 */ expand_value_303 = expand_value_304 - 4L; | |
/* 1724 */ | |
/* 1725 */ } | |
/* 1726 */ if (!expand_isNull_303) { | |
/* 1727 */ expand_isNull_302 = false; // resultCode could change nullability. | |
/* 1728 */ | |
/* 1729 */ expand_value_302 = expand_value_303 * 3000000L; | |
/* 1730 */ | |
/* 1731 */ } | |
/* 1732 */ if (!expand_isNull_302) { | |
/* 1733 */ expand_isNull_301 = false; // resultCode could change nullability. | |
/* 1734 */ | |
/* 1735 */ expand_value_301 = expand_value_302 + 0L; | |
/* 1736 */ | |
/* 1737 */ } | |
/* 1738 */ boolean expand_isNull_300 = expand_isNull_301; | |
/* 1739 */ long expand_value_300 = expand_value_301; | |
/* 1740 */ if (expand_isNull_300) { | |
/* 1741 */ expand_values_3[0] = null; | |
/* 1742 */ } else { | |
/* 1743 */ expand_values_3[0] = expand_value_300; | |
/* 1744 */ } | |
/* 1745 */ | |
/* 1746 */ boolean expand_isNull_350 = true; | |
/* 1747 */ long expand_value_350 = -1L; | |
/* 1748 */ boolean expand_isNull_351 = true; | |
/* 1749 */ long expand_value_351 = -1L; | |
/* 1750 */ boolean expand_isNull_352 = true; | |
/* 1751 */ long expand_value_352 = -1L; | |
/* 1752 */ boolean expand_isNull_353 = true; | |
/* 1753 */ long expand_value_353 = -1L; | |
/* 1754 */ boolean expand_isNull_355 = true; | |
/* 1755 */ boolean expand_value_355 = false; | |
/* 1756 */ boolean expand_isNull_358 = false; | |
/* 1757 */ double expand_value_358 = -1.0; | |
/* 1758 */ if (false || 3000000.0D == 0) { | |
/* 1759 */ expand_isNull_358 = true; | |
/* 1760 */ } else { | |
/* 1761 */ boolean expand_isNull_360 = true; | |
/* 1762 */ long expand_value_360 = -1L; | |
/* 1763 */ boolean expand_isNull_362 = localtablescan_isNull_0; | |
/* 1764 */ long expand_value_362 = -1L; | |
/* 1765 */ if (!localtablescan_isNull_0) { | |
/* 1766 */ scala.Option<Long> expand_longOpt_28 = | |
/* 1767 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[29] /* zoneId */)); | |
/* 1768 */ if (expand_longOpt_28.isDefined()) { | |
/* 1769 */ expand_value_362 = ((Long) expand_longOpt_28.get()).longValue(); | |
/* 1770 */ } else { | |
/* 1771 */ expand_isNull_362 = true; | |
/* 1772 */ } | |
/* 1773 */ } | |
/* 1774 */ boolean expand_isNull_361 = expand_isNull_362; | |
/* 1775 */ long expand_value_361 = expand_value_362; | |
/* 1776 */ if (!expand_isNull_361) { | |
/* 1777 */ expand_isNull_360 = false; // resultCode could change nullability. | |
/* 1778 */ | |
/* 1779 */ expand_value_360 = expand_value_361 - 0L; | |
/* 1780 */ | |
/* 1781 */ } | |
/* 1782 */ boolean expand_isNull_359 = expand_isNull_360; | |
/* 1783 */ double expand_value_359 = -1.0; | |
/* 1784 */ if (!expand_isNull_360) { | |
/* 1785 */ expand_value_359 = (double) expand_value_360; | |
/* 1786 */ } | |
/* 1787 */ if (expand_isNull_359) { | |
/* 1788 */ expand_isNull_358 = true; | |
/* 1789 */ } else { | |
/* 1790 */ expand_value_358 = (double)(expand_value_359 / 3000000.0D); | |
/* 1791 */ } | |
/* 1792 */ } | |
/* 1793 */ boolean expand_isNull_357 = expand_isNull_358; | |
/* 1794 */ long expand_value_357 = -1L; | |
/* 1795 */ | |
/* 1796 */ if (!expand_isNull_358) { | |
/* 1797 */ expand_value_357 = (long)(java.lang.Math.ceil(expand_value_358)); | |
/* 1798 */ } | |
/* 1799 */ boolean expand_isNull_356 = expand_isNull_357; | |
/* 1800 */ double expand_value_356 = -1.0; | |
/* 1801 */ if (!expand_isNull_357) { | |
/* 1802 */ expand_value_356 = (double) expand_value_357; | |
/* 1803 */ } | |
/* 1804 */ if (!expand_isNull_356) { | |
/* 1805 */ boolean expand_isNull_366 = false; | |
/* 1806 */ double expand_value_366 = -1.0; | |
/* 1807 */ if (false || 3000000.0D == 0) { | |
/* 1808 */ expand_isNull_366 = true; | |
/* 1809 */ } else { | |
/* 1810 */ boolean expand_isNull_368 = true; | |
/* 1811 */ long expand_value_368 = -1L; | |
/* 1812 */ boolean expand_isNull_370 = localtablescan_isNull_0; | |
/* 1813 */ long expand_value_370 = -1L; | |
/* 1814 */ if (!localtablescan_isNull_0) { | |
/* 1815 */ scala.Option<Long> expand_longOpt_29 = | |
/* 1816 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[30] /* zoneId */)); | |
/* 1817 */ if (expand_longOpt_29.isDefined()) { | |
/* 1818 */ expand_value_370 = ((Long) expand_longOpt_29.get()).longValue(); | |
/* 1819 */ } else { | |
/* 1820 */ expand_isNull_370 = true; | |
/* 1821 */ } | |
/* 1822 */ } | |
/* 1823 */ boolean expand_isNull_369 = expand_isNull_370; | |
/* 1824 */ long expand_value_369 = expand_value_370; | |
/* 1825 */ if (!expand_isNull_369) { | |
/* 1826 */ expand_isNull_368 = false; // resultCode could change nullability. | |
/* 1827 */ | |
/* 1828 */ expand_value_368 = expand_value_369 - 0L; | |
/* 1829 */ | |
/* 1830 */ } | |
/* 1831 */ boolean expand_isNull_367 = expand_isNull_368; | |
/* 1832 */ double expand_value_367 = -1.0; | |
/* 1833 */ if (!expand_isNull_368) { | |
/* 1834 */ expand_value_367 = (double) expand_value_368; | |
/* 1835 */ } | |
/* 1836 */ if (expand_isNull_367) { | |
/* 1837 */ expand_isNull_366 = true; | |
/* 1838 */ } else { | |
/* 1839 */ expand_value_366 = (double)(expand_value_367 / 3000000.0D); | |
/* 1840 */ } | |
/* 1841 */ } | |
/* 1842 */ if (!expand_isNull_366) { | |
/* 1843 */ expand_isNull_355 = false; // resultCode could change nullability. | |
/* 1844 */ expand_value_355 = ((java.lang.Double.isNaN(expand_value_356) && java.lang.Double.isNaN(expand_value_366)) || expand_value_356 == expand_value_366); | |
/* 1845 */ | |
/* 1846 */ } | |
/* 1847 */ | |
/* 1848 */ } | |
/* 1849 */ boolean expand_isNull_354 = false; | |
/* 1850 */ long expand_value_354 = -1L; | |
/* 1851 */ if (!expand_isNull_355 && expand_value_355) { | |
/* 1852 */ boolean expand_isNull_374 = true; | |
/* 1853 */ long expand_value_374 = -1L; | |
/* 1854 */ boolean expand_isNull_376 = false; | |
/* 1855 */ double expand_value_376 = -1.0; | |
/* 1856 */ if (false || 3000000.0D == 0) { | |
/* 1857 */ expand_isNull_376 = true; | |
/* 1858 */ } else { | |
/* 1859 */ boolean expand_isNull_378 = true; | |
/* 1860 */ long expand_value_378 = -1L; | |
/* 1861 */ boolean expand_isNull_380 = localtablescan_isNull_0; | |
/* 1862 */ long expand_value_380 = -1L; | |
/* 1863 */ if (!localtablescan_isNull_0) { | |
/* 1864 */ scala.Option<Long> expand_longOpt_30 = | |
/* 1865 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[31] /* zoneId */)); | |
/* 1866 */ if (expand_longOpt_30.isDefined()) { | |
/* 1867 */ expand_value_380 = ((Long) expand_longOpt_30.get()).longValue(); | |
/* 1868 */ } else { | |
/* 1869 */ expand_isNull_380 = true; | |
/* 1870 */ } | |
/* 1871 */ } | |
/* 1872 */ boolean expand_isNull_379 = expand_isNull_380; | |
/* 1873 */ long expand_value_379 = expand_value_380; | |
/* 1874 */ if (!expand_isNull_379) { | |
/* 1875 */ expand_isNull_378 = false; // resultCode could change nullability. | |
/* 1876 */ | |
/* 1877 */ expand_value_378 = expand_value_379 - 0L; | |
/* 1878 */ | |
/* 1879 */ } | |
/* 1880 */ boolean expand_isNull_377 = expand_isNull_378; | |
/* 1881 */ double expand_value_377 = -1.0; | |
/* 1882 */ if (!expand_isNull_378) { | |
/* 1883 */ expand_value_377 = (double) expand_value_378; | |
/* 1884 */ } | |
/* 1885 */ if (expand_isNull_377) { | |
/* 1886 */ expand_isNull_376 = true; | |
/* 1887 */ } else { | |
/* 1888 */ expand_value_376 = (double)(expand_value_377 / 3000000.0D); | |
/* 1889 */ } | |
/* 1890 */ } | |
/* 1891 */ boolean expand_isNull_375 = expand_isNull_376; | |
/* 1892 */ long expand_value_375 = -1L; | |
/* 1893 */ | |
/* 1894 */ if (!expand_isNull_376) { | |
/* 1895 */ expand_value_375 = (long)(java.lang.Math.ceil(expand_value_376)); | |
/* 1896 */ } | |
/* 1897 */ if (!expand_isNull_375) { | |
/* 1898 */ expand_isNull_374 = false; // resultCode could change nullability. | |
/* 1899 */ | |
/* 1900 */ expand_value_374 = expand_value_375 + 1L; | |
/* 1901 */ | |
/* 1902 */ } | |
/* 1903 */ expand_isNull_354 = expand_isNull_374; | |
/* 1904 */ expand_value_354 = expand_value_374; | |
/* 1905 */ } else { | |
/* 1906 */ boolean expand_isNull_386 = false; | |
/* 1907 */ double expand_value_386 = -1.0; | |
/* 1908 */ if (false || 3000000.0D == 0) { | |
/* 1909 */ expand_isNull_386 = true; | |
/* 1910 */ } else { | |
/* 1911 */ boolean expand_isNull_388 = true; | |
/* 1912 */ long expand_value_388 = -1L; | |
/* 1913 */ boolean expand_isNull_390 = localtablescan_isNull_0; | |
/* 1914 */ long expand_value_390 = -1L; | |
/* 1915 */ if (!localtablescan_isNull_0) { | |
/* 1916 */ scala.Option<Long> expand_longOpt_31 = | |
/* 1917 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[32] /* zoneId */)); | |
/* 1918 */ if (expand_longOpt_31.isDefined()) { | |
/* 1919 */ expand_value_390 = ((Long) expand_longOpt_31.get()).longValue(); | |
/* 1920 */ } else { | |
/* 1921 */ expand_isNull_390 = true; | |
/* 1922 */ } | |
/* 1923 */ } | |
/* 1924 */ boolean expand_isNull_389 = expand_isNull_390; | |
/* 1925 */ long expand_value_389 = expand_value_390; | |
/* 1926 */ if (!expand_isNull_389) { | |
/* 1927 */ expand_isNull_388 = false; // resultCode could change nullability. | |
/* 1928 */ | |
/* 1929 */ expand_value_388 = expand_value_389 - 0L; | |
/* 1930 */ | |
/* 1931 */ } | |
/* 1932 */ boolean expand_isNull_387 = expand_isNull_388; | |
/* 1933 */ double expand_value_387 = -1.0; | |
/* 1934 */ if (!expand_isNull_388) { | |
/* 1935 */ expand_value_387 = (double) expand_value_388; | |
/* 1936 */ } | |
/* 1937 */ if (expand_isNull_387) { | |
/* 1938 */ expand_isNull_386 = true; | |
/* 1939 */ } else { | |
/* 1940 */ expand_value_386 = (double)(expand_value_387 / 3000000.0D); | |
/* 1941 */ } | |
/* 1942 */ } | |
/* 1943 */ boolean expand_isNull_385 = expand_isNull_386; | |
/* 1944 */ long expand_value_385 = -1L; | |
/* 1945 */ | |
/* 1946 */ if (!expand_isNull_386) { | |
/* 1947 */ expand_value_385 = (long)(java.lang.Math.ceil(expand_value_386)); | |
/* 1948 */ } | |
/* 1949 */ expand_isNull_354 = expand_isNull_385; | |
/* 1950 */ expand_value_354 = expand_value_385; | |
/* 1951 */ } | |
/* 1952 */ if (!expand_isNull_354) { | |
/* 1953 */ expand_isNull_353 = false; // resultCode could change nullability. | |
/* 1954 */ | |
/* 1955 */ expand_value_353 = expand_value_354 + 3L; | |
/* 1956 */ | |
/* 1957 */ } | |
/* 1958 */ if (!expand_isNull_353) { | |
/* 1959 */ expand_isNull_352 = false; // resultCode could change nullability. | |
/* 1960 */ | |
/* 1961 */ expand_value_352 = expand_value_353 - 4L; | |
/* 1962 */ | |
/* 1963 */ } | |
/* 1964 */ if (!expand_isNull_352) { | |
/* 1965 */ expand_isNull_351 = false; // resultCode could change nullability. | |
/* 1966 */ | |
/* 1967 */ expand_value_351 = expand_value_352 * 3000000L; | |
/* 1968 */ | |
/* 1969 */ } | |
/* 1970 */ if (!expand_isNull_351) { | |
/* 1971 */ expand_isNull_350 = false; // resultCode could change nullability. | |
/* 1972 */ | |
/* 1973 */ expand_value_350 = expand_value_351 + 10000000L; | |
/* 1974 */ | |
/* 1975 */ } | |
/* 1976 */ boolean expand_isNull_349 = expand_isNull_350; | |
/* 1977 */ long expand_value_349 = expand_value_350; | |
/* 1978 */ if (expand_isNull_349) { | |
/* 1979 */ expand_values_3[1] = null; | |
/* 1980 */ } else { | |
/* 1981 */ expand_values_3[1] = expand_value_349; | |
/* 1982 */ } | |
/* 1983 */ | |
/* 1984 */ final InternalRow expand_value_299 = new org.apache.spark.sql.catalyst.expressions.GenericInternalRow(expand_values_3); | |
/* 1985 */ expand_values_3 = null; | |
/* 1986 */ expand_resultIsNull_0 = false; | |
/* 1987 */ expand_mutableStateArray_0[0] = expand_value_299; | |
/* 1988 */ | |
/* 1989 */ break; | |
/* 1990 */ } | |
/* 1991 */ ((org.apache.spark.sql.execution.metric.SQLMetric) references[33] /* numOutputRows */).add(1); | |
/* 1992 */ | |
/* 1993 */ do { | |
/* 1994 */ boolean filter_value_2 = !expand_resultIsNull_0; | |
/* 1995 */ if (!filter_value_2) continue; | |
/* 1996 */ | |
/* 1997 */ boolean filter_isNull_2 = true; | |
/* 1998 */ boolean filter_value_3 = false; | |
/* 1999 */ boolean filter_isNull_3 = localtablescan_isNull_0; | |
/* 2000 */ long filter_value_4 = -1L; | |
/* 2001 */ if (!localtablescan_isNull_0) { | |
/* 2002 */ scala.Option<Long> filter_longOpt_0 = | |
/* 2003 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[35] /* zoneId */)); | |
/* 2004 */ if (filter_longOpt_0.isDefined()) { | |
/* 2005 */ filter_value_4 = ((Long) filter_longOpt_0.get()).longValue(); | |
/* 2006 */ } else { | |
/* 2007 */ filter_isNull_3 = true; | |
/* 2008 */ } | |
/* 2009 */ } | |
/* 2010 */ if (!filter_isNull_3) { | |
/* 2011 */ boolean filter_isNull_5 = expand_resultIsNull_0; | |
/* 2012 */ long filter_value_6 = -1L; | |
/* 2013 */ | |
/* 2014 */ if (expand_mutableStateArray_0[0].isNullAt(0)) { | |
/* 2015 */ filter_isNull_5 = true; | |
/* 2016 */ } else { | |
/* 2017 */ filter_value_6 = expand_mutableStateArray_0[0].getLong(0); | |
/* 2018 */ } | |
/* 2019 */ if (!filter_isNull_5) { | |
/* 2020 */ filter_isNull_2 = false; // resultCode could change nullability. | |
/* 2021 */ filter_value_3 = filter_value_4 >= filter_value_6; | |
/* 2022 */ | |
/* 2023 */ } | |
/* 2024 */ | |
/* 2025 */ } | |
/* 2026 */ if (filter_isNull_2 || !filter_value_3) continue; | |
/* 2027 */ boolean filter_value_10 = !expand_resultIsNull_0; | |
/* 2028 */ if (!filter_value_10) continue; | |
/* 2029 */ | |
/* 2030 */ boolean filter_isNull_9 = true; | |
/* 2031 */ boolean filter_value_11 = false; | |
/* 2032 */ boolean filter_isNull_10 = localtablescan_isNull_0; | |
/* 2033 */ long filter_value_12 = -1L; | |
/* 2034 */ if (!localtablescan_isNull_0) { | |
/* 2035 */ scala.Option<Long> filter_longOpt_1 = | |
/* 2036 */ org.apache.spark.sql.catalyst.util.DateTimeUtils.stringToTimestamp(localtablescan_value_0, ((java.time.ZoneId) references[36] /* zoneId */)); | |
/* 2037 */ if (filter_longOpt_1.isDefined()) { | |
/* 2038 */ filter_value_12 = ((Long) filter_longOpt_1.get()).longValue(); | |
/* 2039 */ } else { | |
/* 2040 */ filter_isNull_10 = true; | |
/* 2041 */ } | |
/* 2042 */ } | |
/* 2043 */ if (!filter_isNull_10) { | |
/* 2044 */ boolean filter_isNull_12 = expand_resultIsNull_0; | |
/* 2045 */ long filter_value_14 = -1L; | |
/* 2046 */ | |
/* 2047 */ if (expand_mutableStateArray_0[0].isNullAt(1)) { | |
/* 2048 */ filter_isNull_12 = true; | |
/* 2049 */ } else { | |
/* 2050 */ filter_value_14 = expand_mutableStateArray_0[0].getLong(1); | |
/* 2051 */ } | |
/* 2052 */ if (!filter_isNull_12) { | |
/* 2053 */ filter_isNull_9 = false; // resultCode could change nullability. | |
/* 2054 */ filter_value_11 = filter_value_12 < filter_value_14; | |
/* 2055 */ | |
/* 2056 */ } | |
/* 2057 */ | |
/* 2058 */ } | |
/* 2059 */ if (filter_isNull_9 || !filter_value_11) continue; | |
/* 2060 */ | |
/* 2061 */ ((org.apache.spark.sql.execution.metric.SQLMetric) references[34] /* numOutputRows */).add(1); | |
/* 2062 */ | |
/* 2063 */ // common sub-expressions | |
/* 2064 */ | |
/* 2065 */ boolean project_isNull_0 = false; | |
/* 2066 */ long project_value_0 = -1L; | |
/* 2067 */ | |
/* 2068 */ if (expand_mutableStateArray_0[0].isNullAt(0)) { | |
/* 2069 */ project_isNull_0 = true; | |
/* 2070 */ } else { | |
/* 2071 */ project_value_0 = expand_mutableStateArray_0[0].getLong(0); | |
/* 2072 */ } | |
/* 2073 */ expand_mutableStateArray_1[4].reset(); | |
/* 2074 */ | |
/* 2075 */ expand_mutableStateArray_1[4].zeroOutNullBytes(); | |
/* 2076 */ | |
/* 2077 */ if (project_isNull_0) { | |
/* 2078 */ expand_mutableStateArray_1[4].setNullAt(0); | |
/* 2079 */ } else { | |
/* 2080 */ expand_mutableStateArray_1[4].write(0, project_value_0); | |
/* 2081 */ } | |
/* 2082 */ | |
/* 2083 */ expand_mutableStateArray_1[4].write(1, localtablescan_value_1); | |
/* 2084 */ append((expand_mutableStateArray_1[4].getRow()).copy()); | |
/* 2085 */ | |
/* 2086 */ } while(false); | |
/* 2087 */ | |
/* 2088 */ } | |
/* 2089 */ if (shouldStop()) return; | |
/* 2090 */ } | |
/* 2091 */ } | |
/* 2092 */ | |
/* 2093 */ } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment