Package | Description |
---|---|
org.mule.modules.sparksql | |
org.mule.modules.sparksql.config | |
org.mule.modules.sparksql.util |
Modifier and Type | Method and Description |
---|---|
void |
SparkSqlConnector.addFileDataProperties(List<FileDataProperties> listFileDataProps)
Dynamically add new datasources from Hadoop HDFS files
|
Modifier and Type | Method and Description |
---|---|
List<FileDataProperties> |
ConnectorConfig.getListFileDataProps() |
Modifier and Type | Method and Description |
---|---|
void |
ConnectorConfig.addCsvAndAvroJars(org.apache.spark.SparkContext sc,
FileDataProperties fileDataProperties) |
void |
ConnectorConfig.connectDataSources(FileDataProperties fileDataProperties)
Connect all defined data sources to the sql context
|
protected boolean |
ConnectorConfig.dataSourceAvro(FileDataProperties fileDataProperties) |
protected boolean |
ConnectorConfig.dataSourceCsv(FileDataProperties fileDataProperties) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectorConfig.setListFileDataProps(List<FileDataProperties> listFileDataProps) |
Modifier and Type | Method and Description |
---|---|
static void |
Validation.validateFileDataProperties(FileDataProperties fileProperties) |
protected static void |
Validation.validateFileDataSeparators(FileDataProperties fileProperties) |
Copyright © 2010–2017. All rights reserved.