Skip navigation links
A B C D E F G H I J L M N O P R S T U V Y 

A

AbstractJobProxy - Class in org.apache.samza.rest.proxy.job
Implements a subset of the JobProxy interface with the default, cluster-agnostic, implementations.
AbstractJobProxy(JobsResourceConfig) - Constructor for class org.apache.samza.rest.proxy.job.AbstractJobProxy
Required constructor.
addServlet(Servlet, String) - Method in class org.apache.samza.rest.SamzaRestService
Adds the specified Servlet to the server at the specified path.

B

badRequestResponse(String) - Static method in class org.apache.samza.rest.resources.Responses
Constructs a bad request (HTTP 400) response.
BaseResourceConfig - Class in org.apache.samza.rest.resources
This class contains the common configurations that are shared between different samza-rest resources.
BaseResourceConfig(Config) - Constructor for class org.apache.samza.rest.resources.BaseResourceConfig
 
BIN_SUBPATH - Static variable in class org.apache.samza.rest.proxy.installation.SimpleInstallationFinder
 

C

CFG_SUBPATH - Static variable in class org.apache.samza.rest.proxy.installation.SimpleInstallationFinder
 
config - Variable in class org.apache.samza.rest.proxy.job.AbstractJobProxy
 
CONFIG_IGNORE_FAILURES - Static variable in class org.apache.samza.monitor.LocalStoreMonitorConfig
Will make LocalStoreMonitor ignore failures during store clean ups.
CONFIG_JOB_CONFIG_FACTORY - Static variable in class org.apache.samza.rest.resources.BaseResourceConfig
Specifies the canonical name of the ConfigFactory to read the job configs.
CONFIG_JOB_INSTALLATIONS_PATH - Static variable in class org.apache.samza.rest.resources.BaseResourceConfig
The path where all the Samza jobs are installed (unzipped).
CONFIG_JOB_PROXY_FACTORY - Static variable in class org.apache.samza.rest.resources.JobsResourceConfig
Specifies the canonical name of the JobProxyFactory class to produce JobProxy instances.
CONFIG_MONITOR_FACTORY_CLASS - Static variable in class org.apache.samza.monitor.MonitorConfig
 
CONFIG_REST_RESOURCE_CLASSES - Static variable in class org.apache.samza.rest.SamzaRestConfig
Specifies a comma-delimited list of class names of resources to register with the server.
CONFIG_REST_RESOURCE_FACTORIES - Static variable in class org.apache.samza.rest.SamzaRestConfig
Specifies a comma-delimited list of class names that implement ResourceFactory.
CONFIG_SAMZA_REST_SERVICE_PORT - Static variable in class org.apache.samza.rest.SamzaRestConfig
The port number to use for the HTTP server or 0 to dynamically choose a port.
CONFIG_SCHEDULING_INTERVAL - Static variable in class org.apache.samza.monitor.MonitorConfig
 
CONFIG_TASK_PROXY_FACTORY - Static variable in class org.apache.samza.rest.proxy.task.TaskResourceConfig
Specifies the canonical name of the TaskProxyFactory class to produce TaskProxy instances.

D

DefaultResourceFactory - Class in org.apache.samza.rest.resources
Instantiates all the resources that are shipped with the REST service.
DefaultResourceFactory() - Constructor for class org.apache.samza.rest.resources.DefaultResourceFactory
 
diskSpaceFreedInBytes - Variable in class org.apache.samza.monitor.LocalStoreMonitorMetrics
Total disk space cleared by the LocalStoreMonitor.

E

environment() - Method in class org.apache.samza.rest.script.ScriptRunner
Gets the mutable map of environment variables to add to the child process environment.
equals(Object) - Method in class org.apache.samza.rest.model.Partition
 
equals(Object) - Method in class org.apache.samza.rest.model.Task
 
equals(Object) - Method in class org.apache.samza.rest.proxy.job.JobInstance
 
errorResponse(String) - Static method in class org.apache.samza.rest.resources.Responses
Constructs a consistent format for error responses.

F

failedStoreDeletionAttempts - Variable in class org.apache.samza.monitor.LocalStoreMonitorMetrics
Total number of times task store deletions have been attempted and failed.
fromFactory(JobsResourceConfig) - Static method in class org.apache.samza.rest.proxy.job.AbstractJobProxy
Creates a new JobProxy instance from the factory class specified in the config.

G

GET_JOBS_URL - Static variable in class org.apache.samza.rest.resources.ResourceConstants
 
GET_TASKS_URL - Static variable in class org.apache.samza.rest.resources.ResourceConstants
 
getAllInstalledJobs() - Method in interface org.apache.samza.rest.proxy.installation.InstallationFinder
 
getAllInstalledJobs() - Method in class org.apache.samza.rest.proxy.installation.SimpleInstallationFinder
 
getAllJobInstances() - Method in class org.apache.samza.rest.proxy.job.AbstractJobProxy
 
getAllJobInstances() - Method in class org.apache.samza.rest.proxy.job.SimpleYarnJobProxy
 
getAllJobStatuses() - Method in class org.apache.samza.rest.proxy.job.AbstractJobProxy
 
getAllJobStatuses() - Method in interface org.apache.samza.rest.proxy.job.JobProxy
 
getConfigFilePath() - Method in class org.apache.samza.rest.proxy.installation.InstallationRecord
 
getContainerId() - Method in class org.apache.samza.rest.model.Task
 
getIgnoreFailures() - Method in class org.apache.samza.monitor.LocalStoreMonitorConfig
Determines if failures in store cleanup of individual jobs should be ignored in LocalStoreMonitor.
getInstallationFinder() - Method in class org.apache.samza.rest.proxy.job.ScriptJobProxy
 
getInstallationFinder() - Method in class org.apache.samza.rest.proxy.job.SimpleYarnJobProxy
 
getInstallationsPath() - Method in class org.apache.samza.rest.resources.BaseResourceConfig
 
getInstalledJobs() - Method in class org.apache.samza.rest.resources.JobsResource
Gets the Job for all the jobs installed on this host.
getJob(String, String) - Method in class org.apache.samza.rest.resources.JobsResource
Gets the Job for the job instance specified by jobName and jobId if it is installed on this host.
getJobConfigFactory() - Method in class org.apache.samza.rest.resources.BaseResourceConfig
 
getJobId() - Method in class org.apache.samza.rest.model.Job
 
getJobId() - Method in class org.apache.samza.rest.proxy.job.JobInstance
 
getJobName() - Method in class org.apache.samza.rest.model.Job
 
getJobName() - Method in class org.apache.samza.rest.proxy.job.JobInstance
 
getJobProxy(JobsResourceConfig) - Method in interface org.apache.samza.rest.proxy.job.JobProxyFactory
Creates a new JobProxy and initializes it with the specified config.
getJobProxy(JobsResourceConfig) - Method in class org.apache.samza.rest.proxy.job.SimpleYarnJobProxyFactory
 
getJobProxyFactory() - Method in class org.apache.samza.rest.resources.JobsResourceConfig
 
getJobSamzaStatus(JobInstance) - Method in class org.apache.samza.rest.proxy.job.AbstractJobProxy
Convenience method to get the Samza job status from the name and id.
getJobStatus(JobInstance) - Method in class org.apache.samza.monitor.JobsClient
This method should be used to find the JobStatus of a jobInstance.
getJobStatus(JobInstance) - Method in class org.apache.samza.rest.proxy.job.AbstractJobProxy
 
getJobStatus(JobInstance) - Method in interface org.apache.samza.rest.proxy.job.JobProxy
 
getJobStatus(JobInstance) - Method in interface org.apache.samza.rest.proxy.job.JobStatusProvider
 
getJobStatus(JobInstance) - Method in class org.apache.samza.rest.proxy.job.YarnRestJobStatusProvider
 
getJobStatuses(Collection<Job>) - Method in interface org.apache.samza.rest.proxy.job.JobStatusProvider
Populates the status* fields of each Job in the provided Collection.
getJobStatuses(Collection<Job>) - Method in class org.apache.samza.rest.proxy.job.YarnRestJobStatusProvider
 
getJobStatusProvider() - Method in class org.apache.samza.rest.proxy.job.AbstractJobProxy
 
getJobStatusProvider() - Method in class org.apache.samza.rest.proxy.job.SimpleYarnJobProxy
 
getJobStatusServers() - Method in class org.apache.samza.monitor.LocalStoreMonitorConfig
 
getLocalStoreBaseDir() - Method in class org.apache.samza.monitor.LocalStoreMonitorConfig
 
getMonitorConfigs(Config) - Static method in class org.apache.samza.monitor.MonitorConfig
Groups configuration defined in the config object for each of the monitors into a MonitorConfig object
getMonitorFactoryClass() - Method in class org.apache.samza.monitor.MonitorConfig
 
getMonitorInstance(String, MonitorConfig, MetricsRegistry) - Method in class org.apache.samza.monitor.LocalStoreMonitorFactory
 
getMonitorInstance(String, MonitorConfig, MetricsRegistry) - Method in interface org.apache.samza.monitor.MonitorFactory
 
getName() - Method in class org.apache.samza.rest.model.yarn.YarnApplicationInfo.YarnApplication
 
getOffsetFileTTL() - Method in class org.apache.samza.monitor.LocalStoreMonitorConfig
 
getPartitionId() - Method in class org.apache.samza.rest.model.Partition
 
getPartitions() - Method in class org.apache.samza.rest.model.Task
 
getPort() - Method in class org.apache.samza.rest.SamzaRestConfig
 
getPreferredHost() - Method in class org.apache.samza.rest.model.Task
 
getQualifiedJobName(JobInstance) - Static method in class org.apache.samza.rest.model.yarn.YarnApplicationInfo
Constructs the job name used in YARN.
getResourceClassNames() - Method in class org.apache.samza.rest.SamzaRestConfig
 
getResourceFactoryClassNames() - Method in class org.apache.samza.rest.SamzaRestConfig
 
getResourceInstances(Config) - Method in class org.apache.samza.rest.resources.DefaultResourceFactory
 
getResourceInstances(Config) - Method in interface org.apache.samza.rest.resources.ResourceFactory
Constructs and returns resource instances to register with the server.
getRootPath() - Method in class org.apache.samza.rest.proxy.installation.InstallationRecord
 
getSchedulingIntervalInMs() - Method in class org.apache.samza.monitor.MonitorConfig
 
getScriptFilePath() - Method in class org.apache.samza.rest.proxy.installation.InstallationRecord
 
getScriptPath(JobInstance, String) - Method in class org.apache.samza.rest.proxy.job.ScriptJobProxy
Constructs the path to the specified script within the job installation.
getScriptPath(JobInstance, String) - Method in interface org.apache.samza.rest.script.ScriptPathProvider
 
getScriptTimeoutS() - Method in class org.apache.samza.rest.script.ScriptRunner
 
getState() - Method in class org.apache.samza.rest.model.yarn.YarnApplicationInfo.YarnApplication
 
getStatus() - Method in class org.apache.samza.rest.model.Job
 
getStatusDetail() - Method in class org.apache.samza.rest.model.Job
 
getStoreNames() - Method in class org.apache.samza.rest.model.Task
 
getStream() - Method in class org.apache.samza.rest.model.Partition
 
getSystem() - Method in class org.apache.samza.rest.model.Partition
 
getTaskName() - Method in class org.apache.samza.rest.model.Task
 
getTaskProxy(TaskResourceConfig) - Method in class org.apache.samza.rest.proxy.task.SamzaTaskProxyFactory
 
getTaskProxy(TaskResourceConfig) - Method in interface org.apache.samza.rest.proxy.task.TaskProxyFactory
 
getTaskProxyFactory() - Method in class org.apache.samza.rest.proxy.task.TaskResourceConfig
 
getTasks(JobInstance) - Method in class org.apache.samza.monitor.JobsClient
This method retrieves and returns the list of tasks that are associated with a JobInstance.
getTasks(JobInstance) - Method in class org.apache.samza.rest.proxy.task.SamzaTaskProxy
Fetches the complete job model from the coordinator stream based upon the provided JobInstance param, transforms it to a list of Task and returns it.
getTasks(JobInstance) - Method in interface org.apache.samza.rest.proxy.task.TaskProxy
 
getTasks(String, String) - Method in class org.apache.samza.rest.resources.TasksResource
Gets the list of Task for the job instance specified by jobName and jobId.
getYarnApplications() - Method in class org.apache.samza.rest.model.yarn.YarnApplicationInfo
 
getYarnResourceManagerEndpoint() - Method in class org.apache.samza.rest.resources.YarnJobResourceConfig
Returns the configured YARN Resource Manager REST API endpoint.

H

hasBeenStarted() - Method in enum org.apache.samza.rest.model.JobStatus
 
hashCode() - Method in class org.apache.samza.rest.model.Partition
 
hashCode() - Method in class org.apache.samza.rest.model.Task
 
hashCode() - Method in class org.apache.samza.rest.proxy.job.JobInstance
 

I

initializeCoordinatorStreamConsumer(JobInstance) - Method in class org.apache.samza.rest.proxy.task.SamzaTaskProxy
Initialize CoordinatorStreamSystemConsumer based upon JobInstance parameter.
InstallationFinder - Interface in org.apache.samza.rest.proxy.installation
Finds all the installed jobs.
InstallationRecord - Class in org.apache.samza.rest.proxy.installation
Represents an installation of one Samza job instance on a file system.
InstallationRecord(String, String, String, String, String) - Constructor for class org.apache.samza.rest.proxy.installation.InstallationRecord
 
installationsPath - Variable in class org.apache.samza.rest.proxy.installation.SimpleInstallationFinder
 
instantiateMonitor(String, MonitorConfig, MetricsRegistry) - Static method in class org.apache.samza.monitor.MonitorLoader
 
isInstalled(JobInstance) - Method in interface org.apache.samza.rest.proxy.installation.InstallationFinder
 
isInstalled(JobInstance) - Method in class org.apache.samza.rest.proxy.installation.SimpleInstallationFinder
 

J

Job - Class in org.apache.samza.rest.model
The client view of a job.
Job(String, String) - Constructor for class org.apache.samza.rest.model.Job
 
Job(String, String, JobStatus, String) - Constructor for class org.apache.samza.rest.model.Job
 
Job() - Constructor for class org.apache.samza.rest.model.Job
 
jobConfigFactory - Variable in class org.apache.samza.rest.proxy.installation.SimpleInstallationFinder
 
jobExists(JobInstance) - Method in class org.apache.samza.rest.proxy.job.AbstractJobProxy
 
jobExists(JobInstance) - Method in interface org.apache.samza.rest.proxy.job.JobProxy
 
JobInstance - Class in org.apache.samza.rest.proxy.job
Allows us to encapsulate the jobName,jobId tuple as one entity.
JobInstance(String, String) - Constructor for class org.apache.samza.rest.proxy.job.JobInstance
Required constructor.
JobProxy - Interface in org.apache.samza.rest.proxy.job
Job proxy is the primary abstraction used by the REST API to interact with jobs.
JobProxyFactory - Interface in org.apache.samza.rest.proxy.job
Simple factory interface to produce instances of JobProxy, depending on the implementation.
JobsClient - Class in org.apache.samza.monitor
This is a helper class to interact with the samza-rest apis.
JobsClient(List<String>) - Constructor for class org.apache.samza.monitor.JobsClient
 
JobsResource - Class in org.apache.samza.rest.resources
The REST resource for jobs.
JobsResource(JobsResourceConfig) - Constructor for class org.apache.samza.rest.resources.JobsResource
Initializes a JobResource with JobProxy from the JobProxyFactory class specified in the configuration.
JobsResourceConfig - Class in org.apache.samza.rest.resources
Configurations for the JobsResource endpoint.
JobsResourceConfig(Config) - Constructor for class org.apache.samza.rest.resources.JobsResourceConfig
 
JobStatus - Enum in org.apache.samza.rest.model
The abstract status of the job, irrespective of the status in any underlying cluster management system (e.g.
JobStatusProvider - Interface in org.apache.samza.rest.proxy.job
Interface for getting job status independent of the underlying cluster implementation.

L

LocalStoreMonitor - Class in org.apache.samza.monitor
This monitor class periodically checks for the presence of stale store directories and deletes them if the samza task that created it is not running for more than X days.
LocalStoreMonitor(LocalStoreMonitorConfig, LocalStoreMonitorMetrics, JobsClient) - Constructor for class org.apache.samza.monitor.LocalStoreMonitor
 
LocalStoreMonitorConfig - Class in org.apache.samza.monitor
Configurations for the monitor LocalStoreMonitor.
LocalStoreMonitorConfig(Config) - Constructor for class org.apache.samza.monitor.LocalStoreMonitorConfig
 
LocalStoreMonitorFactory - Class in org.apache.samza.monitor
Factory to build LocalStoreMonitor using provided config.
LocalStoreMonitorFactory() - Constructor for class org.apache.samza.monitor.LocalStoreMonitorFactory
 
LocalStoreMonitorMetrics - Class in org.apache.samza.monitor
Contains all the metrics published by LocalStoreMonitor.
LocalStoreMonitorMetrics(String, MetricsRegistry) - Constructor for class org.apache.samza.monitor.LocalStoreMonitorMetrics
 

M

main(String[]) - Static method in class org.apache.samza.rest.SamzaRestService
Command line interface to run the server.
monitor() - Method in class org.apache.samza.monitor.LocalStoreMonitor
This monitor method is invoked periodically to delete the stale state stores of dead jobs/tasks.
Monitor - Interface in org.apache.samza.monitor
A Monitor is a class implementing some functionality that should be done every N milliseconds on a YARN RM or NM.
monitor() - Method in interface org.apache.samza.monitor.Monitor
Do the work of the monitor.
MonitorConfig - Class in org.apache.samza.monitor
Configurations for the Monitor implementations.
MonitorConfig(Config) - Constructor for class org.apache.samza.monitor.MonitorConfig
 
MonitorFactory - Interface in org.apache.samza.monitor
Factory to build Monitor using provided config.
MonitorLoader - Class in org.apache.samza.monitor
Helper class that instantiates the Monitor.
MonitorLoader() - Constructor for class org.apache.samza.monitor.MonitorLoader
 

N

noOfDeletedTaskPartitionStores - Variable in class org.apache.samza.monitor.LocalStoreMonitorMetrics
Total number of task partition stores deleted by the LocalStoreMonitor.

O

org.apache.samza.monitor - package org.apache.samza.monitor
 
org.apache.samza.rest - package org.apache.samza.rest
 
org.apache.samza.rest.model - package org.apache.samza.rest.model
 
org.apache.samza.rest.model.yarn - package org.apache.samza.rest.model.yarn
 
org.apache.samza.rest.proxy.installation - package org.apache.samza.rest.proxy.installation
 
org.apache.samza.rest.proxy.job - package org.apache.samza.rest.proxy.job
 
org.apache.samza.rest.proxy.task - package org.apache.samza.rest.proxy.task
 
org.apache.samza.rest.resources - package org.apache.samza.rest.resources
 
org.apache.samza.rest.script - package org.apache.samza.rest.script
 

P

Partition - Class in org.apache.samza.rest.model
Provides a client view of the samza system stream partition.
Partition() - Constructor for class org.apache.samza.rest.model.Partition
 
Partition(String, String, int) - Constructor for class org.apache.samza.rest.model.Partition
 
Partition(SystemStreamPartition) - Constructor for class org.apache.samza.rest.model.Partition
 
processScriptOutput(InputStream) - Method in interface org.apache.samza.rest.script.ScriptOutputHandler
Processes the script output represented by the InputStream.

R

readTasksFromCoordinatorStream(CoordinatorStreamSystemConsumer) - Method in class org.apache.samza.rest.proxy.task.SamzaTaskProxy
Builds list of Task from job model in coordinator stream.
ResourceConstants - Class in org.apache.samza.rest.resources
 
ResourceConstants() - Constructor for class org.apache.samza.rest.resources.ResourceConstants
 
ResourceFactory - Interface in org.apache.samza.rest.resources
Instantiates a resource using the provided config.
Responses - Class in org.apache.samza.rest.resources
This is a helper class that holds the methods that are reusable across the different samza-rest resource endpoints.
runScript(String, String...) - Method in class org.apache.samza.rest.script.ScriptRunner
Runs a script with IO inherited from the current Java process.
runScript(String, ScriptOutputHandler, String...) - Method in class org.apache.samza.rest.script.ScriptRunner
 

S

SamzaMonitorService - Class in org.apache.samza.monitor
The class responsible for handling long-running/scheduled monitors in Samza REST.
SamzaMonitorService(SamzaRestConfig, MetricsRegistry, SchedulingProvider) - Constructor for class org.apache.samza.monitor.SamzaMonitorService
 
SamzaRestApplication - Class in org.apache.samza.rest
Samza REST implementation of the JAX-RS Application model.
SamzaRestApplication(SamzaRestConfig) - Constructor for class org.apache.samza.rest.SamzaRestApplication
 
SamzaRestConfig - Class in org.apache.samza.rest
The set of configurations required by the core components of the SamzaRestService.
SamzaRestConfig(Config) - Constructor for class org.apache.samza.rest.SamzaRestConfig
 
SamzaRestService - Class in org.apache.samza.rest
The main Java class for the Samza REST API.
SamzaRestService(Server, ReadableMetricsRegistry, Map<String, MetricsReporter>, ServletContextHandler) - Constructor for class org.apache.samza.rest.SamzaRestService
 
SamzaTaskProxy - Class in org.apache.samza.rest.proxy.task
TaskProxy interface implementation for samza jobs running in yarn execution environment.
SamzaTaskProxy(TaskResourceConfig, InstallationFinder) - Constructor for class org.apache.samza.rest.proxy.task.SamzaTaskProxy
 
SamzaTaskProxyFactory - Class in org.apache.samza.rest.proxy.task
Creates the TaskProxy instances.
SamzaTaskProxyFactory() - Constructor for class org.apache.samza.rest.proxy.task.SamzaTaskProxyFactory
 
schedule(Runnable, int) - Method in class org.apache.samza.monitor.ScheduledExecutorSchedulingProvider
 
schedule(Runnable, int) - Method in interface org.apache.samza.monitor.SchedulingProvider
 
ScheduledExecutorSchedulingProvider - Class in org.apache.samza.monitor
 
ScheduledExecutorSchedulingProvider(ScheduledExecutorService) - Constructor for class org.apache.samza.monitor.ScheduledExecutorSchedulingProvider
 
SchedulingProvider - Interface in org.apache.samza.monitor
Provides scheduling functionality to the SamzaMonitorService.
ScriptJobProxy - Class in org.apache.samza.rest.proxy.job
Extends AbstractJobProxy with some script support functionality.
ScriptJobProxy(JobsResourceConfig) - Constructor for class org.apache.samza.rest.proxy.job.ScriptJobProxy
Required constructor.
ScriptOutputHandler - Interface in org.apache.samza.rest.script
A script output handler processes the stream of output from the stdout and stderr channels of a script.
ScriptPathProvider - Interface in org.apache.samza.rest.script
Defines the protocol for getting script paths.
scriptRunner - Variable in class org.apache.samza.rest.proxy.job.ScriptJobProxy
 
ScriptRunner - Class in org.apache.samza.rest.script
Runs a script process and returns the exit code.
ScriptRunner() - Constructor for class org.apache.samza.rest.script.ScriptRunner
 
setContainerId(String) - Method in class org.apache.samza.rest.model.Task
 
setJobId(String) - Method in class org.apache.samza.rest.model.Job
 
setJobName(String) - Method in class org.apache.samza.rest.model.Job
 
setPartitionId(int) - Method in class org.apache.samza.rest.model.Partition
 
setPartitions(List<Partition>) - Method in class org.apache.samza.rest.model.Task
 
setPreferredHost(String) - Method in class org.apache.samza.rest.model.Task
 
setStatus(JobStatus) - Method in class org.apache.samza.rest.model.Job
 
setStatusDetail(String) - Method in class org.apache.samza.rest.model.Job
 
setStoreNames(List<String>) - Method in class org.apache.samza.rest.model.Task
 
setStream(String) - Method in class org.apache.samza.rest.model.Partition
 
setSystem(String) - Method in class org.apache.samza.rest.model.Partition
 
setTaskName(String) - Method in class org.apache.samza.rest.model.Task
 
SimpleInstallationFinder - Class in org.apache.samza.rest.proxy.installation
A simple default implementation of InstallationFinder.
SimpleInstallationFinder(String, ConfigFactory) - Constructor for class org.apache.samza.rest.proxy.installation.SimpleInstallationFinder
Required constructor.
SimpleYarnJobProxy - Class in org.apache.samza.rest.proxy.job
Extends the ScriptJobProxy with methods specific to simple Samza deployments.
SimpleYarnJobProxy(JobsResourceConfig) - Constructor for class org.apache.samza.rest.proxy.job.SimpleYarnJobProxy
 
SimpleYarnJobProxyFactory - Class in org.apache.samza.rest.proxy.job
Factory to produce SimpleJobProxy instances.
SimpleYarnJobProxyFactory() - Constructor for class org.apache.samza.rest.proxy.job.SimpleYarnJobProxyFactory
 
start() - Method in class org.apache.samza.monitor.SamzaMonitorService
 
start(JobInstance) - Method in interface org.apache.samza.rest.proxy.job.JobProxy
Starts the job instance specified by jobName and jobId.
start(JobInstance) - Method in class org.apache.samza.rest.proxy.job.SimpleYarnJobProxy
 
start() - Method in class org.apache.samza.rest.SamzaRestService
Starts the server asynchronously.
stop() - Method in class org.apache.samza.monitor.SamzaMonitorService
 
stop() - Method in class org.apache.samza.monitor.ScheduledExecutorSchedulingProvider
 
stop() - Method in interface org.apache.samza.monitor.SchedulingProvider
 
stop(JobInstance) - Method in interface org.apache.samza.rest.proxy.job.JobProxy
Stops the job instance specified by jobName and jobId.
stop(JobInstance) - Method in class org.apache.samza.rest.proxy.job.SimpleYarnJobProxy
 
stop() - Method in class org.apache.samza.rest.SamzaRestService
Stops the server.

T

Task - Class in org.apache.samza.rest.model
Provides a client view of a samza task.
Task() - Constructor for class org.apache.samza.rest.model.Task
 
Task(String, String, String, List<Partition>, List<String>) - Constructor for class org.apache.samza.rest.model.Task
 
TaskProxy - Interface in org.apache.samza.rest.proxy.task
TaskProxy is the primary abstraction that will be used by Rest API's to interact with tasks.
TaskProxyFactory - Interface in org.apache.samza.rest.proxy.task
Factory interface that will be used to create TaskProxy instances.
TaskResourceConfig - Class in org.apache.samza.rest.proxy.task
Configurations for the TasksResource endpoint.
TaskResourceConfig(Config) - Constructor for class org.apache.samza.rest.proxy.task.TaskResourceConfig
 
TasksResource - Class in org.apache.samza.rest.resources
The REST resource for tasks.
TasksResource(TaskResourceConfig) - Constructor for class org.apache.samza.rest.resources.TasksResource
Initializes a TaskResource with TaskProxy from the TaskProxyFactory class specified in the configuration.
toString() - Method in enum org.apache.samza.rest.model.JobStatus
 
toString() - Method in class org.apache.samza.rest.model.Task
 
toString() - Method in class org.apache.samza.rest.proxy.installation.InstallationRecord
 
toString() - Method in class org.apache.samza.rest.proxy.job.JobInstance
 

U

updateJobStatus(String, String, String) - Method in class org.apache.samza.rest.resources.JobsResource
 

V

valueOf(String) - Static method in enum org.apache.samza.rest.model.JobStatus
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.samza.rest.model.JobStatus
Returns an array containing the constants of this enum type, in the order they are declared.

Y

YarnApplication() - Constructor for class org.apache.samza.rest.model.yarn.YarnApplicationInfo.YarnApplication
 
YarnApplication(String, String) - Constructor for class org.apache.samza.rest.model.yarn.YarnApplicationInfo.YarnApplication
 
YarnApplicationInfo - Class in org.apache.samza.rest.model.yarn
 
YarnApplicationInfo() - Constructor for class org.apache.samza.rest.model.yarn.YarnApplicationInfo
 
YarnApplicationInfo(List<YarnApplicationInfo.YarnApplication>) - Constructor for class org.apache.samza.rest.model.yarn.YarnApplicationInfo
 
YarnApplicationInfo.YarnApplication - Class in org.apache.samza.rest.model.yarn
 
YarnJobResourceConfig - Class in org.apache.samza.rest.resources
Configurations for the YARN based JobsResource endpoint.
YarnJobResourceConfig(JobsResourceConfig) - Constructor for class org.apache.samza.rest.resources.YarnJobResourceConfig
 
YarnRestJobStatusProvider - Class in org.apache.samza.rest.proxy.job
An implementation of the JobStatusProvider that retrieves the job status from the YARN REST api.
YarnRestJobStatusProvider(JobsResourceConfig) - Constructor for class org.apache.samza.rest.proxy.job.YarnRestJobStatusProvider
 
A B C D E F G H I J L M N O P R S T U V Y 
Skip navigation links