Smartbi Mining

Completed Queries: 433

Completed Queries (433)

Page:

ID	Description	Submitted	Duration	Job IDs ▴
9	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:03	32 ms
12	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:05	4 ms
17	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	0 ms
20	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	0 ms
36	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:03	4 ms
39	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:04	0 ms
44	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:07	0 ms
47	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:07	0 ms
63	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/14 08:00:03	3 ms
66	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/14 08:00:04	0 ms
71	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/14 08:00:07	0 ms
74	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/14 08:00:07	0 ms
90	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/15 08:00:03	4 ms
93	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/15 08:00:04	0 ms
98	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/15 08:00:07	0 ms
101	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/15 08:00:07	0 ms
117	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/16 08:00:03	3 ms
120	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/16 08:00:04	0 ms
125	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/16 08:00:07	0 ms
128	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/16 08:00:07	0 ms
144	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/17 08:00:02	3 ms
147	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/17 08:00:04	0 ms
152	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/17 08:00:07	0 ms
155	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/17 08:00:07	1 ms
171	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/18 08:00:02	3 ms
174	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/18 08:00:04	0 ms
179	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/18 08:00:07	0 ms
182	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/18 08:00:07	0 ms
198	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/19 08:00:03	3 ms
201	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/19 08:00:04	0 ms
206	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/19 08:00:07	0 ms
209	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/19 08:00:07	0 ms
225	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/20 08:00:02	2 ms
228	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/20 08:00:04	0 ms
233	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/20 08:00:07	0 ms
236	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/20 08:00:07	1 ms
252	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/21 08:00:02	3 ms
255	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/21 08:00:04	0 ms
260	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/21 08:00:07	0 ms
263	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/21 08:00:07	0 ms
279	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/22 08:00:02	3 ms
282	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/22 08:00:04	0 ms
287	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/22 08:00:07	0 ms
290	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/22 08:00:07	0 ms
306	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/23 08:00:02	3 ms
309	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/23 08:00:04	0 ms
314	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/23 08:00:07	0 ms
317	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/23 08:00:07	0 ms
333	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/24 08:00:03	3 ms
336	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/24 08:00:04	0 ms
341	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/24 08:00:07	0 ms
344	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/24 08:00:07	0 ms
360	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/25 08:00:02	3 ms
363	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/25 08:00:04	0 ms
368	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/25 08:00:07	0 ms
371	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/25 08:00:07	0 ms
387	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/26 08:00:03	3 ms
390	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/26 08:00:04	0 ms
395	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/26 08:00:07	0 ms
398	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/26 08:00:07	0 ms
414	collectAsList at DivideNode.java:230 +details collectAsList at DivideNode.java:230 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:230) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/27 08:00:02	2 ms
417	createOrReplaceTempView at Column2RowNode.java:103 +details createOrReplaceTempView at Column2RowNode.java:103 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:103) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/27 08:00:04	0 ms
422	createOrReplaceTempView at DeriveColumnNode.java:81 +details createOrReplaceTempView at DeriveColumnNode.java:81 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/27 08:00:07	0 ms
425	createOrReplaceTempView at ColumnSelectionNode.java:67 +details createOrReplaceTempView at ColumnSelectionNode.java:67 org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.selectColumns(ColumnSelectionNode.java:67) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:44) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/27 08:00:07	0 ms
0	count at SparkSQLExample.java:94 +details count at SparkSQLExample.java:94 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.util.SparkSQLExample.runExample(SparkSQLExample.java:94) smartbix.datamining.engine.agent.spark.DefaultSparkSessionFactory.tryCreate(DefaultSparkSessionFactory.java:180) smartbix.datamining.engine.agent.spark.DefaultSparkSessionFactory.checkOrCreate(DefaultSparkSessionFactory.java:155) smartbix.datamining.engine.experiment.agent.DefaultAgentLauncher.start(DefaultAgentLauncher.java:41) smartbix.datamining.engine.experiment.ExperimentApplication.startEngine(ExperimentApplication.java:236) smartbix.datamining.engine.experiment.ExperimentApplication.main(ExperimentApplication.java:196)	2025/06/11 09:50:40	2 s	[0]
1	parquet at DatasetEvent.java:208 +details parquet at DatasetEvent.java:208 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:874) smartbix.datamining.engine.execute.event.DatasetEvent.serializeFields(DatasetEvent.java:208) smartbix.datamining.engine.util.EventSerializeUtil.serialize(EventSerializeUtil.java:45) smartbix.datamining.engine.agent.execute.flow.DefaultSparkFlowContext.persistNodeExecuteResult(DefaultSparkFlowContext.java:97) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:201) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 01:00:06	4 s	[1]
2	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 01:00:11	0.6 s	[3]
3	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 01:00:11	0.5 s	[4]
4	foreachPartition at SparkFunctionUtil.java:146 +details foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:274) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:226) smartbix.datamining.engine.execute.node.datasource.handler.ClickHouseHandler.executorByTable(ClickHouseHandler.java:122) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.createTable(SmartbiMppOutputNode.java:98) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:69) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 01:00:13	0.6 s	[7]
5	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 01:00:14	0.2 s	[8]
6	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 01:00:14	0.1 s	[9]
7	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:00	1.0 s	[10]
8	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:01	0.9 s	[11]
10	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:88) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:03	0.9 s	[13]
11	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:88) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:04	1.0 s	[14]
13	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:116) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:05	1 s	[15]
14	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:116) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:06	0.9 s	[16]
15	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:08	1 s	[17]
16	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	85 ms	[18]
18	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	90 ms	[19]
19	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	74 ms	[20]
21	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	50 ms	[21]
22	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	63 ms	[22]
23	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.MetadataNode.execute(MetadataNode.java:54) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	53 ms	[23]
24	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.MetadataNode.execute(MetadataNode.java:54) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:09	34 ms	[24]
25	foreachPartition at SparkFunctionUtil.java:146 +details foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.replaceDataToDatabase(JdbcHandler.java:305) smartbix.datamining.engine.execute.node.datasource.handler.MysqlHandler.executor(MysqlHandler.java:48) smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:165) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:10	29 s	[25]
26	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:177) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:39	45 ms	[26]
27	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:177) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/12 08:00:39	31 ms	[27]
28	parquet at DatasetEvent.java:208 +details parquet at DatasetEvent.java:208 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:874) smartbix.datamining.engine.execute.event.DatasetEvent.serializeFields(DatasetEvent.java:208) smartbix.datamining.engine.util.EventSerializeUtil.serialize(EventSerializeUtil.java:45) smartbix.datamining.engine.agent.execute.flow.DefaultSparkFlowContext.persistNodeExecuteResult(DefaultSparkFlowContext.java:97) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:201) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 01:00:03	2 s	[28]
29	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 01:00:06	0.2 s	[30]
30	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 01:00:06	91 ms	[31]
31	foreachPartition at SparkFunctionUtil.java:146 +details foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:274) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:226) smartbix.datamining.engine.execute.node.datasource.handler.ClickHouseHandler.executorByTable(ClickHouseHandler.java:122) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.createTable(SmartbiMppOutputNode.java:98) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:69) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 01:00:07	0.3 s	[34]
32	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 01:00:07	0.1 s	[35]
33	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 01:00:07	0.2 s	[36]
34	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:00	0.9 s	[37]
35	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:01	0.8 s	[38]
37	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:88) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:03	0.9 s	[40]
38	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:88) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:03	0.8 s	[41]
40	count at DatasetOutput.java:65 +details count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:116) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:04	0.9 s	[42]
41	collectAsList at DataStorageUtils.java:104 +details collectAsList at DataStorageUtils.java:104 org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.preprocess.Column2RowNode.execute(Column2RowNode.java:116) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/06/13 08:00:05	0.9 s	[43]

Page:

SQL

Completed Queries (433)