A checkpoint message is sent by the client's subprocess to indicate to the kcl processor that it should attempt to checkpoint.
An initialize message is sent to the client's subprocess to indicate that it should perform its initialization steps.
Class for encoding Record objects to json.
Abstract class for all messages that are sent to the client's process.
A message to indicate to the client's process that it should process a list of records.
A message to indicate to the client's process that it should shutdown and then terminate.
A message to indicate to the client's process that shutdown is requested.
A message sent by the client's process to indicate to the record processor that it completed a particular action.
Copyright © 2019. All rights reserved.