----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34009/ -----------------------------------------------------------
(Updated May 9, 2015, 1:52 a.m.) Review request for samza, Chris Riccomini, Guozhang Wang, Milinda Pathirage, Navina Ramesh, and Naveen Somasundaram. Changes ------- Another round trying to make programmer APIs for operators simpler Bugs: SAMZA-552 https://issues.apache.org/jira/browse/SAMZA-552 Repository: samza Description (updated) ------- SAMZA-650: adding updateOutputs(), getResult(), and flush() in window operator. Adding example code as use case for window operator. This is to solicitate the iteration on the change of Operator APIs to make it simpler for programmers. * Main highlights: * Removed differentiation between RelationOperator and TupleOperator * Added OperatorCallback interface to allow user to insert callback functions to be invoked before process the input and before send the result * Simplified test task implementation WIP: * Implementation of window store and message store Diffs ----- samza-sql-core/src/main/java/org/apache/samza/sql/api/data/EntityName.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Relation.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Stream.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Tuple.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/Operator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/OperatorCallback.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/RelationOperator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/SimpleOperator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/SqlOperatorFactory.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/TupleOperator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/spec/OperatorSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/router/OperatorRouter.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/IncomingMessageTuple.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/exception/OperatorException.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/DefaultOperatorCallback.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorFactoryImpl.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorImpl.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleRouter.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/join/StreamStreamJoin.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionOp.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/relation/Join.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/relation/JoinSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/stream/InsertStream.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/stream/InsertStreamSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/BoundedTimeWindow.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/FullStateTimeWindow.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/FullStateTimeWindowOp.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/FullStateWindowOp.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/RetentionPolicy.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowOp.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowOpSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowState.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/router/SimpleRouter.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/FilteredMessageIterator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/HashPrefixedMessageStore.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/MessageStore.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/MessageStoreSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/OrderedStoreKey.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/PrefixedKey.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/Range.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/TimeAndOffsetKey.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/TimeKey.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/WindowOutputStream.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/WindowState.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/WindowStore.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/system/sql/LongOffset.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/system/sql/Offset.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/OperatorMessageCollector.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/RouterMessageCollector.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/SimpleMessageCollector.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/SqlMessageCollector.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/StoreMessageCollector.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/task/sql/RandomOperatorTask.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/task/sql/RandomWindowOperatorTask.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/task/sql/UserCallbacksSqlTask.java PRE-CREATION Diff: https://reviews.apache.org/r/34009/diff/ Testing (updated) ------- ./gradlew clean build passed Thanks, Yi Pan (Data Infrastructure)