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

getSchedulingJitterPercent() - 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