Skip to content

Instantly share code, notes, and snippets.

@softwaredoug

softwaredoug/SearchTimestampFunction.java

Created November 11, 2020 15:32
Show Gist options
  • Save softwaredoug/62684255a68a13572aaa644fff04ed9f to your computer and use it in GitHub Desktop.
Save softwaredoug/62684255a68a13572aaa644fff04ed9f to your computer and use it in GitHub Desktop.
Download ZIP
Search timestamp function
Raw
SearchTimestampFunction.java
public class GetSearchQueryTimestampFunction implements SerializableFunction<KafkaRecord<Long, SearchQueryEvent>, Instant> {
@Override
public Instant apply(KafkaRecord<Long, SearchQueryEvent> input) {
return input.getKV().getValue().searchTimestamp;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment