com.actian.dataflow.cal.yarn.server

Class YarnWorkerArgs

java.lang.Object

com.actian.dataflow.cal.yarn.server.YarnWorkerArgs

public class YarnWorkerArgs
extends Object

Container of arguments passed to each partition worker. The arguments are serialized to be sent to the worker.

Constructor Summary

Constructors

Constructor and Description
YarnWorkerArgs(JobSpecifier jobSpec, ModuleConfiguration moduleConfiguration, FileMetaConfiguration configuration, com.pervasive.datarush.cal.dr.NodeAllocationProvider provider)

Method Summary

Modifier and Type	Method and Description
com.pervasive.datarush.cal.dr.NodeAllocationProvider	getAllocationProvider()
FileMetaConfiguration	getFileConfiguration()
JobSpecifier	getJobSpecifier()
ModuleConfiguration	getModuleConfiguration()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

YarnWorkerArgs

public YarnWorkerArgs(JobSpecifier jobSpec,
                      ModuleConfiguration moduleConfiguration,
                      FileMetaConfiguration configuration,
                      com.pervasive.datarush.cal.dr.NodeAllocationProvider provider)

Method Detail

getJobSpecifier

public JobSpecifier getJobSpecifier()

getModuleConfiguration

public ModuleConfiguration getModuleConfiguration()

getFileConfiguration

public FileMetaConfiguration getFileConfiguration()

getAllocationProvider

public com.pervasive.datarush.cal.dr.NodeAllocationProvider getAllocationProvider()