[
https://issues.apache.org/jira/browse/SAMZA-390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14236324#comment-14236324
]
Yi Pan (Data Infrastructure) commented on SAMZA-390:
----------------------------------------------------
[~criccomini], yes! That's a great point! This *does* apply to all window
operator, given that all tuples in the stream are coming in the order of the
"timestamp" used to determine the window operation. The tricky issue on that
is: when we have re-paritioning in-between the tasks, the original order on the
timestamp field may be lost.
> High-Level Language for Samza
> -----------------------------
>
> Key: SAMZA-390
> URL: https://issues.apache.org/jira/browse/SAMZA-390
> Project: Samza
> Issue Type: New Feature
> Reporter: Raul Castro Fernandez
> Priority: Minor
> Labels: project
>
> Discussion about high-level languages to define Samza queries. Queries are
> defined in this language and transformed to a dataflow graph where the nodes
> are Samza jobs.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
