oracle.pgx.config

Class SparkStreamsConfig

java.lang.Object

oracle.pgx.config.AbstractConfig

oracle.pgx.config.AbstractSparkStreamsConfig

oracle.pgx.config.SparkStreamsConfig

@Generated(value="config_generator.py")
public class SparkStreamsConfig
extends AbstractSparkStreamsConfig

spark streams config

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkStreamsConfig.Field Fields of spark streams config

Field Summary

Fields inherited from class oracle.pgx.config.AbstractConfig

ENV_SEPARATOR, ENV_VARIABLE_PREFIX, SYSTEM_PROPERTY_PREFIX

Method Summary

Modifier and Type	Method and Description
static SparkStreamsConfig.Field[]	getConfigFields()
java.lang.Integer	getMaxPortRange() PGX will open port with same or smaller than this value
java.lang.Integer	getMaxRowSizeInBytes() the maximum size of Spark Row in bytes, Spark loader can handle.
java.lang.Integer	getMinPortRange() PGX will open port with same or larger than this value.
java.lang.String	getNetworkInterface() the name of an interface will be used spark data communication
java.util.Map<SparkStreamsConfig.Field,java.lang.Object>	getValues() Gets the parsed values.
java.util.Map<SparkStreamsConfig.Field,java.lang.Object>	getValuesWithoutDefaults() Gets the values without defaults.
boolean	hasDefaultValue(SparkStreamsConfig.Field field) Checks for default value.
boolean	isEmpty() Checks if it's empty.
static SparkStreamsConfig	parse(java.io.InputStream is, boolean strict, java.lang.String parentPath) Parses an input stream.
static SparkStreamsConfig	parse(java.util.Map<java.lang.String,java.lang.Object> raw, boolean strict, java.lang.String parentPath) Parses a raw key/value mapping.
static SparkStreamsConfig	parse(java.util.Properties props, boolean strict) Parses a properties file.
java.lang.String	toString()
java.lang.String	toString(boolean hashSensitiveData)

Methods inherited from class oracle.pgx.config.AbstractConfig

getValueFromEnvironment, getValueFromEnvironment, parseString, setSerializable

Methods inherited from class java.lang.Object

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

Method Detail

getConfigFields

public static SparkStreamsConfig.Field[] getConfigFields()

getMaxPortRange

public java.lang.Integer getMaxPortRange()

PGX will open port with same or smaller than this value

Specified by:

getMaxPortRange in class AbstractSparkStreamsConfig

getMaxRowSizeInBytes

public java.lang.Integer getMaxRowSizeInBytes()

the maximum size of Spark Row in bytes, Spark loader can handle. Because Spark is not aware of PGX runtime, it will always use the default value. Do not change this value in runtime

getMinPortRange

public java.lang.Integer getMinPortRange()

PGX will open port with same or larger than this value. If this is 0, PGX will open any available port

Specified by:

getMinPortRange in class AbstractSparkStreamsConfig

getNetworkInterface

public java.lang.String getNetworkInterface()

the name of an interface will be used spark data communication

Specified by:

getNetworkInterface in class AbstractSparkStreamsConfig

getValues

public java.util.Map<SparkStreamsConfig.Field,java.lang.Object> getValues()

Gets the parsed values.

Returns:

the parsed values

getValuesWithoutDefaults

public java.util.Map<SparkStreamsConfig.Field,java.lang.Object> getValuesWithoutDefaults()

Gets the values without defaults.

Returns:

the values without defaults

hasDefaultValue

public boolean hasDefaultValue(SparkStreamsConfig.Field field)

Checks for default value.

Parameters:

field - the field

Returns:

true, if value for given field is the default value

isEmpty

public boolean isEmpty()

Checks if it's empty.

Returns:

true, if the Map 'values' is empty.

parse

public static SparkStreamsConfig parse(java.io.InputStream is,
                                       boolean strict,
                                       java.lang.String parentPath)
                                throws java.io.IOException

Parses an input stream.

Parameters:

is - the input stream

strict - if true, parses in strict mode

parentPath - if not null, resolves relative paths against this parentPath

Returns:

the parsed graph config

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

parse

public static SparkStreamsConfig parse(java.util.Map<java.lang.String,java.lang.Object> raw,
                                       boolean strict,
                                       java.lang.String parentPath)

Parses a raw key/value mapping.

Parameters:

raw - the raw key/value mapping to parse

strict - if true, parses in strict mode

parentPath - if not null, resolves relative paths against this parentPath

Returns:

the parsed graph config

parse

public static SparkStreamsConfig parse(java.util.Properties props,
                                       boolean strict)

Parses a properties file.

Parameters:

props - the properties to parse

strict - if true, parses in strict mode

Returns:

the parsed graph config

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

toString

public java.lang.String toString(boolean hashSensitiveData)