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(oracle.odi.domain.mapping.physical.MapPhysicalDesign pd)
static java.lang.String	getCurrentMappingCheckpointId(oracle.odi.domain.mapping.physical.MapPhysicalDesign pd)
static java.util.Map	getEKMOptions(oracle.odi.domain.mapping.physical.ExecutionUnit eu)
static java.lang.String	getEKMOptionValueString(oracle.odi.domain.mapping.physical.ExecutionUnit eu, java.lang.String optionName)
static boolean	isCheckpointing(oracle.odi.domain.mapping.physical.MapPhysicalDesign pd)
static boolean	isDebugMode()
static boolean	useDataFrames(oracle.odi.domain.mapping.physical.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(oracle.odi.domain.mapping.physical.ExecutionUnit eu)

getEKMOptionValueString

public static java.lang.String getEKMOptionValueString(oracle.odi.domain.mapping.physical.ExecutionUnit eu,
                                                       java.lang.String optionName)

isCheckpointing

public static boolean isCheckpointing(oracle.odi.domain.mapping.physical.MapPhysicalDesign pd)
                               throws oracle.odi.domain.adapter.AdapterException,
                                      oracle.odi.domain.mapping.exception.MappingException,
                                      GenerationException

Throws:

oracle.odi.domain.adapter.AdapterException

oracle.odi.domain.mapping.exception.MappingException

GenerationException

useDataFrames

public static boolean useDataFrames(oracle.odi.domain.mapping.physical.MapPhysicalDesign pd)
                             throws oracle.odi.domain.adapter.AdapterException,
                                    oracle.odi.domain.mapping.exception.MappingException,
                                    GenerationException

Throws:

oracle.odi.domain.adapter.AdapterException

oracle.odi.domain.mapping.exception.MappingException

GenerationException

customImports

public static java.lang.String customImports(oracle.odi.domain.mapping.physical.MapPhysicalDesign pd)
                                      throws oracle.odi.domain.adapter.AdapterException,
                                             oracle.odi.domain.mapping.exception.MappingException,
                                             GenerationException

Throws:

oracle.odi.domain.adapter.AdapterException

oracle.odi.domain.mapping.exception.MappingException

GenerationException

isDebugMode

public static boolean isDebugMode()

getCurrentMappingCheckpointId

public static java.lang.String getCurrentMappingCheckpointId(oracle.odi.domain.mapping.physical.MapPhysicalDesign pd)