You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by "Yi Pan (Data Infrastructure)" <yi...@linkedin.com> on 2015/02/04 19:07:37 UTC
Review Request 30627: REVISION: operator APIs: rebased and cleaned up

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30627/
-----------------------------------------------------------

Review request for samza, Chinmay Soman, Chris Riccomini, Jay Kreps, Milinda Pathirage, Navina Ramesh, and Naveen Somasundaram.


Bugs: SAMZA-482
    https://issues.apache.org/jira/browse/SAMZA-482


Repository: samza


Description
-------

REVISION: operator APIs: rebased and cleaned up


Diffs
-----

  build.gradle 4d0b44f53124740f18bd56a53b65324a2d0f3ee4 
  gradle/dependency-versions.gradle 12b324dc9421411ccdc43f674b8332b726cd9431 
  samza-sql/README PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/data/EntityName.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/data/Relation.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/data/Tuple.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/operators/Operator.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/operators/RelationOperator.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/operators/SqlOperatorFactory.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/operators/TupleOperator.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/operators/spec/OperatorSpec.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/router/OperatorRouter.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/data/IncomingMessageTuple.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperator.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorFactoryImpl.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorSpec.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/partition/PartitionOp.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/partition/PartitionSpec.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/relation/Join.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/relation/JoinSpec.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/stream/InsertStream.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/stream/InsertStreamSpec.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/window/BoundedTimeWindow.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/window/WindowSpec.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/operators/window/WindowState.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/router/SimpleRouter.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/task/sql/OperatorMessageCollector.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/task/sql/SqlMessageCollector.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/task/sql/StoreMessageCollector.java PRE-CREATION 
  samza-sql/src/test/java/org/apache/samza/task/sql/RandomOperatorTask.java PRE-CREATION 
  samza-sql/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java PRE-CREATION 
  settings.gradle bb07a3b84b14dcef94da1bb166eab6aa3d0026bb 

Diff: https://reviews.apache.org/r/30627/diff/


Testing
-------

./bin/check-all.sh passed


Thanks,

Yi Pan (Data Infrastructure)