hunk.code_window:     def tearDown(self):
           pass
       def testReportCallback(self):
           def train(config):
  
hunk.labels: keep keep keep keep replace keep
hunk.after_edit:     def testReportCallbackUnnamed(self):
  
hunk.file_path: python/ray/tune/tests/test_integration_pytorch_lightning.py
hunk.type: replace
file: package io.ray.streaming.operator;
  
  import io.ray.streaming.message.Record;
  
  public interface TwoInputOperator<T, O> extends Operator {
  
    void processElement(Record<T> record1, Record<O> record2);
  
    default OperatorType getOpType() {
      return OperatorType.TWO_INPUT;
    }
  }
  