Modifier and Type | Method and Description |
---|---|
CheckpointingMode |
TestingSinkSettings.getCheckpointingMode()
Checkpointing mode required for the sink.
|
Modifier and Type | Method and Description |
---|---|
TestingSinkSettings.Builder |
TestingSinkSettings.Builder.setCheckpointingMode(CheckpointingMode checkpointingMode) |
Modifier and Type | Method and Description |
---|---|
CheckpointingMode |
TestingSourceSettings.getCheckpointingMode()
Checkpointing mode required for the source.
|
Modifier and Type | Method and Description |
---|---|
TestingSourceSettings.Builder |
TestingSourceSettings.Builder.setCheckpointingMode(CheckpointingMode checkpointingMode) |
Modifier and Type | Method and Description |
---|---|
protected void |
SourceTestSuiteBase.checkResultWithSemantic(CloseableIterator<T> resultIterator,
List<List<T>> testData,
CheckpointingMode semantic,
Integer limit)
Compare the test data with the result.
|
void |
SinkTestSuiteBase.testBasicSink(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test DataStream connector sink.
|
void |
SourceTestSuiteBase.testIdleReader(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source with an idle reader.
|
void |
SinkTestSuiteBase.testMetrics(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink metrics.
|
void |
SourceTestSuiteBase.testMultipleSplits(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source with multiple splits in the external system
|
void |
SourceTestSuiteBase.testSavepoint(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source restart from a savepoint.
|
void |
SinkTestSuiteBase.testScaleDown(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed savepoint with a lower parallelism.
|
void |
SourceTestSuiteBase.testScaleDown(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source restart from a savepoint with a lower parallelism.
|
void |
SinkTestSuiteBase.testScaleUp(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed savepoint with a higher parallelism.
|
void |
SourceTestSuiteBase.testScaleUp(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source restart from a savepoint with a higher parallelism.
|
void |
SourceTestSuiteBase.testSourceMetrics(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source metrics.
|
void |
SourceTestSuiteBase.testSourceSingleSplit(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source with only one split in the external system.
|
void |
SinkTestSuiteBase.testStartFromSavepoint(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed savepoint with the same parallelism.
|
void |
SourceTestSuiteBase.testTaskManagerFailure(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
ClusterControllable controller,
CheckpointingMode semantic)
Test connector source with task manager failover.
|
Modifier and Type | Method and Description |
---|---|
void |
UnorderedCollectIteratorAssert.matchesRecordsFromSource(List<List<T>> recordsBySplitsFromSource,
CheckpointingMode semantic) |
void |
CollectIteratorAssert.matchesRecordsFromSource(List<List<T>> recordsBySplitsFromSource,
CheckpointingMode semantic) |
Modifier and Type | Method and Description |
---|---|
static CheckpointingMode |
CheckpointingMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CheckpointingMode[] |
CheckpointingMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Field and Description |
---|---|
static CheckpointingMode |
CheckpointConfig.DEFAULT_MODE
The default checkpoint mode: exactly once.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<CheckpointingMode> |
ExecutionCheckpointingOptions.CHECKPOINTING_MODE |
Modifier and Type | Method and Description |
---|---|
CheckpointingMode |
CheckpointConfig.getCheckpointingMode()
Gets the checkpointing mode (exactly-once vs.
|
CheckpointingMode |
StreamExecutionEnvironment.getCheckpointingMode()
Returns the checkpointing mode (exactly-once vs.
|
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode)
Enables checkpointing for the streaming job.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode,
boolean force)
Deprecated.
Use
StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode) instead. Forcing
checkpoints will be removed in the future. |
void |
CheckpointConfig.setCheckpointingMode(CheckpointingMode checkpointingMode)
Sets the checkpointing mode (exactly-once vs.
|
Modifier and Type | Method and Description |
---|---|
CheckpointingMode |
StreamConfig.getCheckpointMode() |
Modifier and Type | Method and Description |
---|---|
void |
StreamConfig.setCheckpointMode(CheckpointingMode mode) |
Modifier and Type | Method and Description |
---|---|
CheckpointingMode |
StreamingRuntimeContext.getCheckpointMode()
Returns the checkpointing mode.
|
Modifier and Type | Method and Description |
---|---|
CheckpointingMode |
DummyStreamExecutionEnvironment.getCheckpointingMode() |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode,
boolean force) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.