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:
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.