hunk.code_window:         episode_reward_mean: -300  # note that evaluation perf is higher
           timesteps_total: 10000
       config:
           evaluation_interval: 1  # logged under evaluation/* metric keys
           soft_horizon: True
           clip_actions: False
           normalize_actions: True
           metrics_smoothing_episodes: 5
hunk.labels: keep keep keep replace keep keep keep keep
hunk.file_path: rllib/tuned_examples/regression_tests/pendulum-sac.yaml
hunk.type: replace
file: package org.ray.streaming.util;
  
  public class Config {
  
    /**
     * Maximum number of batches to run in a streaming job.
     */
    public static final String STREAMING_BATCH_MAX_COUNT = "streaming.batch.max.count";
  
    /**
     * batch frequency in milliseconds
     */
    public static final String STREAMING_BATCH_FREQUENCY = "streaming.batch.frequency";
    public static final long STREAMING_BATCH_FREQUENCY_DEFAULT = 1000;
  
    public static final String STREAMING_JOB_NAME = "streaming.job.name";
    public static final String STREAMING_OP_NAME = "streaming.op_name";
    public static final String TASK_JOB_ID = "streaming.task_job_id";
    public static final String STREAMING_WORKER_NAME = "streaming.worker_name";
  
    // channel
    public static final String CHANNEL_TYPE = "channel_type";
    public static final String MEMORY_CHANNEL = "memory_channel";
    public static final String NATIVE_CHANNEL = "native_channel";
    public static final String DEFAULT_CHANNEL_TYPE = NATIVE_CHANNEL;
    public static final String CHANNEL_SIZE = "channel_size";
    public static final String CHANNEL_SIZE_DEFAULT = String.valueOf((long)Math.pow(10, 8));
    public static final String IS_RECREATE = "streaming.is_recreate";
    // return from DataReader.getBundle if only empty message read in this interval.
    public static final String TIMER_INTERVAL_MS = "timer_interval_ms";
    public static final String READ_TIMEOUT_MS = "read_timeout_ms";
    public static final String DEFAULT_READ_TIMEOUT_MS = "10";
  
  
    public static final String STREAMING_RING_BUFFER_CAPACITY = "streaming.ring_buffer_capacity";
    // write an empty message if there is no data to be written in this
    // interval.
    public static final String STREAMING_EMPTY_MESSAGE_INTERVAL = "streaming.empty_message_interval";
  
    // operator type
    public static final String OPERATOR_TYPE = "operator_type";
  
    // flow control
    public static final String FLOW_CONTROL_TYPE = "streaming.flow_control_type";
    public static final String WRITER_CONSUMED_STEP = "streaming.writer.consumed_step";
    public static final String READER_CONSUMED_STEP = "streaming.reader.consumed_step";
  
  
  }
  