ElasticsearchIOITCommon.ElasticsearchPipelineOptions (Apache Beam 2.67.0)

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.options.PipelineOptions
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions
TestPipelineOptions.AlwaysPassMatcher, TestPipelineOptions.AlwaysPassMatcherFactory
Method Summary

Modifier and Type

Method

Description

Integer

getElasticsearchHttpPort()

String

getElasticsearchServer()

void

setElasticsearchHttpPort(Integer value)

void

setElasticsearchServer(String value)

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

Methods inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions
getOnCreateMatcher, getOnSuccessMatcher, getTempRoot, getTestTimeoutSeconds, isBlockOnRun, setBlockOnRun, setOnCreateMatcher, setOnSuccessMatcher, setTempRoot, setTestTimeoutSeconds

Method Details
- getElasticsearchServer
  
  @String("elasticsearch-server-name") String getElasticsearchServer()
- setElasticsearchServer
  
  void setElasticsearchServer(String value)
- getElasticsearchHttpPort
  
  @Integer(9200) Integer getElasticsearchHttpPort()
- setElasticsearchHttpPort
  
  void setElasticsearchHttpPort(Integer value)