@UriEndpoint(scheme="ignite:compute", title="Ignite Compute", syntax="ignite:compute:[endpointId]", label="nosql,cache,compute", producerOnly=true) public class IgniteComputeEndpoint extends AbstractIgniteEndpoint
component
Constructor and Description |
---|
IgniteComputeEndpoint(String uri,
URI remainingUri,
Map<String,Object> parameters,
IgniteComponent igniteComponent) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.ignite.IgniteCompute |
createIgniteCompute() |
org.apache.camel.Producer |
createProducer() |
String |
getComputeName()
Gets the name of the compute job, which will be set via
IgniteCompute.withName(String) . |
IgniteComputeExecutionType |
getExecutionType()
Gets the execution type of this producer.
|
String |
getTaskName()
Gets the task name, only applicable if using the
IgniteComputeExecutionType.EXECUTE execution type. |
Long |
getTimeoutMillis()
Gets the timeout interval for triggered jobs, in milliseconds, which will be set via
IgniteCompute.withTimeout(long) . |
void |
setComputeName(String computeName)
Sets the name of the compute job, which will be set via
IgniteCompute.withName(String) . |
void |
setExecutionType(IgniteComputeExecutionType executionType)
Sets the execution type of this producer.
|
void |
setTaskName(String taskName)
Sets the task name, only applicable if using the
IgniteComputeExecutionType.EXECUTE execution type. |
void |
setTimeoutMillis(Long timeoutMillis)
Sets the timeout interval for triggered jobs, in milliseconds, which will be set via
IgniteCompute.withTimeout(long) . |
ignite, igniteComponent, isPropagateIncomingBodyIfNoReturnValue, isSingleton, isTreatCollectionsAsCacheObjects, setPropagateIncomingBodyIfNoReturnValue, setTreatCollectionsAsCacheObjects
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public IgniteComputeEndpoint(String uri, URI remainingUri, Map<String,Object> parameters, IgniteComponent igniteComponent) throws ClassNotFoundException
ClassNotFoundException
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public org.apache.ignite.IgniteCompute createIgniteCompute()
public IgniteComputeExecutionType getExecutionType()
public void setExecutionType(IgniteComputeExecutionType executionType)
executionType
- public String getTaskName()
IgniteComputeExecutionType.EXECUTE
execution type.public void setTaskName(String taskName)
IgniteComputeExecutionType.EXECUTE
execution type.taskName
- public String getComputeName()
IgniteCompute.withName(String)
.public void setComputeName(String computeName)
IgniteCompute.withName(String)
.computeName
- public Long getTimeoutMillis()
IgniteCompute.withTimeout(long)
.public void setTimeoutMillis(Long timeoutMillis)
IgniteCompute.withTimeout(long)
.timeoutMillis
- Apache Camel