Uses of Class
org.wikimedia.eventutilities.flink.formats.json.KafkaRecordTimestampStrategy

Packages that use KafkaRecordTimestampStrategy

Package	Description
org.wikimedia.eventutilities.flink.formats.json
org.wikimedia.eventutilities.flink.stream

Uses of KafkaRecordTimestampStrategy in org.wikimedia.eventutilities.flink.formats.json

Methods in org.wikimedia.eventutilities.flink.formats.json that return KafkaRecordTimestampStrategy

Modifier and Type	Method and Description
static KafkaRecordTimestampStrategy	KafkaRecordTimestampStrategy.valueOf(String name) Returns the enum constant of this type with the specified name.
static KafkaRecordTimestampStrategy[]	KafkaRecordTimestampStrategy.values() Returns an array containing the constants of this enum type, in the order they are declared.

Constructors in org.wikimedia.eventutilities.flink.formats.json with parameters of type KafkaRecordTimestampStrategy

Constructor and Description

KafkaEventSerializationSchema(org.apache.flink.api.java.typeutils.RowTypeInfo typeInformation, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row> serializationSchema, SerializableClock ingestionTimeClock, String topic, KafkaRecordTimestampStrategy timestampStrategy, org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaPartitioner<org.apache.flink.types.Row> partitioner)

Uses of KafkaRecordTimestampStrategy in org.wikimedia.eventutilities.flink.stream

Methods in org.wikimedia.eventutilities.flink.stream with parameters of type KafkaRecordTimestampStrategy

Modifier and Type	Method and Description
org.apache.flink.connector.kafka.sink.KafkaSinkBuilder<org.apache.flink.types.Row>	EventDataStreamFactory.kafkaSinkBuilder(String streamName, String schemaVersion, String bootstrapServers, String topic, KafkaRecordTimestampStrategy timestampStrategy) Prepare a KafkaSinkBuilder with all the required components to produce to kafka using a json format matching the provided schema.
org.apache.flink.connector.kafka.sink.KafkaSinkBuilder<org.apache.flink.types.Row>	EventDataStreamFactory.kafkaSinkBuilder(String streamName, String schemaVersion, String bootstrapServers, String topic, KafkaRecordTimestampStrategy timestampStrategy, org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaPartitioner<org.apache.flink.types.Row> partitioner) Prepare a KafkaSinkBuilder with all the required components to produce to kafka using a json format matching the provided schema.