[SPARK-1981] Add AWS Kinesis streaming support

What is the point of this function? Seems like this is only used in unit-tests? In which case shouldnt this be in the test classes only? Either way, if the user is not expected to use this function directly, this is should not be exposed.