Package | Description |
---|---|
oracle.pgx.config |
This package contains all configuration-related classes of PGX.
|
Modifier and Type | Method and Description |
---|---|
SparkStreamsConfigBuilder |
SparkStreamsConfigBuilder.clear()
Clears all values from the builder
|
SparkStreamsConfigBuilder |
SparkStreamsConfigBuilder.putAll(java.util.Map<SparkStreamsConfig.Field,java.lang.Object> values)
Puts all values from the given map into this builder.
|
SparkStreamsConfigBuilder |
SparkStreamsConfigBuilder.putAll(SparkStreamsConfig config)
Puts all values from the given config into this builder
|
SparkStreamsConfigBuilder |
SparkStreamsConfigBuilder.setMaxPortRange(int maxPortRange)
PGX will open port with same or smaller than this value
|
SparkStreamsConfigBuilder |
SparkStreamsConfigBuilder.setMaxRowSizeInBytes(int maxRowSizeInBytes)
the maximum size of Spark Row in bytes, Spark loader can handle.
|
SparkStreamsConfigBuilder |
SparkStreamsConfigBuilder.setMinPortRange(int minPortRange)
PGX will open port with same or larger than this value.
|
SparkStreamsConfigBuilder |
SparkStreamsConfigBuilder.setNetworkInterface(java.lang.String networkInterface)
the name of an interface will be used spark data communication
|
Modifier and Type | Method and Description |
---|---|
static SparkStreamsConfig |
SparkStreamsConfigBuilder.buildSparkStreamsConfig(java.util.function.Consumer<SparkStreamsConfigBuilder> builderSetup)
Builds a
SparkStreamsConfig in-place |
PgxConfigBuilder |
PgxConfigBuilder.setSparkStreamsConfig(java.util.function.Consumer<SparkStreamsConfigBuilder> sparkStreamsConfigBuilderSetup)
Builds a SparkStreamsConfig in-place.
|
Constructor and Description |
---|
SparkStreamsConfigBuilder(SparkStreamsConfigBuilder builder)
Constructs a SparkStreamsConfigBuilder initialized with the values from the given builder
|
Copyright © 2016, 2019, Oracle and/or its affiliates. All Rights Reserved.