rm DirectActorTable (#6684)

src/ray/gcs/redis_gcs_client.cc

@@ -120,7 +120,6 @@ Status RedisGcsClient::Connect(boost::asio::io_service &io_service) {
   Attach(io_service);
 
   actor_table_.reset(new ActorTable({primary_context_}, this));
-  direct_actor_table_.reset(new DirectActorTable({primary_context_}, this));
 
   // TODO(micafan) Modify ClientTable' Constructor(remove ClientID) in future.
   // We will use NodeID instead of ClientID.
@@ -198,8 +197,6 @@ raylet::TaskTable &RedisGcsClient::raylet_task_table() { return *raylet_task_tab
 
 ActorTable &RedisGcsClient::actor_table() { return *actor_table_; }
 
-DirectActorTable &RedisGcsClient::direct_actor_table() { return *direct_actor_table_; }
-
 TaskReconstructionLog &RedisGcsClient::task_reconstruction_log() {
   return *task_reconstruction_log_;
 }

src/ray/gcs/redis_gcs_client.h

@@ -66,10 +66,6 @@ class RAY_EXPORT RedisGcsClient : public GcsClient {
   TaskLeaseTable &task_lease_table();
   ErrorTable &error_table();
   ProfileTable &profile_table();
-  /// Used only for direct calls. Tasks submitted through the raylet transport
-  /// should use Actors(), which has a requirement on the order in which
-  /// entries can be appended to the log.
-  DirectActorTable &direct_actor_table();
 
   // We also need something to export generic code to run on workers from the
   // driver (to set the PYTHONPATH)
@@ -115,7 +111,6 @@ class RAY_EXPORT RedisGcsClient : public GcsClient {
   std::unique_ptr<ObjectTable> object_table_;
   std::unique_ptr<raylet::TaskTable> raylet_task_table_;
   std::unique_ptr<ActorTable> actor_table_;
-  std::unique_ptr<DirectActorTable> direct_actor_table_;
   std::unique_ptr<TaskReconstructionLog> task_reconstruction_log_;
   std::unique_ptr<TaskLeaseTable> task_lease_table_;
   std::unique_ptr<HeartbeatTable> heartbeat_table_;

src/ray/gcs/subscription_executor.cc

@@ -185,7 +185,6 @@ Status SubscriptionExecutor<ID, Data, Table>::AsyncUnsubscribe(
 }
 
 template class SubscriptionExecutor<ActorID, ActorTableData, ActorTable>;
-template class SubscriptionExecutor<ActorID, ActorTableData, DirectActorTable>;
 template class SubscriptionExecutor<JobID, JobTableData, JobTable>;
 template class SubscriptionExecutor<TaskID, TaskTableData, raylet::TaskTable>;
 template class SubscriptionExecutor<ObjectID, ObjectChangeNotification, ObjectTable>;

src/ray/gcs/tables.h

@@ -716,16 +716,6 @@ class ActorTable : public Log<ActorID, ActorTableData> {
   }
 };
 
-class DirectActorTable : public Log<ActorID, ActorTableData> {
- public:
-  DirectActorTable(const std::vector<std::shared_ptr<RedisContext>> &contexts,
-                   RedisGcsClient *client)
-      : Log(contexts, client) {
-    pubsub_channel_ = TablePubsub::DIRECT_ACTOR_PUBSUB;
-    prefix_ = TablePrefix::DIRECT_ACTOR;
-  }
-};
-
 class TaskReconstructionLog : public Log<TaskID, TaskReconstructionData> {
  public:
   TaskReconstructionLog(const std::vector<std::shared_ptr<RedisContext>> &contexts,