defapply(flows: Dataset[Row], sPorts: Seq[Int] = Seq(53), ppSec: Int = 10, pktCount: Int = 300): Dataset[Result]
Given a dataset containing outbound SiLK flow records as
input, return a Dataset containing timestamped packets
and flow record counts matching the given packet frequency
and volume.