com.mozilla.secops

Interface InputOptions

All Superinterfaces:

org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions, org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.io.gcp.pubsub.PubsubOptions, org.apache.beam.sdk.options.StreamingOptions

All Known Subinterfaces:

Amo.AmoOptions, AuthProfile.AuthProfileOptions, AwsBehavior.AwsBehaviorOptions, Customs.CustomsOptions, ETDTransforms.Options, GatekeeperPipeline.GatekeeperOptions, GuardDutyTransforms.Options, HTTPRequest.HTTPRequestOptions, IOOptions, Pioneer.PioneerOptions, PostProcessing.PostProcessingOptions, StreamWriter.StreamWriterOptions, Workshop.WorkshopOptions

public interface InputOptions
extends org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.io.gcp.pubsub.PubsubOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions

Standard input options for pipelines.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

org.apache.beam.sdk.extensions.gcp.options.GcpOptions.DefaultProjectFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.EnableStreamingEngineFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer

Field Summary

Fields inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

STREAMING_ENGINE_EXPERIMENT, WINDMILL_SERVICE_EXPERIMENT

Method Summary

Modifier and Type	Method and Description
Boolean	getDeferGeoIpResolution()
Boolean	getDisableCloudwatchStrip()
Boolean	getDisableMozlogStrip()
Integer	getGenerateConfigurationTicksInterval()
Long	getGenerateConfigurationTicksMaximum()
String	getIdentityManagerPath()
String[]	getInputFile()
String	getInputIprepd()
String[]	getInputKinesis()
String[]	getInputPubsub()
Integer	getMaxAllowableTimestampDifference()
String	getMaxmindAccountId()
String	getMaxmindCityDbPath()
String	getMaxmindIspDbPath()
String	getMaxmindLicenseKey()
String	getParserFastMatcher()
String	getPipelineVersion()
String[]	getStackdriverLabelFilters()
String	getStackdriverProjectFilter()
Boolean	getUseEventTimestamp()
Boolean	getUseProxyXff()
Boolean	getUseXffAsRemote()
String	getXffAddressSelector()
void	setDeferGeoIpResolution(Boolean value)
void	setDisableCloudwatchStrip(Boolean value)
void	setDisableMozlogStrip(Boolean value)
void	setGenerateConfigurationTicksInterval(Integer value)
void	setGenerateConfigurationTicksMaximum(Long value)
void	setIdentityManagerPath(String value)
void	setInputFile(String[] value)
void	setInputIprepd(String value)
void	setInputKinesis(String[] value)
void	setInputPubsub(String[] value)
void	setMaxAllowableTimestampDifference(Integer value)
void	setMaxmindAccountId(String value)
void	setMaxmindCityDbPath(String value)
void	setMaxmindIspDbPath(String value)
void	setMaxmindLicenseKey(String value)
void	setParserFastMatcher(String value)
void	setPipelineVersion(String value)
void	setStackdriverLabelFilters(String[] value)
void	setStackdriverProjectFilter(String value)
void	setUseEventTimestamp(Boolean value)
void	setUseProxyXff(Boolean proxyXff)
void	setUseXffAsRemote(Boolean xffAsRemote)
void	setXffAddressSelector(String value)

Methods inherited from interface org.apache.beam.sdk.io.gcp.pubsub.PubsubOptions

getPubsubRootUrl, setPubsubRootUrl, targetForRootUrl

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpTempLocation, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpTempLocation, setProject, setWorkerRegion, setWorkerZone, setZone

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

getGoogleApiTrace, setGoogleApiTrace

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

isStreaming, setStreaming

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

getAppName, setAppName

Method Detail

getPipelineVersion

@Default.String(value="0.19.2")
String getPipelineVersion()

setPipelineVersion

void setPipelineVersion(String value)

getUseEventTimestamp

@Default.Boolean(value=false)
Boolean getUseEventTimestamp()

setUseEventTimestamp

void setUseEventTimestamp(Boolean value)

getStackdriverProjectFilter

String getStackdriverProjectFilter()

setStackdriverProjectFilter

void setStackdriverProjectFilter(String value)

getStackdriverLabelFilters

String[] getStackdriverLabelFilters()

setStackdriverLabelFilters

void setStackdriverLabelFilters(String[] value)

getDisableMozlogStrip

@Default.Boolean(value=false)
Boolean getDisableMozlogStrip()

setDisableMozlogStrip

void setDisableMozlogStrip(Boolean value)

getDisableCloudwatchStrip

@Default.Boolean(value=false)
Boolean getDisableCloudwatchStrip()

setDisableCloudwatchStrip

void setDisableCloudwatchStrip(Boolean value)

getInputPubsub

String[] getInputPubsub()

setInputPubsub

void setInputPubsub(String[] value)

getInputFile

String[] getInputFile()

setInputFile

void setInputFile(String[] value)

getInputKinesis

String[] getInputKinesis()

setInputKinesis

void setInputKinesis(String[] value)

getMaxmindCityDbPath

String getMaxmindCityDbPath()

setMaxmindCityDbPath

void setMaxmindCityDbPath(String value)

getMaxmindIspDbPath

String getMaxmindIspDbPath()

setMaxmindIspDbPath

void setMaxmindIspDbPath(String value)

getDeferGeoIpResolution

@Default.Boolean(value=false)
Boolean getDeferGeoIpResolution()

setDeferGeoIpResolution

void setDeferGeoIpResolution(Boolean value)

getXffAddressSelector

String getXffAddressSelector()

setXffAddressSelector

void setXffAddressSelector(String value)

getIdentityManagerPath

String getIdentityManagerPath()

setIdentityManagerPath

void setIdentityManagerPath(String value)

getParserFastMatcher

String getParserFastMatcher()

setParserFastMatcher

void setParserFastMatcher(String value)

getGenerateConfigurationTicksInterval

@Default.Integer(value=0)
Integer getGenerateConfigurationTicksInterval()

setGenerateConfigurationTicksInterval

void setGenerateConfigurationTicksInterval(Integer value)

getGenerateConfigurationTicksMaximum

@Default.Long(value=-1L)
Long getGenerateConfigurationTicksMaximum()

setGenerateConfigurationTicksMaximum

void setGenerateConfigurationTicksMaximum(Long value)

getInputIprepd

String getInputIprepd()

setInputIprepd

void setInputIprepd(String value)

getMaxAllowableTimestampDifference

Integer getMaxAllowableTimestampDifference()

setMaxAllowableTimestampDifference

void setMaxAllowableTimestampDifference(Integer value)

getMaxmindAccountId

String getMaxmindAccountId()

setMaxmindAccountId

void setMaxmindAccountId(String value)

getMaxmindLicenseKey

String getMaxmindLicenseKey()

setMaxmindLicenseKey

void setMaxmindLicenseKey(String value)

getUseXffAsRemote

@Default.Boolean(value=false)
Boolean getUseXffAsRemote()

setUseXffAsRemote

void setUseXffAsRemote(Boolean xffAsRemote)

getUseProxyXff

@Default.Boolean(value=false)
Boolean getUseProxyXff()

setUseProxyXff

void setUseProxyXff(Boolean proxyXff)