Skip to content

Instantly share code, notes, and snippets.

@maropu
Last active November 4, 2022 11:15
Show Gist options
  • Save maropu/5f1ef1f4967b887e539a78cdbba98040 to your computer and use it in GitHub Desktop.
Save maropu/5f1ef1f4967b887e539a78cdbba98040 to your computer and use it in GitHub Desktop.
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