ata stored in this
format.
*/
public final class UnsafeRow extends MutableRow implements Externalizable,
KryoSerializable
Xinh
On Sun, Jun 26, 2016 at 1:11 PM, Mich Talebzadeh <mich.talebza...@gmail.com>
wrote:
>
> Hi,
>
> In Spark's Physical Plan what is the explanation for ConvertToUn
Hi,
In Spark's Physical Plan what is the explanation for ConvertToUnsafe?
Example:
scala> sorted.filter($"prod_id" ===13).explain
== Physical Plan ==
Filter (prod_id#10L = 13)
+- Sort [prod_id#10L ASC,cust_id#11L ASC,time_id#12 ASC,channel_id#13L
ASC,promo_id#14L
