コンストラクターの詳細

• SparkYarnTasklet

  public SparkYarnTasklet()

メソッドの詳細

• execute

  public org.springframework.batch.repeat.RepeatStatus execute(org.springframework.batch.core.StepContribution contribution,
                                                      org.springframework.batch.core.scope.context.ChunkContext chunkContext)
                                                        throws java.lang.Exception

  次で指定:

  インターフェース org.springframework.batch.core.step.tasklet.Tasklet 内の execute 

  例外:

  java.lang.Exception

• beforeStep

  public void beforeStep(org.springframework.batch.core.StepExecution stepExecution)

  次で指定:

  インターフェース org.springframework.batch.core.StepExecutionListener 内の beforeStep 

• afterStep

  public org.springframework.batch.core.ExitStatus afterStep(org.springframework.batch.core.StepExecution stepExecution)

  次で指定:

  インターフェース org.springframework.batch.core.StepExecutionListener 内の afterStep 

• afterPropertiesSet

  public void afterPropertiesSet()
                          throws java.lang.Exception

  次で指定:

  インターフェース org.springframework.beans.factory.InitializingBean 内の afterPropertiesSet 

  例外:

  java.lang.Exception

• setSparkAssemblyJar

  public void setSparkAssemblyJar(java.lang.String sparkAssemblyJar)

• setExtraClassPath

  public void setExtraClassPath(java.lang.String extraClassPath)

• setHadoopConfiguration

  public void setHadoopConfiguration(org.apache.hadoop.conf.Configuration configuration)

• setAppName

  public void setAppName(java.lang.String appName)

• setAppClass

  public void setAppClass(java.lang.String appClass)

• setAppJar

  public void setAppJar(java.lang.String appJar)

• setResourceFiles

  public void setResourceFiles(java.lang.String resourceFiles)

• setResourceArchives

  public void setResourceArchives(java.lang.String resourceArchives)

• setExecutorMemory

  public void setExecutorMemory(java.lang.String executorMemory)

• setExecutorCores

  public void setExecutorCores(java.lang.String executorCores)

• setDriverMemory

  public void setDriverMemory(java.lang.String driverMemory)

• setDriverCores

  public void setDriverCores(java.lang.String driverCores)

• setNumExecutors

  public void setNumExecutors(int numExecutors)

• setArguments

  public void setArguments(java.lang.String[] arguments)