in athena-udfs-textanalytics/src/main/java/com/amazonaws/athena/udf/textanalytics/TextAnalyticsUDFHandler.java [1040:1059]
private List<Object[]> getBatches(String[] input, int multiRowBatchSize)
throws Exception
{
List<Object[]> batches = new ArrayList<Object[]>();
int start = 0;
int c = 0;
for (int i = 0; i < input.length; i++) {
if (c++ >= multiRowBatchSize) {
// add a batch, and reset c
batches.add(new Object[] {Arrays.copyOfRange(input, start, i), "MULTI_ROW_BATCH"});
start = i;
c = 1;
}
}
// last split
if (start < input.length) {
batches.add(new Object[] {Arrays.copyOfRange(input, start, input.length), "MULTI_ROW_BATCH"});
}
return batches;
}