in java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/RecordDeaggregator.java [80:96]
private List<Record> convertType(List<T> inputRecords) {
List<Record> 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 = (List<Record>) inputRecords;
} else {
if (inputRecords.size() == 0) {
return new ArrayList<Record>();
} else {
throw new InvalidArgumentException("Input Types must be Kinesis Event or Model Records");
}
}
return records;
}