in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java [228:353]
public void overrideFromOptions(NexmarkOptions options) {
if (options.getDebug() != null) {
debug = options.getDebug();
}
if (options.getQuery() != null) {
query = NexmarkQueryName.fromId(options.getQuery());
}
if (options.getSourceType() != null) {
sourceType = options.getSourceType();
}
if (options.getGenerateEventFilePathPrefix() != null) {
generateEventFilePathPrefix = options.getGenerateEventFilePathPrefix();
}
if (options.getSinkType() != null) {
sinkType = options.getSinkType();
}
if (options.getExportSummaryToBigQuery() != null) {
exportSummaryToBigQuery = options.getExportSummaryToBigQuery();
}
if (options.getPubSubMode() != null) {
pubSubMode = options.getPubSubMode();
}
if (options.getPubsubMessageSerializationMethod() != null) {
pubsubMessageSerializationMethod = options.getPubsubMessageSerializationMethod();
}
if (options.getNumEvents() != null) {
numEvents = options.getNumEvents();
}
if (options.getNumEventGenerators() != null) {
numEventGenerators = options.getNumEventGenerators();
}
if (options.getRateShape() != null) {
rateShape = options.getRateShape();
}
if (options.getFirstEventRate() != null) {
firstEventRate = options.getFirstEventRate();
}
if (options.getNextEventRate() != null) {
nextEventRate = options.getNextEventRate();
}
if (options.getRateUnit() != null) {
rateUnit = options.getRateUnit();
}
if (options.getRatePeriodSec() != null) {
ratePeriodSec = options.getRatePeriodSec();
}
if (options.getPreloadSeconds() != null) {
preloadSeconds = options.getPreloadSeconds();
}
if (options.getStreamTimeout() != null) {
streamTimeout = options.getStreamTimeout();
}
if (options.getIsRateLimited() != null) {
isRateLimited = options.getIsRateLimited();
}
if (options.getUseWallclockEventTime() != null) {
useWallclockEventTime = options.getUseWallclockEventTime();
}
if (options.getAvgPersonByteSize() != null) {
avgPersonByteSize = options.getAvgPersonByteSize();
}
if (options.getAvgAuctionByteSize() != null) {
avgAuctionByteSize = options.getAvgAuctionByteSize();
}
if (options.getAvgBidByteSize() != null) {
avgBidByteSize = options.getAvgBidByteSize();
}
if (options.getHotAuctionRatio() != null) {
hotAuctionRatio = options.getHotAuctionRatio();
}
if (options.getHotSellersRatio() != null) {
hotSellersRatio = options.getHotSellersRatio();
}
if (options.getHotBiddersRatio() != null) {
hotBiddersRatio = options.getHotBiddersRatio();
}
if (options.getWindowSizeSec() != null) {
windowSizeSec = options.getWindowSizeSec();
}
if (options.getWindowPeriodSec() != null) {
windowPeriodSec = options.getWindowPeriodSec();
}
if (options.getWatermarkHoldbackSec() != null) {
watermarkHoldbackSec = options.getWatermarkHoldbackSec();
}
if (options.getNumInFlightAuctions() != null) {
numInFlightAuctions = options.getNumInFlightAuctions();
}
if (options.getNumActivePeople() != null) {
numActivePeople = options.getNumActivePeople();
}
if (options.getCoderStrategy() != null) {
coderStrategy = options.getCoderStrategy();
}
if (options.getCpuDelayMs() != null) {
cpuDelayMs = options.getCpuDelayMs();
}
if (options.getDiskBusyBytes() != null) {
diskBusyBytes = options.getDiskBusyBytes();
}
if (options.getAuctionSkip() != null) {
auctionSkip = options.getAuctionSkip();
}
if (options.getFanout() != null) {
fanout = options.getFanout();
}
if (options.getMaxAuctionsWaitingTime() != null) {
maxAuctionsWaitingTime = options.getMaxAuctionsWaitingTime();
}
if (options.getOccasionalDelaySec() != null) {
occasionalDelaySec = options.getOccasionalDelaySec();
}
if (options.getProbDelayedEvent() != null) {
probDelayedEvent = options.getProbDelayedEvent();
}
if (options.getMaxLogEvents() != null) {
maxLogEvents = options.getMaxLogEvents();
}
if (options.getUsePubsubPublishTime() != null) {
usePubsubPublishTime = options.getUsePubsubPublishTime();
}
if (options.getOutOfOrderGroupSize() != null) {
outOfOrderGroupSize = options.getOutOfOrderGroupSize();
}
}