I designed a new worker api: Twister2Worker.
I created a unified method to initialize proper Environment object.
I deleted base interfaces: BatchTSetIWorker.java, StreamingTSetIWorker.java, CheckpointingBatchTSetIWorker.java
I modified example classes that have been implementing these base interfaces.
I designed a new worker api: Twister2Worker. I created a unified method to initialize proper Environment object. I deleted base interfaces: BatchTSetIWorker.java, StreamingTSetIWorker.java, CheckpointingBatchTSetIWorker.java I modified example classes that have been implementing these base interfaces.