mixing scala and java sources
XAP Input DStream