hunk.code_window:             cpu: 1
               memory: 1Gi
             limits:
               memory: 2Gi
               cpu: 1
         {{- if .Values.imagePullSecrets }}
         imagePullSecrets:
         {{ toYaml .Values.imagePullSecrets | indent 8 }}
         {{- end }}
   {{- end }}
  
hunk.labels: keep keep keep keep keep replace replace replace replace keep keep
hunk.file_path: deploy/charts/ray/templates/operator_namespaced.yaml
hunk.type: replace
file: package io.ray.streaming.api.stream;
  
  import io.ray.streaming.api.Language;
  import io.ray.streaming.operator.impl.SinkOperator;
  
  /**
   * Represents a sink of the DataStream.
   *
   * @param <T> Type of the input data of this sink.
   */
  public class DataStreamSink<T> extends StreamSink<T> {
  
    public DataStreamSink(DataStream input, SinkOperator sinkOperator) {
      super(input, sinkOperator);
      getStreamingContext().addSink(this);
    }
  
    @Override
    public Language getLanguage() {
      return Language.JAVA;
    }
  }
  