Skip to content

Instantly share code, notes, and snippets.

@MarkRoddy

MarkRoddy/last_segment_per_sessionId

Forked from pixie79/last_segment_per_sessionId
Last active December 19, 2015 02:48
Show Gist options
  • Save MarkRoddy/5885255 to your computer and use it in GitHub Desktop.
Save MarkRoddy/5885255 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
last_segment_per_sessionId
last_segment_per_sessionId = FOREACH gpv_sessionized GENERATE
FLATTEN(group) AS sessionId,
MAX(pv_sessionized.time) AS max_time;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment