public abstract class ElasticsearchSinkE2ECaseBase<T extends Comparable<T>> extends SinkTestSuiteBase<T>
Modifier and Type | Field and Description |
---|---|
protected static String |
ELASTICSEARCH_HOSTNAME |
protected FlinkContainerTestEnvironment |
flink |
Constructor and Description |
---|
ElasticsearchSinkE2ECaseBase() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkResultWithSemantic(ExternalSystemDataReader<T> reader,
List<T> testData,
CheckpointingMode semantic)
Compare the test data with actual data in given semantic.
|
addCollectSink, generateTestData, testBasicSink, testMetrics, testScaleDown, testScaleUp, testStartFromSavepoint
protected static final String ELASTICSEARCH_HOSTNAME
protected FlinkContainerTestEnvironment flink
protected void checkResultWithSemantic(ExternalSystemDataReader<T> reader, List<T> testData, CheckpointingMode semantic) throws Exception
SinkTestSuiteBase
checkResultWithSemantic
in class SinkTestSuiteBase<T extends Comparable<T>>
reader
- the data reader for the sinktestData
- the test datasemantic
- the supported semantic, see CheckpointingMode
Exception
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.