10.8.4 Processing after tuples have been input

The timestamp adjustment function changes the reference time when the time information set in records in the tuples sent from the input adaptor changes and then inputs to the input stream input-eligible tuples it has placed on hold. Once the tuple input operation from the input adaptor is completed, the timestamp adjustment function's reference time will no longer be subject to change, which means that it will not be possible for tuples still being held by the function to be input to the input stream.

However, the putEnd method of the StreamInput object can be used to input to the input stream the tuples that are still being held by the timestamp adjustment function after a tuple input operation has been completed. If you are using a custom adaptor, you can input to the input stream these tuples held by the function by issuing the putEnd method from a data transmission application. If you are using a standard adaptor, the putEnd method is issued upon completion of the tuple input operation.

When the putEnd method is issued, the following statuses occur in the timestamp adjustment function:

  1. Stops accepting new tuples
    The timestamp adjustment function goes onto a status in which it no longer accepts new tuples.
    When the putEnd method has been issued for all input streams within the query group, the timestamp adjustment function prepares to resume accepting tuples.
  2. Resumes accepting new tuples
    When the timestamp adjustment function completes its preparations, it starts accepting new tuples again. Once the timestamp adjustment function resumes accepting tuples, it goes onto the same status as when the query group started.

You can check the status of the timestamp adjustment function by using the isStarted method of the StreamInput object. If you issue the isStarted method when the timestamp adjustment function is in status 1 above, false (function has not resumed accepting tuples) is returned. If you issue the isStarted method when the timestamp adjustment function is in status 2 above, true (function has resumed accepting tuples) is returned.