import org.apache.samza.task.StreamTask; //导入依赖的package包/类
@Override
SamzaContainer createSamzaContainer(String processorId, JobModel jobModel) {
  if (container == null) {
    RunLoop mockRunLoop = mock(RunLoop.class);
    doAnswer(invocation ->
      {
        try {
          runLoopStartForMain.countDown();
          containerStop.await();
        } catch (InterruptedException e) {
          System.out.println("In exception" + e);
          e.printStackTrace();
        }
        return null;
      }).when(mockRunLoop).run();

    doAnswer(invocation ->
      {
        containerStop.countDown();
        return null;
      }).when(mockRunLoop).shutdown();
    container = StreamProcessorTestUtils.getDummyContainer(mockRunLoop, mock(StreamTask.class));
  }
  return container;
}
 

import org.apache.samza.task.StreamTask; //导入依赖的package包/类
public SamzaJobConfigBuilder task(Class<? extends StreamTask> taskClass) {
  isNull(taskClass, "Task class");

  put(TASK_CLASS, taskClass.getName());

  return this;
}