public interface SparkPortableStreamingPipelineOptions extends SparkPipelineOptions, PortablePipelineOptions
SparkCommonPipelineOptions.StorageLevelFactory, SparkCommonPipelineOptions.TmpCheckpointDirFactory
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
DEFAULT_MASTER_URL
Modifier and Type | Method and Description |
---|---|
java.lang.Long |
getStreamingTimeoutMs() |
void |
setStreamingTimeoutMs(java.lang.Long value) |
getBatchIntervalMillis, getBundleSize, getCheckpointDurationMillis, getMaxRecordsPerBatch, getMinReadTimeMillis, getReadTimePercentage, getUsesProvidedSparkContext, isCacheDisabled, setBatchIntervalMillis, setBundleSize, setCacheDisabled, setCheckpointDurationMillis, setMaxRecordsPerBatch, setMinReadTimeMillis, setReadTimePercentage, setUsesProvidedSparkContext
getCheckpointDir, getEnableSparkMetricSinks, getSparkMaster, getStorageLevel, prepareFilesToStage, setCheckpointDir, setEnableSparkMetricSinks, setSparkMaster, setStorageLevel
isStreaming, setStreaming
getAppName, setAppName
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
getFilesToStage, setFilesToStage
getDefaultEnvironmentConfig, getDefaultEnvironmentType, getEnableHeapDumps, getEnvironmentCacheMillis, getEnvironmentExpirationMillis, getEnvironmentOption, getEnvironmentOptions, getJobEndpoint, getJobServerTimeout, getLoadBalanceBundles, getOutputExecutablePath, getSdkWorkerParallelism, setDefaultEnvironmentConfig, setDefaultEnvironmentType, setEnableHeapDumps, setEnvironmentCacheMillis, setEnvironmentExpirationMillis, setEnvironmentOptions, setJobEndpoint, setJobServerTimeout, setLoadBalanceBundles, setOutputExecutablePath, setSdkWorkerParallelism
@Default.Long(value=-1L) java.lang.Long getStreamingTimeoutMs()
void setStreamingTimeoutMs(java.lang.Long value)