default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.AdvancedSparkEndpointBuilder.basic() |
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.collect(boolean collect) |
Indicates if results should be collected or counted.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.collect(String collect) |
Indicates if results should be collected or counted.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.dataFrame(Object dataFrame) |
DataFrame to compute against.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.dataFrame(String dataFrame) |
DataFrame to compute against.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.dataFrameCallback(Object dataFrameCallback) |
Function performing action against an DataFrame.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.dataFrameCallback(String dataFrameCallback) |
Function performing action against an DataFrame.
|
static SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.endpointBuilder(String componentName,
String path) |
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.rdd(Object rdd) |
RDD to compute against.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.rdd(String rdd) |
RDD to compute against.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.rddCallback(Object rddCallback) |
Function performing action against an RDD.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkEndpointBuilder.rddCallback(String rddCallback) |
Function performing action against an RDD.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkBuilders.spark(String path) |
Spark (camel-spark)
Send RDD or DataFrame jobs to Apache Spark clusters.
|
default SparkEndpointBuilderFactory.SparkEndpointBuilder |
SparkEndpointBuilderFactory.SparkBuilders.spark(String componentName,
String path) |
Spark (camel-spark)
Send RDD or DataFrame jobs to Apache Spark clusters.
|