Package io.github.flink.gcp.connector.testutils

Class TestContexts

java.lang.Object

io.github.flink.gcp.connector.testutils.TestContexts

@Internal
public final class TestContexts
extends Object

Shared test stubs for SinkWriter.Context.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.flink.api.connector.sink2.SinkWriter.Context	NO_OP	A no-op context: no timestamp, and Long.MIN_VALUE for the watermark — the value a writer sees before any watermark has arrived.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

NO_OP

public static final org.apache.flink.api.connector.sink2.SinkWriter.Context NO_OP

A no-op context: no timestamp, and Long.MIN_VALUE for the watermark — the value a writer sees before any watermark has arrived.