samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Navina Ramesh" <nram...@linkedin.com>
Subject Review Request 30634: Serde for Stream Tuples
Date Wed, 04 Feb 2015 19:39:08 GMT

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

Review request for samza.


Repository: samza


Description
-------

Changes return type in the tuple interface to Data, instead of Object


Wrapping default serdes within sql specific serdes


Synced with Yi's latest patch - added README


Removing unused enum SerdeType


Diffs
-----

  build.gradle 4f9fb44d6dbf927a3ba92ef3c3dc91903406bb4f 
  gradle/dependency-versions.gradle 7bbaa41831c842b8164734ed578c07dd3394397f 
  samza-sql/README PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/api/data/Data.java 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/Schema.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/data/avro/AvroData.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/data/avro/AvroSchema.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerde.java PRE-CREATION

  samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerdeFactory.java
PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/data/string/StringData.java PRE-CREATION 
  samza-sql/src/main/java/org/apache/samza/sql/data/string/StringSchema.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/sql/task/StoreMessageCollector.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/sql/task/RandomOperatorTask.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 3a01fd66359b8c79954ae8f34eeaf4b2e3fdc0b4 

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


Testing
-------


Thanks,

Navina Ramesh


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message