org.apache.beam.sdk.io.elasticsearch

Interface ElasticsearchIOITCommon.ElasticsearchPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions, TestPipelineOptions

Enclosing class:

ElasticsearchIOITCommon

public static interface ElasticsearchIOITCommon.ElasticsearchPipelineOptions
extends TestPipelineOptions

Pipeline options for elasticsearch tests.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions

TestPipelineOptions.AlwaysPassMatcher, TestPipelineOptions.AlwaysPassMatcherFactory

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

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
java.lang.Integer	getElasticsearchHttpPort()
java.lang.String	getElasticsearchServer()
void	setElasticsearchHttpPort(java.lang.Integer value)
void	setElasticsearchServer(java.lang.String value)

Methods inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions

getOnCreateMatcher, getOnSuccessMatcher, getTempRoot, getTestTimeoutSeconds, isBlockOnRun, setBlockOnRun, setOnCreateMatcher, setOnSuccessMatcher, setTempRoot, setTestTimeoutSeconds

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

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

populateDisplayData

Method Detail

getElasticsearchServer

@Default.String(value="elasticsearch-server-name")
java.lang.String getElasticsearchServer()

setElasticsearchServer

void setElasticsearchServer(java.lang.String value)

getElasticsearchHttpPort

@Default.Integer(value=9200)
java.lang.Integer getElasticsearchHttpPort()

setElasticsearchHttpPort

void setElasticsearchHttpPort(java.lang.Integer value)