hunk.code_window:         self.action = tf.cond(stochastic, lambda: stochastic_actions,
                                 lambda: deterministic_actions)
           self.action_prob = None
   class DQNPolicyGraph(DQNPostprocessing, TFPolicyGraph):
       def __init__(self, observation_space, action_space, config):
           config = dict(ray.rllib.agents.dqn.dqn.DEFAULT_CONFIG, **config)
           if not isinstance(action_space, Discrete):
               raise UnsupportedSpaceException(
                   "Action space {} is not supported for DQN.".format(
  
hunk.labels: keep keep keep keep keep replace keep keep keep keep keep
hunk.after_edit: class DQNPolicyGraph(LearningRateSchedule, DQNPostprocessing, TFPolicyGraph):
  
hunk.file_path: python/ray/rllib/agents/dqn/dqn_policy_graph.py
hunk.type: replace
file: package org.ray.streaming.plan;
  
  /**
   * Different roles for a node.
   */
  public enum VertexType {
    MASTER,
    SOURCE,
    PROCESS,
    SINK,
  }
  