in ClientLibrary/ClientLibrary.cs [198:203]
public DefaultProcessRecordsInput(ProcessRecordsAction processRecordsAction, Checkpointer checkpointer)
{
Records = processRecordsAction.Records;
MillisBehindLatest = processRecordsAction.MillisBehindLatest;
Checkpointer = checkpointer;
}