本文整理了Java中co.cask.cdap.api.workflow.WorkflowSpecification.getClassName()方法的一些代码示例，展示了WorkflowSpecification.getClassName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WorkflowSpecification.getClassName()方法的具体详情如下：
包路径：co.cask.cdap.api.workflow.WorkflowSpecification
类名称：WorkflowSpecification
方法名：getClassName

WorkflowSpecification.getClassName介绍

暂无

代码示例

代码示例来源：origin: caskdata/cdap

@Override
public JsonElement serialize(WorkflowSpecification src, Type typeOfSrc, JsonSerializationContext context) {
 JsonObject jsonObj = new JsonObject();
 jsonObj.add("className", new JsonPrimitive(src.getClassName()));
 jsonObj.add("name", new JsonPrimitive(src.getName()));
 jsonObj.add("description", new JsonPrimitive(src.getDescription()));
 jsonObj.add("plugins", serializeMap(src.getPlugins(), context, Plugin.class));
 jsonObj.add("properties", serializeMap(src.getProperties(), context, String.class));
 jsonObj.add("nodes", serializeList(src.getNodes(), context, WorkflowNode.class));
 jsonObj.add("localDatasetSpecs", serializeMap(src.getLocalDatasetSpecs(), context, DatasetCreationSpec.class));
 return jsonObj;
}

代码示例来源：origin: co.cask.cdap/cdap-proto

@Override
public JsonElement serialize(WorkflowSpecification src, Type typeOfSrc, JsonSerializationContext context) {
 JsonObject jsonObj = new JsonObject();
 jsonObj.add("className", new JsonPrimitive(src.getClassName()));
 jsonObj.add("name", new JsonPrimitive(src.getName()));
 jsonObj.add("description", new JsonPrimitive(src.getDescription()));
 jsonObj.add("plugins", serializeMap(src.getPlugins(), context, Plugin.class));
 jsonObj.add("properties", serializeMap(src.getProperties(), context, String.class));
 jsonObj.add("nodes", serializeList(src.getNodes(), context, WorkflowNode.class));
 jsonObj.add("localDatasetSpecs", serializeMap(src.getLocalDatasetSpecs(), context, DatasetCreationSpec.class));
 return jsonObj;
}

代码示例来源：origin: cdapio/cdap

@Override
 public String toString() {
  return "WorkflowSpecification{" +
   "className='" + getClassName() + '\'' +
   ", name='" + getName() + '\'' +
   ", description='" + getDescription() + '\'' +
   ", plugins=" + getPlugins() +
   ", properties=" + properties +
   ", nodes=" + nodes +
   ", nodeIdMap=" + nodeIdMap +
   ", localDatasetSpecs=" + localDatasetSpecs +
   '}';
 }
}

代码示例来源：origin: co.cask.cdap/cdap-app-fabric

@SuppressWarnings("unchecked")
private Workflow initializeWorkflow() throws Exception {
 Class<?> clz = Class.forName(workflowSpec.getClassName(), true, program.getClassLoader());
 if (!Workflow.class.isAssignableFrom(clz)) {
  throw new IllegalStateException(String.format("%s is not Workflow.", clz));
 }
 Class<? extends Workflow> workflowClass = (Class<? extends Workflow>) clz;
 final Workflow workflow = new InstantiatorFactory(false).get(TypeToken.of(workflowClass)).create();
 // set metrics
 Reflections.visit(workflow, workflow.getClass(), new MetricsFieldSetter(workflowContext.getMetrics()));
 if (!(workflow instanceof ProgramLifecycle)) {
  return workflow;
 }
 final TransactionControl txControl =
  Transactions.getTransactionControl(workflowContext.getDefaultTxControl(), Workflow.class,
                    workflow, "initialize", WorkflowContext.class);
 basicWorkflowToken.setCurrentNode(workflowSpec.getName());
 workflowContext.setState(new ProgramState(ProgramStatus.INITIALIZING, null));
 workflowContext.initializeProgram((ProgramLifecycle) workflow, txControl, false);
 workflowStateWriter.setWorkflowToken(workflowRunId, basicWorkflowToken);
 return workflow;
}

代码示例来源：origin: cdapio/cdap

@SuppressWarnings("unchecked")
private Workflow initializeWorkflow() throws Exception {
 Class<?> clz = Class.forName(workflowSpec.getClassName(), true, program.getClassLoader());
 if (!Workflow.class.isAssignableFrom(clz)) {
  throw new IllegalStateException(String.format("%s is not Workflow.", clz));
 }
 Class<? extends Workflow> workflowClass = (Class<? extends Workflow>) clz;
 final Workflow workflow = new InstantiatorFactory(false).get(TypeToken.of(workflowClass)).create();
 // set metrics
 Reflections.visit(workflow, workflow.getClass(), new MetricsFieldSetter(workflowContext.getMetrics()));
 if (!(workflow instanceof ProgramLifecycle)) {
  return workflow;
 }
 final TransactionControl txControl =
  Transactions.getTransactionControl(workflowContext.getDefaultTxControl(), Workflow.class,
                    workflow, "initialize", WorkflowContext.class);
 basicWorkflowToken.setCurrentNode(workflowSpec.getName());
 workflowContext.setState(new ProgramState(ProgramStatus.INITIALIZING, null));
 workflowContext.initializeProgram((ProgramLifecycle) workflow, txControl, false);
 workflowStateWriter.setWorkflowToken(workflowRunId, basicWorkflowToken);
 return workflow;
}