oracle.odi.mapping.generation.spark

Class SparkUtils

java.lang.Object

oracle.odi.mapping.generation.spark.SparkUtils

public class SparkUtils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CUSTOM_IMPORTS
static java.lang.String	SPARK_DEFAULT_CONTEXT_NAME
static java.lang.String	SPARK_DEFAULT_CONTEXT_TYPE
static java.lang.String	SPARK_PROPERTY_DEFAULT_VALUE_TAG
static java.lang.String	SPARK_PROPERTY_PREFIX
static java.lang.String	SPARK_PROPERTY_SERVER_INSTANCE_NAME
static java.lang.String	SPARK_WORK_DIR
static java.lang.String	STREAMING_CHECKPOINT_ID
static java.lang.String	STREAMING_MODE
static java.lang.String	STREAMING_PROPERTY_BATCH_DURATION
static java.lang.String	STREAMING_PROPERTY_CHECKPOINTING
static java.lang.String	STREAMING_PROPERTY_STOP_GRACEFULLY
static java.lang.String	STREAMING_PROPERTY_TIMEOUT
static java.lang.String	USE_DATAFRAMES

Constructor Summary

Constructors

Constructor and Description
SparkUtils()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	customImports(MapPhysicalDesign pd)
static java.lang.String	getCurrentMappingCheckpointId(MapPhysicalDesign pd)
static java.util.Map	getEKMOptions(ExecutionUnit eu)
static java.lang.String	getEKMOptionValueString(ExecutionUnit eu, java.lang.String optionName)
static boolean	isCheckpointing(MapPhysicalDesign pd)
static boolean	isDebugMode()
static boolean	useDataFrames(MapPhysicalDesign pd)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SPARK_PROPERTY_PREFIX

public static final java.lang.String SPARK_PROPERTY_PREFIX

See Also:

Constant Field Values

SPARK_WORK_DIR

public static final java.lang.String SPARK_WORK_DIR

See Also:

Constant Field Values

SPARK_PROPERTY_SERVER_INSTANCE_NAME

public static final java.lang.String SPARK_PROPERTY_SERVER_INSTANCE_NAME

See Also:

Constant Field Values

SPARK_DEFAULT_CONTEXT_TYPE

public static final java.lang.String SPARK_DEFAULT_CONTEXT_TYPE

See Also:

Constant Field Values

SPARK_DEFAULT_CONTEXT_NAME

public static final java.lang.String SPARK_DEFAULT_CONTEXT_NAME

See Also:

Constant Field Values

SPARK_PROPERTY_DEFAULT_VALUE_TAG

public static final java.lang.String SPARK_PROPERTY_DEFAULT_VALUE_TAG

See Also:

Constant Field Values

USE_DATAFRAMES

public static final java.lang.String USE_DATAFRAMES

See Also:

Constant Field Values

CUSTOM_IMPORTS

public static final java.lang.String CUSTOM_IMPORTS

See Also:

Constant Field Values

STREAMING_MODE

public static final java.lang.String STREAMING_MODE

See Also:

Constant Field Values

STREAMING_PROPERTY_TIMEOUT

public static final java.lang.String STREAMING_PROPERTY_TIMEOUT

See Also:

Constant Field Values

STREAMING_PROPERTY_BATCH_DURATION

public static final java.lang.String STREAMING_PROPERTY_BATCH_DURATION

See Also:

Constant Field Values

STREAMING_PROPERTY_CHECKPOINTING

public static final java.lang.String STREAMING_PROPERTY_CHECKPOINTING

See Also:

Constant Field Values

STREAMING_PROPERTY_STOP_GRACEFULLY

public static final java.lang.String STREAMING_PROPERTY_STOP_GRACEFULLY

See Also:

Constant Field Values

STREAMING_CHECKPOINT_ID

public static final java.lang.String STREAMING_CHECKPOINT_ID

See Also:

Constant Field Values

Constructor Detail

SparkUtils

public SparkUtils()

Method Detail

getEKMOptions

public static java.util.Map getEKMOptions(ExecutionUnit eu)

getEKMOptionValueString

public static java.lang.String getEKMOptionValueString(ExecutionUnit eu,
                                                       java.lang.String optionName)

isCheckpointing

public static boolean isCheckpointing(MapPhysicalDesign pd)
                               throws AdapterException,
                                      MappingException,
                                      GenerationException

Throws:

AdapterException

MappingException

GenerationException

useDataFrames

public static boolean useDataFrames(MapPhysicalDesign pd)
                             throws AdapterException,
                                    MappingException,
                                    GenerationException

Throws:

AdapterException

MappingException

GenerationException

customImports

public static java.lang.String customImports(MapPhysicalDesign pd)
                                      throws AdapterException,
                                             MappingException,
                                             GenerationException

Throws:

AdapterException

MappingException

GenerationException

isDebugMode

public static boolean isDebugMode()

getCurrentMappingCheckpointId

public static java.lang.String getCurrentMappingCheckpointId(MapPhysicalDesign pd)