SAMZA-1264; Make Operator Functions Closable
authorvjagadish1989 <jvenkatr@linkedin.com>
Thu, 1 Jun 2017 05:20:14 +0000 (22:20 -0700)
committervjagadish1989 <jvenkatr@linkedin.com>
Thu, 1 Jun 2017 05:20:14 +0000 (22:20 -0700)
commita19f86f8f1c322b8eeda2e38eafc901836746cdb
tree88e80c3efb3cead3b6f668a81d6e30fc342335a6
parent026ef7f789685f62380b0a05ded9be6736011950
SAMZA-1264; Make Operator Functions Closable

- Added `close()` to the lifecycle of `OperatorImpl`s, and all `Function`s.
- Added unit tests to verify calls to `close()`

Author: vjagadish1989 <jvenkatr@linkedin.com>

Reviewers: Prateek Maheshwari<pmaheshw@linkedin.com>

Closes #208 from vjagadish1989/operator_functions
22 files changed:
samza-api/src/main/java/org/apache/samza/application/StreamApplication.java
samza-api/src/main/java/org/apache/samza/operators/functions/ClosableFunction.java [new file with mode: 0644]
samza-api/src/main/java/org/apache/samza/operators/functions/FilterFunction.java
samza-api/src/main/java/org/apache/samza/operators/functions/FlatMapFunction.java
samza-api/src/main/java/org/apache/samza/operators/functions/FoldLeftFunction.java
samza-api/src/main/java/org/apache/samza/operators/functions/JoinFunction.java
samza-api/src/main/java/org/apache/samza/operators/functions/MapFunction.java
samza-api/src/main/java/org/apache/samza/operators/functions/SinkFunction.java
samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java
samza-core/src/main/java/org/apache/samza/operators/functions/PartialJoinFunction.java
samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java
samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java
samza-core/src/main/java/org/apache/samza/operators/impl/PartialJoinOperatorImpl.java
samza-core/src/main/java/org/apache/samza/operators/impl/RootOperatorImpl.java
samza-core/src/main/java/org/apache/samza/operators/impl/SinkOperatorImpl.java
samza-core/src/main/java/org/apache/samza/operators/impl/StreamOperatorImpl.java
samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java
samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java
samza-core/src/test/java/org/apache/samza/operators/TestJoinOperator.java
samza-core/src/test/java/org/apache/samza/operators/impl/TestOperatorImpl.java
samza-core/src/test/java/org/apache/samza/operators/impl/TestSinkOperatorImpl.java
samza-core/src/test/java/org/apache/samza/operators/impl/TestStreamOperatorImpl.java