test_class.declarator: TOPIC = "test"
test_class.modifier: private static final
test_class.original_string: private static final String TOPIC = "test";
test_class.type: String
test_class.var_name: TOPIC
test_class.declarator: tempFile
test_class.modifier: private
test_class.original_string: private File tempFile;
test_class.type: File
test_class.var_name: tempFile
test_class.declarator: config
test_class.modifier: private
test_class.original_string: private Map<String, String> config;
test_class.type: Map<String, String>
test_class.var_name: config
test_class.declarator: offsetStorageReader
test_class.modifier: private
test_class.original_string: private OffsetStorageReader offsetStorageReader;
test_class.type: OffsetStorageReader
test_class.var_name: offsetStorageReader
test_class.declarator: context
test_class.modifier: private
test_class.original_string: private SourceTaskContext context;
test_class.type: SourceTaskContext
test_class.var_name: context
test_class.declarator: task
test_class.modifier: private
test_class.original_string: private FileStreamSourceTask task;
test_class.type: FileStreamSourceTask
test_class.var_name: task
test_class.declarator: verifyMocks = false
test_class.modifier: private
test_class.original_string: private boolean verifyMocks = false;
test_class.type: boolean
test_class.var_name: verifyMocks
test_class.file: connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceTaskTest.java
test_class.identifier: FileStreamSourceTaskTest
test_case.body: @Test(expected = ConnectException.class)
      public void testMissingTopic() throws InterruptedException {
          replay();
  
          config.remove(FileStreamSourceConnector.TOPIC_CONFIG);
          task.start(config);
      }
test_case.class_method_signature: FileStreamSourceTaskTest.testMissingTopic()
test_case.full_signature: @Test(expected = ConnectException.class) public void testMissingTopic()
test_case.identifier: testMissingTopic
test_case.invocations: replay remove start
test_case.modifiers: @Test(expected = ConnectException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testMissingTopic()
focal_class.declarator: log = LoggerFactory.getLogger(FileStreamSourceTask.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger log = LoggerFactory.getLogger(FileStreamSourceTask.class);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: FILENAME_FIELD = "filename"
focal_class.modifier: public static final
focal_class.original_string: public static final String FILENAME_FIELD = "filename";
focal_class.type: String
focal_class.var_name: FILENAME_FIELD
focal_class.declarator: POSITION_FIELD = "position"
focal_class.modifier: public  static final
focal_class.original_string: public  static final String POSITION_FIELD = "position";
focal_class.type: String
focal_class.var_name: POSITION_FIELD
focal_class.declarator: VALUE_SCHEMA = Schema.STRING_SCHEMA
focal_class.modifier: private static final
focal_class.original_string: private static final Schema VALUE_SCHEMA = Schema.STRING_SCHEMA;
focal_class.type: Schema
focal_class.var_name: VALUE_SCHEMA
focal_class.declarator: filename
focal_class.modifier: private
focal_class.original_string: private String filename;
focal_class.type: String
focal_class.var_name: filename
focal_class.declarator: stream
focal_class.modifier: private
focal_class.original_string: private InputStream stream;
focal_class.type: InputStream
focal_class.var_name: stream
focal_class.declarator: reader = null
focal_class.modifier: private
focal_class.original_string: private BufferedReader reader = null;
focal_class.type: BufferedReader
focal_class.var_name: reader
focal_class.declarator: buffer = new char[1024]
focal_class.modifier: private
focal_class.original_string: private char[] buffer = new char[1024];
focal_class.type: char[]
focal_class.var_name: buffer
focal_class.declarator: offset = 0
focal_class.modifier: private
focal_class.original_string: private int offset = 0;
focal_class.type: int
focal_class.var_name: offset
focal_class.declarator: topic = null
focal_class.modifier: private
focal_class.original_string: private String topic = null;
focal_class.type: String
focal_class.var_name: topic
focal_class.declarator: streamOffset
focal_class.modifier: private
focal_class.original_string: private Long streamOffset;
focal_class.type: Long
focal_class.var_name: streamOffset
focal_class.file: connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java
focal_class.identifier: FileStreamSourceTask
focal_class.class_method_signature: FileStreamSourceTask.version()
focal_class.full_signature: @Override public String version()
focal_class.identifier: version
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String version()
focal_class.class_method_signature: FileStreamSourceTask.start(Map<String, String> props)
focal_class.full_signature: @Override public void start(Map<String, String> props)
focal_class.identifier: start
focal_class.modifiers: @Override public
focal_class.parameters: (Map<String, String> props)
focal_class.return: void
focal_class.signature: void start(Map<String, String> props)
focal_class.class_method_signature: FileStreamSourceTask.poll()
focal_class.full_signature: @Override public List<SourceRecord> poll()
focal_class.identifier: poll
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: List<SourceRecord>
focal_class.signature: List<SourceRecord> poll()
focal_class.class_method_signature: FileStreamSourceTask.extractLine()
focal_class.full_signature: private String extractLine()
focal_class.identifier: extractLine
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String extractLine()
focal_class.class_method_signature: FileStreamSourceTask.stop()
focal_class.full_signature: @Override public void stop()
focal_class.identifier: stop
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stop()
focal_class.class_method_signature: FileStreamSourceTask.offsetKey(String filename)
focal_class.full_signature: private Map<String, String> offsetKey(String filename)
focal_class.identifier: offsetKey
focal_class.modifiers: private
focal_class.parameters: (String filename)
focal_class.return: Map<String, String>
focal_class.signature: Map<String, String> offsetKey(String filename)
focal_class.class_method_signature: FileStreamSourceTask.offsetValue(Long pos)
focal_class.full_signature: private Map<String, Long> offsetValue(Long pos)
focal_class.identifier: offsetValue
focal_class.modifiers: private
focal_class.parameters: (Long pos)
focal_class.return: Map<String, Long>
focal_class.signature: Map<String, Long> offsetValue(Long pos)
focal_class.class_method_signature: FileStreamSourceTask.logFilename()
focal_class.full_signature: private String logFilename()
focal_class.identifier: logFilename
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String logFilename()
focal_class.superclass: extends SourceTask
focal_method.body: @Override
      public void start(Map<String, String> props) {
          filename = props.get(FileStreamSourceConnector.FILE_CONFIG);
          if (filename == null || filename.isEmpty()) {
              stream = System.in;
              // Tracking offset for stdin doesn't make sense
              streamOffset = null;
              reader = new BufferedReader(new InputStreamReader(stream));
          }
          topic = props.get(FileStreamSourceConnector.TOPIC_CONFIG);
          if (topic == null)
              throw new ConnectException("FileStreamSourceTask config missing topic setting");
      }
focal_method.class_method_signature: FileStreamSourceTask.start(Map<String, String> props)
focal_method.full_signature: @Override public void start(Map<String, String> props)
focal_method.identifier: start
focal_method.invocations: get isEmpty get
focal_method.modifiers: @Override public
focal_method.parameters: (Map<String, String> props)
focal_method.return: void
focal_method.signature: void start(Map<String, String> props)