Modifier and Type | Method and Description |
---|---|
static SerializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext) |
static SerializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext,
java.util.function.Function<MetricGroup,MetricGroup> mapMetricGroup) |
Modifier and Type | Method and Description |
---|---|
default void |
SerializationSchema.open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
SerializationSchema.InitializationContext |
Sink.InitContext.asSerializationSchemaInitializationContext()
Provides a view on this context as a
SerializationSchema.InitializationContext . |
Modifier and Type | Method and Description |
---|---|
default void |
KafkaRecordSerializationSchema.open(SerializationSchema.InitializationContext context,
KafkaRecordSerializationSchema.KafkaSinkContext sinkContext)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
PulsarSerializationSchemaWrapper.open(SerializationSchema.InitializationContext initializationContext,
PulsarSinkContext sinkContext,
SinkConfiguration sinkConfiguration) |
default void |
PulsarSerializationSchema.open(SerializationSchema.InitializationContext initializationContext,
PulsarSinkContext sinkContext,
SinkConfiguration sinkConfiguration)
Initialization method for the schema.
|
Modifier and Type | Class and Description |
---|---|
class |
DummyInitializationContext
A dummy context for serialization schemas.
|
Modifier and Type | Method and Description |
---|---|
void |
AvroRowDataSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DebeziumAvroSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CsvRowDataSerializationSchema.open(SerializationSchema.InitializationContext context) |
void |
CsvRowSerializationSchema.open(SerializationSchema.InitializationContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
JsonRowDataSerializationSchema.open(SerializationSchema.InitializationContext context) |
void |
JsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
void |
JsonRowSerializationSchema.open(SerializationSchema.InitializationContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
CanalJsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DebeziumJsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MaxwellJsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
OggJsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
PbRowDataSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
RawFormatSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
PythonConnectorUtils.SecondColumnSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
default void |
KafkaSerializationSchema.open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaSerializationSchemaWrapper.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
default void |
KinesisSerializationSchema.open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.