tlpipe.timestream.timestream_task.OneAndOne.process

OneAndOne.process(input)[source]

Override this method with your data processing task.