SAMZA-1415: Add clearStream API in SystemAdmin and remove deprecated APIs
authorXinyu Liu <xiliu@xiliu-ld1.linkedin.biz>
Thu, 7 Sep 2017 23:49:20 +0000 (16:49 -0700)
committerXinyu Liu <xiliu@xiliu-ld1.linkedin.biz>
Thu, 7 Sep 2017 23:49:20 +0000 (16:49 -0700)
commit79200c73509727abba2d6eb68cfc45ac1d842d35
treecc83921e9d8d3fa5ed334f77473a32598fa95a1a
parent23bfaa8d117511ecc1e8a71c0d2695def24158af
SAMZA-1415: Add clearStream API in SystemAdmin and remove deprecated APIs

The patch does the following:

1) add clearStream() APi in SystemAdmin. Currently it's only supported in Kafka with broker configuring delete.topic.enable=true.

2) remove the deprecated APIs including createChangeLogStream(), validateChangelogStream() and createCoordinatorStream().

Author: Xinyu Liu <xiliu@xiliu-ld1.linkedin.biz>

Reviewers: Jake Maes <jacob.maes@gmail.com>

Closes #292 from xinyuiscool/SAMZA-1415
20 files changed:
samza-api/src/main/java/org/apache/samza/system/StreamSpec.java
samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java
samza-api/src/main/java/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.java
samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala
samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala
samza-core/src/main/scala/org/apache/samza/storage/TaskStorageManager.scala
samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamSystemFactory.java
samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java
samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala
samza-core/src/test/scala/org/apache/samza/container/TestTaskInstance.scala
samza-core/src/test/scala/org/apache/samza/coordinator/TestJobCoordinator.scala
samza-core/src/test/scala/org/apache/samza/storage/TestTaskStorageManager.scala
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemAdmin.java
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemAdmin.java
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemAdminJava.java
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java
samza-test/src/test/java/org/apache/samza/test/util/SimpleSystemAdmin.java
samza-yarn/src/test/scala/org/apache/samza/job/yarn/MockSystemAdmin.scala