Modifier and Type | Method and Description |
---|---|
static DeserializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.deserializationAdapter(RuntimeContext runtimeContext) |
static DeserializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.deserializationAdapter(RuntimeContext runtimeContext,
Function<MetricGroup,MetricGroup> mapMetricGroup) |
Modifier and Type | Method and Description |
---|---|
default void |
DeserializationSchema.open(DeserializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Class and Description |
---|---|
class |
DummyInitializationContext
A dummy context for serialization schemas.
|
Modifier and Type | Class and Description |
---|---|
class |
TestingDeserializationContext
An implementation of
DeserializationSchema.InitializationContext for test. |
Modifier and Type | Method and Description |
---|---|
void |
AvroRowDataDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DebeziumAvroDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CsvRowDataDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
void |
CsvRowDeserializationSchema.open(DeserializationSchema.InitializationContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractJsonDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
void |
JsonDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
void |
JsonRowDeserializationSchema.open(DeserializationSchema.InitializationContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
CanalJsonDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DebeziumJsonDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MaxwellJsonDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
OggJsonDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
PbRowDataDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
RawFormatDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ChangelogCsvDeserializer.open(DeserializationSchema.InitializationContext context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.