@UriEndpoint(scheme="spark",
title="Apache Spark",
syntax="spark:endpointType",
producerOnly=true,
label="bigdata,iot")
public class SparkEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
SparkEndpoint(String endpointUri,
SparkComponent component,
EndpointType endpointType) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
SparkComponent |
getComponent() |
org.apache.spark.sql.DataFrame |
getDataFrame() |
DataFrameCallback |
getDataFrameCallback() |
EndpointType |
getEndpointType() |
org.apache.spark.api.java.JavaRDDLike |
getRdd() |
RddCallback |
getRddCallback() |
boolean |
isCollect() |
boolean |
isSingleton() |
void |
setCollect(boolean collect)
Indicates if results should be collected or counted.
|
void |
setDataFrame(org.apache.spark.sql.DataFrame dataFrame)
DataFrame to compute against.
|
void |
setDataFrameCallback(DataFrameCallback dataFrameCallback)
Function performing action against an DataFrame.
|
void |
setEndpointType(EndpointType endpointType)
Type of the endpoint (rdd, dataframe, hive).
|
void |
setRdd(org.apache.spark.api.java.JavaRDDLike rdd)
RDD to compute against.
|
void |
setRddCallback(RddCallback rddCallback)
Function performing action against an RDD.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, 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 SparkEndpoint(String endpointUri, SparkComponent component, EndpointType endpointType)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public SparkComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public EndpointType getEndpointType()
public void setEndpointType(EndpointType endpointType)
public org.apache.spark.api.java.JavaRDDLike getRdd()
public void setRdd(org.apache.spark.api.java.JavaRDDLike rdd)
public RddCallback getRddCallback()
public void setRddCallback(RddCallback rddCallback)
public org.apache.spark.sql.DataFrame getDataFrame()
public void setDataFrame(org.apache.spark.sql.DataFrame dataFrame)
public DataFrameCallback getDataFrameCallback()
public void setDataFrameCallback(DataFrameCallback dataFrameCallback)
public boolean isCollect()
public void setCollect(boolean collect)
Apache Camel