oracle.pgx.config

Class SparkStreamsConfigBuilder

java.lang.Object

oracle.pgx.config.SparkStreamsConfigBuilder

@Generated(value={"common/src/templates/ConfigBuilder.stg","common/common.gradle"})
public final class SparkStreamsConfigBuilder
extends java.lang.Object

Builder for SparkStreamsConfig.

Constructor Summary

Constructors

Constructor and Description
SparkStreamsConfigBuilder() Constructs an empty SparkStreamsConfigBuilder
SparkStreamsConfigBuilder(java.util.Map<SparkStreamsConfig.Field,java.lang.Object> values) Constructs a SparkStreamsConfigBuilder initialized with the values from the given map
SparkStreamsConfigBuilder(SparkStreamsConfig config) Constructs a SparkStreamsConfigBuilder initialized with the values from the given config
SparkStreamsConfigBuilder(SparkStreamsConfigBuilder builder) Constructs a SparkStreamsConfigBuilder initialized with the values from the given builder

Method Summary

Modifier and Type	Method and Description
SparkStreamsConfig	build() Builds the SparkStreamsConfig with a parentPath of null.
SparkStreamsConfig	build(java.lang.String parentPath) Builds the SparkStreamsConfig.
static SparkStreamsConfig	buildSparkStreamsConfig(java.util.function.Consumer<SparkStreamsConfigBuilder> builderSetup) Builds a SparkStreamsConfig in-place
SparkStreamsConfigBuilder	clear() Clears all values from the builder
java.util.Map<SparkStreamsConfig.Field,java.lang.Object>	getValues()
SparkStreamsConfigBuilder	putAll(java.util.Map<SparkStreamsConfig.Field,java.lang.Object> values) Puts all values from the given map into this builder.
SparkStreamsConfigBuilder	putAll(SparkStreamsConfig config) Puts all values from the given config into this builder
SparkStreamsConfigBuilder	setMaxPortRange(int maxPortRange) PGX will open port with same or smaller than this value
SparkStreamsConfigBuilder	setMaxRowSizeInBytes(int maxRowSizeInBytes) the maximum size of Spark Row in bytes, Spark loader can handle.
SparkStreamsConfigBuilder	setMinPortRange(int minPortRange) PGX will open port with same or larger than this value.
SparkStreamsConfigBuilder	setNetworkInterface(java.lang.String networkInterface) the name of an interface will be used spark data communication
java.io.InputStream	toInputStream()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkStreamsConfigBuilder

public SparkStreamsConfigBuilder()

Constructs an empty SparkStreamsConfigBuilder

SparkStreamsConfigBuilder

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

Constructs a SparkStreamsConfigBuilder initialized with the values from the given map

Parameters:

values - a map containing configuration values

SparkStreamsConfigBuilder

public SparkStreamsConfigBuilder(SparkStreamsConfig config)

Constructs a SparkStreamsConfigBuilder initialized with the values from the given config

Parameters:

config - the configuration to take the values from

SparkStreamsConfigBuilder

public SparkStreamsConfigBuilder(SparkStreamsConfigBuilder builder)

Constructs a SparkStreamsConfigBuilder initialized with the values from the given builder

Parameters:

builder - the builder to take the values from

Method Detail

build

public SparkStreamsConfig build()

Builds the SparkStreamsConfig with a parentPath of null.

Returns:

An instance of SparkStreamsConfig

See Also:

build(String)

build

public SparkStreamsConfig build(java.lang.String parentPath)

Builds the SparkStreamsConfig.

Parameters:

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

Returns:

an instance of SparkStreamsConfig

buildSparkStreamsConfig

public static SparkStreamsConfig buildSparkStreamsConfig(java.util.function.Consumer<SparkStreamsConfigBuilder> builderSetup)

Builds a SparkStreamsConfig in-place

Parameters:

builderSetup - a consumer to setup a newly created SparkStreamsConfig

clear

public SparkStreamsConfigBuilder clear()

Clears all values from the builder

getValues

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

Returns:

the raw config values

putAll

public SparkStreamsConfigBuilder putAll(java.util.Map<SparkStreamsConfig.Field,java.lang.Object> values)

Puts all values from the given map into this builder.

Parameters:

values - the values to put in the builder

putAll

public SparkStreamsConfigBuilder putAll(SparkStreamsConfig config)

Puts all values from the given config into this builder

Parameters:

config - the config to take the values from

setMaxPortRange

public SparkStreamsConfigBuilder setMaxPortRange(int maxPortRange)

PGX will open port with same or smaller than this value

setMaxRowSizeInBytes

public SparkStreamsConfigBuilder setMaxRowSizeInBytes(int maxRowSizeInBytes)

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

setMinPortRange

public SparkStreamsConfigBuilder setMinPortRange(int minPortRange)

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

setNetworkInterface

public SparkStreamsConfigBuilder setNetworkInterface(java.lang.String networkInterface)

the name of an interface will be used spark data communication

toInputStream

public java.io.InputStream toInputStream()

Returns:

an InputStream representing the config

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object