public class PartitionInfo extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static String |
COLLECTOR_QUEUE |
static String |
PARTITION_QUEUE |
static String |
STOP_REQUEST_TOPIC |
Constructor and Description |
---|
PartitionInfo(PartitionExecutionImpl partitionExecution,
Step step,
JobExecutionImpl jobExecution) |
Modifier and Type | Method and Description |
---|---|
static String |
getCollectorQueueName(long stepExecutionId)
Returns the name of the queue for sending and receiving partition execution
collector data.
|
JobExecutionImpl |
getJobExecution() |
PartitionExecutionImpl |
getPartitionExecution() |
Step |
getStep() |
static String |
getStopRequestTopicName(long jobExecutionId) |
String |
toString() |
public static final String PARTITION_QUEUE
public static final String COLLECTOR_QUEUE
public static final String STOP_REQUEST_TOPIC
public PartitionInfo(PartitionExecutionImpl partitionExecution, Step step, JobExecutionImpl jobExecution)
public static String getCollectorQueueName(long stepExecutionId)
stepExecutionId
- the step execution id used to uniquely identify the step executionpublic static String getStopRequestTopicName(long jobExecutionId)
public PartitionExecutionImpl getPartitionExecution()
public Step getStep()
public JobExecutionImpl getJobExecution()
Copyright © 2019 JBoss by Red Hat. All rights reserved.