public interface SparkStructuredStreamingPipelineOptions extends SparkCommonPipelineOptions
PipelineOptions
handles Spark execution-related configurations, such as the
master address, and other user-related knobs.SparkCommonPipelineOptions.TmpCheckpointDirFactory
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
DEFAULT_MASTER_URL
Modifier and Type | Method and Description |
---|---|
boolean |
getTestMode()
Set to true to run the job in test mode.
|
void |
setTestMode(boolean testMode) |
getCheckpointDir, getEnableSparkMetricSinks, getFilesToStage, getSparkMaster, setCheckpointDir, setEnableSparkMetricSinks, setFilesToStage, setSparkMaster
isStreaming, setStreaming
getAppName, setAppName
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
@Default.Boolean(value=false) boolean getTestMode()
void setTestMode(boolean testMode)