[streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface