Package cz.o2.proxima.beam.core

Interface ProximaPipelineOptions

All Superinterfaces:

org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions

public interface ProximaPipelineOptions
extends org.apache.beam.sdk.options.PipelineOptions

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ProximaPipelineOptions.Registrar

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

org.apache.beam.sdk.options.PipelineOptions.AtomicLongFactory, org.apache.beam.sdk.options.PipelineOptions.CheckEnabled, org.apache.beam.sdk.options.PipelineOptions.DirectRunner, org.apache.beam.sdk.options.PipelineOptions.JobNameFactory, org.apache.beam.sdk.options.PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method	Description
boolean	getEnforceStableInputForRemoteConsumer()	Enforce stable input for remote consumers in console
boolean	getPreserveUDFJar()	false to preserve UDF jar on exit.
long	getProximaIOWriteFinalizeTimeoutMs()
long	getStartBatchReadDelayMs()	Set delay for BatchLogRead in ms.
@Nullable java.lang.String	getUdfJarDirPath()	Set directory where to store generated UDF jar(s).
void	setEnforceStableInputForRemoteConsumer(boolean enforce)
void	setPreserveUDFJar(boolean preserve)
void	setProximaIOWriteFinalizeTimeoutMs(long timeout)
void	setStartBatchReadDelayMs(long readDelayMs)
void	setUdfJarDirPath(java.lang.String path)

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Method Detail

getPreserveUDFJar

@Boolean(true)
boolean getPreserveUDFJar()

false to preserve UDF jar on exit.

setPreserveUDFJar

void setPreserveUDFJar(boolean preserve)

getUdfJarDirPath

@Nullable java.lang.String getUdfJarDirPath()

Set directory where to store generated UDF jar(s).

setUdfJarDirPath

void setUdfJarDirPath(java.lang.String path)

getStartBatchReadDelayMs

@Long(0L)
long getStartBatchReadDelayMs()

Set delay for BatchLogRead in ms.

setStartBatchReadDelayMs

void setStartBatchReadDelayMs(long readDelayMs)

getEnforceStableInputForRemoteConsumer

@Boolean(true)
boolean getEnforceStableInputForRemoteConsumer()

Enforce stable input for remote consumers in console

setEnforceStableInputForRemoteConsumer

void setEnforceStableInputForRemoteConsumer(boolean enforce)

getProximaIOWriteFinalizeTimeoutMs

@Long(30000L)
long getProximaIOWriteFinalizeTimeoutMs()

setProximaIOWriteFinalizeTimeoutMs

void setProximaIOWriteFinalizeTimeoutMs(long timeout)