I have a filter.map that triggers 170 tasks. How can i increase it ? Code:
val viEvents = details.filter(_.get(14).asInstanceOf[Long] != NULL_VALUE).map
{ vi => (vi.get(14).asInstanceOf[Long], vi) }
Deepak
I have a filter.map that triggers 170 tasks. How can i increase it ? Code:
val viEvents = details.filter(_.get(14).asInstanceOf[Long] != NULL_VALUE).map
{ vi => (vi.get(14).asInstanceOf[Long], vi) }
Deepak