support for Kinesis

+KinesisInputDStream
+KinesisWorcCount