Package | Description |
---|---|
oracle.odi.mapping.generation.spark |
Modifier and Type | Class and Description |
---|---|
class |
SparkCallScriptCmd
This class is the AST representing a Spark script call command, for implementing ODI table function.
|
class |
SparkDistinctCmd
This is the AST representing a Spark distinct command.
|
class |
SparkExpressionCmd
The AST representing a Spark expression command.
|
class |
SparkFilterCmd
This is the AST representing a Spark filter command.
|
class |
SparkFlattenCmd |
class |
SparkGroupCmd
This is the AST representing a Spark group command.
|
class |
SparkHiveStoreCmd
This is the AST representing a Spark Hive store command.
|
class |
SparkHqlCmd
This is the AST representing a Spark Hql command.
|
class |
SparkInputSigCmd
The AST representing a Spark input signature command.
|
class |
SparkJoinCmd
This is the AST representing a Spark Join command.
|
class |
SparkKeyBasedLookupCmd
This is the AST representing a Spark key based lookup command
|
class |
SparkLoadCmd
This is the AST representing a Spark load command.
|
class |
SparkLookupCmd
The Spark command for Lookup data for a driving data source.
|
class |
SparkOrderByCmd
This is the AST representing a Spark order command.
|
class |
SparkOutputSigCmd
The AST representing a Spark output signature command.
|
class |
SparkPivotCmd
The Spark specific AST for pivot command.
|
class |
SparkSetCmd
This is the AST representing a Spark set command.
|
class |
SparkSplitCmd
This is the AST representing a Spark split command.
|
class |
SparkSQLCmd
This is the AST representing a Spark SQL command.
|
class |
SparkSQLStoreCmd
This is the AST representing a Spark SQL store command.
|
class |
SparkStartStreamingCmd
This Spark command class generate python code for starting and stopping streaming processing
start()
awaitTerminationOrTimeout(timeout)
|
class |
SparkStoreCmd
This is the AST representing a Spark store command.
|
class |
SparkUnpivotCmd
This is the AST representing a Spark unpivot command.
|
Modifier and Type | Method and Description |
---|---|
SparkCommand |
SparkScript.getCommand()
Get the very last command in this this spark script.
|
Modifier and Type | Method and Description |
---|---|
void |
SparkScript.setCommand(SparkCommand lastCommand)
Set the command associated with this script.
|
void |
SparkCommand.setWindowingValues(SparkCommand sparkCmd)
Provide generic place for Spark Windowing KM's to set the windowing options
|
Constructor and Description |
---|
SparkScript(TemplateUtils templateUtils,
java.util.List inputScripts,
SparkCommand lastCommand) |
SparkScript(TemplateUtils templateUtils,
java.util.List inputScripts,
SparkCommand lastCommand,
java.util.List inputScriptMasks) |