Modifier and Type | Method and Description |
---|---|
static TimestampFormat |
TimestampFormat.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TimestampFormat[] |
TimestampFormat.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static TimestampFormat |
JsonFormatOptionsUtil.getTimestampFormat(ReadableConfig config) |
Constructor and Description |
---|
JsonRowDataDeserializationSchema(RowType rowType,
TypeInformation<RowData> resultTypeInfo,
boolean failOnMissingField,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
JsonRowDataSerializationSchema(RowType rowType,
TimestampFormat timestampFormat,
JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
String mapNullKeyLiteral,
boolean encodeDecimalAsPlainNumber) |
JsonToRowDataConverters(boolean failOnMissingField,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
RowDataToJsonConverters(TimestampFormat timestampFormat,
JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
String mapNullKeyLiteral) |
Modifier and Type | Method and Description |
---|---|
CanalJsonDeserializationSchema.Builder |
CanalJsonDeserializationSchema.Builder.setTimestampFormat(TimestampFormat timestampFormat) |
Constructor and Description |
---|
CanalJsonDecodingFormat(String database,
String table,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
CanalJsonSerializationSchema(RowType rowType,
TimestampFormat timestampFormat,
JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
String mapNullKeyLiteral,
boolean encodeDecimalAsPlainNumber) |
Constructor and Description |
---|
DebeziumJsonDecodingFormat(boolean schemaInclude,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
DebeziumJsonDeserializationSchema(DataType physicalDataType,
List<org.apache.flink.formats.json.debezium.DebeziumJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo,
boolean schemaInclude,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
DebeziumJsonSerializationSchema(RowType rowType,
TimestampFormat timestampFormat,
JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
String mapNullKeyLiteral,
boolean encodeDecimalAsPlainNumber) |
Constructor and Description |
---|
MaxwellJsonDecodingFormat(boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
MaxwellJsonDeserializationSchema(DataType physicalDataType,
List<org.apache.flink.formats.json.maxwell.MaxwellJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
MaxwellJsonSerializationSchema(RowType rowType,
TimestampFormat timestampFormat,
JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
String mapNullKeyLiteral,
boolean encodeDecimalAsPlainNumber) |
Constructor and Description |
---|
OggJsonDecodingFormat(boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
OggJsonDeserializationSchema(DataType physicalDataType,
List<org.apache.flink.formats.json.ogg.OggJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
OggJsonSerializationSchema(RowType rowType,
TimestampFormat timestampFormat,
JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
String mapNullKeyLiteral,
boolean encodeDecimalAsPlainNumber) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.