add spark streaming code