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

Vertex.getTaskLaunchCmdOpts介绍

[英]Get the launch command opts for tasks in this vertex
[中]获取启动命令选择此顶点中的任务

代码示例

代码示例来源：origin: cascading/cascading-hadoop2-tez

private void addRemoteDebug( FlowNode flowNode, Vertex vertex )
 {
 String value = System.getProperty( "test.debug.node", null );
 if( Util.isEmpty( value ) )
  return;
 if( !flowNode.getSourceElementNames().contains( value ) && asInt( value ) != flowNode.getOrdinal() )
  return;
 LOG.warn( "remote debugging enabled with property: {}, on node: {}, with node id: {}", "test.debug.node", value, flowNode.getID() );
 String opts = vertex.getTaskLaunchCmdOpts();
 if( opts == null )
  opts = "";
 String address = System.getProperty( "test.debug.address", "localhost:5005" ).trim();
 opts += " -agentlib:jdwp=transport=dt_socket,server=n,address=" + address + ",suspend=y";
 vertex.setTaskLaunchCmdOpts( opts );
 }

代码示例来源：origin: cwensel/cascading

private void addRemoteProfiling( FlowNode flowNode, Vertex vertex )
 {
 String value = System.getProperty( "test.profile.node", null );
 if( Util.isEmpty( value ) )
  return;
 if( !flowNode.getSourceElementNames().contains( value ) && asInt( value ) != flowNode.getOrdinal() )
  return;
 LOG.warn( "remote profiling enabled with property: {}, on node: {}, with node id: {}", "test.profile.node", value, flowNode.getID() );
 String opts = vertex.getTaskLaunchCmdOpts();
 if( opts == null )
  opts = "";
 String path = System.getProperty( "test.profile.path", "/tmp/jfr/" );
 if( !path.endsWith( "/" ) )
  path += "/";
 LOG.warn( "remote profiling property: {}, logging to path: {}", "test.profile.path", path );
 opts += String.format( " -XX:+UnlockCommercialFeatures -XX:+FlightRecorder -XX:FlightRecorderOptions=defaultrecording=true,dumponexit=true,dumponexitpath=%1$s%2$s,disk=true,repository=%1$s%2$s", path, flowNode.getID() );
 vertex.setTaskLaunchCmdOpts( opts );
 }

代码示例来源：origin: cwensel/cascading

private void addRemoteDebug( FlowNode flowNode, Vertex vertex )
 {
 String value = System.getProperty( "test.debug.node", null );
 if( Util.isEmpty( value ) )
  return;
 if( !flowNode.getSourceElementNames().contains( value ) && asInt( value ) != flowNode.getOrdinal() )
  return;
 LOG.warn( "remote debugging enabled with property: {}, on node: {}, with node id: {}", "test.debug.node", value, flowNode.getID() );
 String opts = vertex.getTaskLaunchCmdOpts();
 if( opts == null )
  opts = "";
 String address = System.getProperty( "test.debug.address", "localhost:5005" ).trim();
 opts += " -agentlib:jdwp=transport=dt_socket,server=n,address=" + address + ",suspend=y";
 vertex.setTaskLaunchCmdOpts( opts );
 }

代码示例来源：origin: cascading/cascading-hadoop2-tez

private void addRemoteProfiling( FlowNode flowNode, Vertex vertex )
 {
 String value = System.getProperty( "test.profile.node", null );
 if( Util.isEmpty( value ) )
  return;
 if( !flowNode.getSourceElementNames().contains( value ) && asInt( value ) != flowNode.getOrdinal() )
  return;
 LOG.warn( "remote profiling enabled with property: {}, on node: {}, with node id: {}", "test.profile.node", value, flowNode.getID() );
 String opts = vertex.getTaskLaunchCmdOpts();
 if( opts == null )
  opts = "";
 String path = System.getProperty( "test.profile.path", "/tmp/jfr/" );
 if( !path.endsWith( "/" ) )
  path += "/";
 LOG.warn( "remote profiling property: {}, logging to path: {}", "test.profile.path", path );
 opts += String.format( " -XX:+UnlockCommercialFeatures -XX:+FlightRecorder -XX:FlightRecorderOptions=defaultrecording=true,dumponexit=true,dumponexitpath=%1$s%2$s,disk=true,repository=%1$s%2$s", path, flowNode.getID() );
 vertex.setTaskLaunchCmdOpts( opts );
 }

代码示例来源：origin: cwensel/cascading

addRemoteProfiling( flowNode, vertex );
if( vertex.getTaskLaunchCmdOpts() != null )
 flowNode.addProcessAnnotation( TezConfiguration.TEZ_TASK_LAUNCH_CMD_OPTS, vertex.getTaskLaunchCmdOpts() );

代码示例来源：origin: cascading/cascading-hadoop2-tez

addRemoteProfiling( flowNode, vertex );
if( vertex.getTaskLaunchCmdOpts() != null )
 flowNode.addProcessAnnotation( TezConfiguration.TEZ_TASK_LAUNCH_CMD_OPTS, vertex.getTaskLaunchCmdOpts() );

代码示例来源：origin: org.apache.tez/tez-tests

preWarmVertex.addTaskLocalFiles(dag.getVertex("initialmap").getTaskLocalFiles());
preWarmVertex.setTaskEnvironment(dag.getVertex("initialmap").getTaskEnvironment());
preWarmVertex.setTaskLaunchCmdOpts(dag.getVertex("initialmap").getTaskLaunchCmdOpts());

代码示例来源：origin: org.apache.tez/tez-mapreduce

+ vertex.getName() + ", processor="
+ vertex.getProcessorDescriptor().getClassName() + ", parallelism="
+ vertex.getParallelism() + ", javaOpts=" + vertex.getTaskLaunchCmdOpts()
+ ", resources=" + vertex.getTaskResource()

代码示例来源：origin: org.apache.pig/pig

+ ": parallelism=" + tezOp.getVertexParallelism()
    + ", memory=" + vertex.getTaskResource().getMemory()
    + ", java opts=" + vertex.getTaskLaunchCmdOpts()
    );
log.info("Processing aliases: " + alias);

代码示例来源：origin: org.apache.tez/tez-api

TezClientUtils.addDefaultsToTaskLaunchCmdOpts(vertex.getTaskLaunchCmdOpts(), tezConf,
     javaOptsChecker));
} catch (TezException e) {