...
Workers have semantics similar to a Java thread and are run in a thread when CDAP is run in either in-memory or local sandbox modes. In distributed mode, each instance of a worker runs in its own YARN container. Their instances may be updated via the Command Line Interface or a RESTful APIMicroservices:
| Code Block |
|---|
public class ProcessWorker extends AbstractWorker {
@Override
public void initialize(WorkerContext context) {
super.initialize(context);
...
}
@Override
public void run() {
...
}
@Override
public void stop() {
...
}
@Override
public void destroy() {
...
}
} |
...