Package | Description |
---|---|
org.apache.camel.component.spark | |
org.apache.camel.component.spark.annotations |
Modifier and Type | Class and Description |
---|---|
class |
ConvertingRddCallback<T> |
class |
VoidRddCallback |
Modifier and Type | Method and Description |
---|---|
RddCallback |
SparkComponent.getRddCallback() |
RddCallback |
SparkEndpoint.getRddCallback() |
protected RddCallback |
RddSparkProducer.resolveRddCallback(org.apache.camel.Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
void |
SparkComponent.setRddCallback(RddCallback rddCallback)
Function performing action against an RDD.
|
void |
SparkEndpoint.setRddCallback(RddCallback rddCallback)
Function performing action against an RDD.
|
Modifier and Type | Method and Description |
---|---|
static RddCallback |
AnnotatedRddCallback.annotatedRddCallback(Object objectWithCallback) |
static RddCallback |
AnnotatedRddCallback.annotatedRddCallback(Object objectWithCallback,
org.apache.camel.CamelContext camelContext) |
Apache Camel