private List convertType()

in java/KinesisDeaggregatorV2/src/main/java/com/amazonaws/kinesis/deagg/RecordDeaggregator.java [81:100]

• 18 lines of code
• 7 McCabe index (conditional complexity)

	private List<KinesisClientRecord> convertType(List<T> inputRecords) throws Exception {
		List<KinesisClientRecord> records = null;

		if (inputRecords.size() > 0 && inputRecords.get(0) instanceof KinesisEventRecord) {
			records = convertToKinesis((List<KinesisEventRecord>) inputRecords);
		} else if (inputRecords.size() > 0 && inputRecords.get(0) instanceof Record) {
			records = new ArrayList<>();
			for (Record rec : (List<Record>) inputRecords) {
				records.add(KinesisClientRecord.fromRecord((Record) rec));
			}
		} else {
			if (inputRecords.size() == 0) {
				return new ArrayList<KinesisClientRecord>();
			} else {
				throw new Exception("Input Types must be Kinesis Event or Model Records");
			}
		}

		return records;
	}