JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Camel :: Apache Spark 2.23.2.fuse-7_10_1-00008-redhat-00001
Prev
Next
Frames
No Frames
All Classes
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(Dataset<Row>, 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(Dataset<Row>)
- 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
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Camel :: Apache Spark 2.23.2.fuse-7_10_1-00008-redhat-00001
Prev
Next
Frames
No Frames
All Classes
Apache Camel