digraph G {
0 [id="node0" labelType="html" label="<br><b>DeserializeToObject</b><br><br>" tooltip="DeserializeToObject createexternalrow(invoke(shardId#1100043.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#1100044L)), static_invoke(java.lang.Double.valueOf(qty#1100045)), invoke(demandChannel#1100046.toString()), invoke(demandStream#1100047.toString()), mapobjects(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1), createexternalrow(invoke(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).label.toString()), static_invoke(DateTimeUtils.toJavaTimestamp(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).dateTime)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).value)), StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true)), kpis#1100048, Some(class scala.collection.mutable.ArraySeq)), StructField(shardId,StringType,true), StructField(worklistShardItemId,LongType,true), StructField(qty,DoubleType,true), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpis,ArrayType(StructType(StructField(label,StringType,true),StructField(dateTime,TimestampType,true),StructField(value,DoubleType,true)),false),true)), obj#1100061: org.apache.spark.sql.Row"];
1 [id="node1" labelType="html" label="<br><b>LocalTableScan</b><br><br>" tooltip="LocalTableScan <empty>, [shardId#1100043, worklistShardItemId#1100044L, qty#1100045, demandChannel#1100046, demandStream#1100047, kpis#1100048]"];
1->0;
}
== Physical Plan ==
DeserializeToObject (2)
+- LocalTableScan (1)
(1) LocalTableScan
Output [6]: [shardId#1100043, worklistShardItemId#1100044L, qty#1100045, demandChannel#1100046, demandStream#1100047, kpis#1100048]
Arguments: <empty>, [shardId#1100043, worklistShardItemId#1100044L, qty#1100045, demandChannel#1100046, demandStream#1100047, kpis#1100048]
(2) DeserializeToObject
Input [6]: [shardId#1100043, worklistShardItemId#1100044L, qty#1100045, demandChannel#1100046, demandStream#1100047, kpis#1100048]
Arguments: createexternalrow(invoke(shardId#1100043.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#1100044L)), static_invoke(java.lang.Double.valueOf(qty#1100045)), invoke(demandChannel#1100046.toString()), invoke(demandStream#1100047.toString()), mapobjects(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1), createexternalrow(invoke(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).label.toString()), static_invoke(DateTimeUtils.toJavaTimestamp(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).dateTime)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).value)), StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true)), kpis#1100048, Some(class scala.collection.mutable.ArraySeq)), StructField(shardId,StringType,true), StructField(worklistShardItemId,LongType,true), StructField(qty,DoubleType,true), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpis,ArrayType(StructType(StructField(label,StringType,true),StructField(dateTime,TimestampType,true),StructField(value,DoubleType,true)),false),true)), obj#1100061: org.apache.spark.sql.Row