A C D E G H I M O P R S V

A

AnnotatedRddCallback - Class in org.apache.camel.component.spark.annotations

Provides facade for working with annotated RDD callbacks i.e.

annotatedRddCallback(Object) - Static method in class org.apache.camel.component.spark.annotations.AnnotatedRddCallback

annotatedRddCallback(Object, CamelContext) - Static method in class org.apache.camel.component.spark.annotations.AnnotatedRddCallback

C

collectResults(Exchange, Object) - Method in class org.apache.camel.component.spark.DataFrameSparkProducer

collectResults(Exchange, Object) - Method in class org.apache.camel.component.spark.RddSparkProducer

ConvertingRddCallback<T> - Class in org.apache.camel.component.spark

ConvertingRddCallback(CamelContext, Class...) - Constructor for class org.apache.camel.component.spark.ConvertingRddCallback

createConsumer(Processor) - Method in class org.apache.camel.component.spark.SparkEndpoint

createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.spark.SparkComponent

createLocalSparkContext() - Static method in class org.apache.camel.component.spark.Sparks

createProducer() - Method in class org.apache.camel.component.spark.SparkEndpoint

D

DataFrameCallback<T> - Interface in org.apache.camel.component.spark

Generic block of code with parameters which can be executed against Spark Data Frames and return results.

DataFrameSparkProducer - Class in org.apache.camel.component.spark

DataFrameSparkProducer(SparkEndpoint) - Constructor for class org.apache.camel.component.spark.DataFrameSparkProducer

doOnRdd(JavaRDDLike, Object...) - Method in class org.apache.camel.component.spark.ConvertingRddCallback

doOnRdd(JavaRDDLike, Object...) - Method in class org.apache.camel.component.spark.VoidRddCallback

doStart() - Method in class org.apache.camel.component.spark.SparkEndpoint

E

EndpointType - Enum in org.apache.camel.component.spark

G

getComponent() - Method in class org.apache.camel.component.spark.SparkEndpoint

getDataFrame() - Method in class org.apache.camel.component.spark.SparkEndpoint

getDataFrameCallback() - Method in class org.apache.camel.component.spark.SparkEndpoint

getEndpoint() - Method in class org.apache.camel.component.spark.DataFrameSparkProducer

getEndpoint() - Method in class org.apache.camel.component.spark.HiveSparkProducer

getEndpoint() - Method in class org.apache.camel.component.spark.RddSparkProducer

getEndpointType() - Method in class org.apache.camel.component.spark.SparkEndpoint

getRdd() - Method in class org.apache.camel.component.spark.SparkComponent

getRdd() - Method in class org.apache.camel.component.spark.SparkEndpoint

getRddCallback() - Method in class org.apache.camel.component.spark.SparkComponent

getRddCallback() - Method in class org.apache.camel.component.spark.SparkEndpoint

H

HiveSparkProducer - Class in org.apache.camel.component.spark

HiveSparkProducer(SparkEndpoint) - Constructor for class org.apache.camel.component.spark.HiveSparkProducer

I

isCollect() - Method in class org.apache.camel.component.spark.SparkEndpoint

isSingleton() - Method in class org.apache.camel.component.spark.SparkEndpoint

M

mongoRdd(JavaSparkContext, String, long, String, String) - Static method in class org.apache.camel.component.spark.SparkMongos

O

onDataFrame(DataFrame, Object...) - Method in interface org.apache.camel.component.spark.DataFrameCallback

onRdd(JavaRDDLike, Object...) - Method in class org.apache.camel.component.spark.ConvertingRddCallback

onRdd(JavaRDDLike, Object...) - Method in interface org.apache.camel.component.spark.RddCallback

onRdd(JavaRDDLike, Object...) - Method in class org.apache.camel.component.spark.VoidRddCallback

org.apache.camel.component.spark - package org.apache.camel.component.spark

org.apache.camel.component.spark.annotations - package org.apache.camel.component.spark.annotations

P

process(Exchange) - Method in class org.apache.camel.component.spark.DataFrameSparkProducer

process(Exchange) - Method in class org.apache.camel.component.spark.HiveSparkProducer

process(Exchange) - Method in class org.apache.camel.component.spark.RddSparkProducer

R

RddCallback - Annotation Type in org.apache.camel.component.spark.annotations

RddCallback<T> - Interface in org.apache.camel.component.spark

Generic block of code with parameters which can be executed against RDD and return results.

RddSparkProducer - Class in org.apache.camel.component.spark

RddSparkProducer(SparkEndpoint) - Constructor for class org.apache.camel.component.spark.RddSparkProducer

resolveDataFrame(Exchange) - Method in class org.apache.camel.component.spark.DataFrameSparkProducer

resolveDataFrameCallback(Exchange) - Method in class org.apache.camel.component.spark.DataFrameSparkProducer

resolveHiveContext() - Method in class org.apache.camel.component.spark.HiveSparkProducer

resolveRdd(Exchange) - Method in class org.apache.camel.component.spark.RddSparkProducer

resolveRddCallback(Exchange) - Method in class org.apache.camel.component.spark.RddSparkProducer

S

setCollect(boolean) - Method in class org.apache.camel.component.spark.SparkEndpoint

Indicates if results should be collected or counted.

setDataFrame(DataFrame) - Method in class org.apache.camel.component.spark.SparkEndpoint

DataFrame to compute against.

setDataFrameCallback(DataFrameCallback) - Method in class org.apache.camel.component.spark.SparkEndpoint

Function performing action against an DataFrame.

setEndpointType(EndpointType) - Method in class org.apache.camel.component.spark.SparkEndpoint

Type of the endpoint (rdd, dataframe, hive).

setRdd(JavaRDDLike) - Method in class org.apache.camel.component.spark.SparkComponent

RDD to compute against.

setRdd(JavaRDDLike) - Method in class org.apache.camel.component.spark.SparkEndpoint

RDD to compute against.

setRddCallback(RddCallback) - Method in class org.apache.camel.component.spark.SparkComponent

Function performing action against an RDD.

setRddCallback(RddCallback) - Method in class org.apache.camel.component.spark.SparkEndpoint

Function performing action against an RDD.

SPARK_DATAFRAME_CALLBACK_HEADER - Static variable in class org.apache.camel.component.spark.SparkConstants

SPARK_DATAFRAME_HEADER - Static variable in class org.apache.camel.component.spark.SparkConstants

SPARK_RDD_CALLBACK_HEADER - Static variable in class org.apache.camel.component.spark.SparkConstants

SPARK_RDD_HEADER - Static variable in class org.apache.camel.component.spark.SparkConstants

SparkComponent - Class in org.apache.camel.component.spark

SparkComponent() - Constructor for class org.apache.camel.component.spark.SparkComponent

SparkConstants - Class in org.apache.camel.component.spark

SparkEndpoint - Class in org.apache.camel.component.spark

The spark component can be used to send RDD or DataFrame jobs to Apache Spark cluster.

SparkEndpoint(String, SparkComponent, EndpointType) - Constructor for class org.apache.camel.component.spark.SparkEndpoint

SparkMongos - Class in org.apache.camel.component.spark

Sparks - Class in org.apache.camel.component.spark

V

valueOf(String) - Static method in enum org.apache.camel.component.spark.EndpointType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.camel.component.spark.EndpointType

Returns an array containing the constants of this enum type, in the order they are declared.

VoidRddCallback - Class in org.apache.camel.component.spark

VoidRddCallback() - Constructor for class org.apache.camel.component.spark.VoidRddCallback

A C D E G H I M O P R S V