Package | Description |
---|---|
org.apache.flink.streaming.kafka.test.base |
Modifier and Type | Method and Description |
---|---|
KafkaEvent |
KafkaEventSchema.deserialize(byte[] message) |
static KafkaEvent |
KafkaEvent.fromString(String eventStr) |
KafkaEvent |
RollingAdditionMapper.map(KafkaEvent event) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<KafkaEvent> |
KafkaEventSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
long |
CustomWatermarkExtractor.extractTimestamp(KafkaEvent event,
long previousElementTimestamp) |
boolean |
KafkaEventSchema.isEndOfStream(KafkaEvent nextElement) |
KafkaEvent |
RollingAdditionMapper.map(KafkaEvent event) |
byte[] |
KafkaEventSchema.serialize(KafkaEvent event) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.