code: def test_file_source(self):
      stream_format = StreamFormat.text_line_format()
      paths = ["/tmp/1.txt", "/tmp/2.txt"]
      file_source_builder = FileSource.for_record_stream_format(
          stream_format, *paths
      )
      file_source = (
          file_source_builder.monitor_continuously(Duration.of_days(1))
          .set_file_enumerator(
              FileEnumeratorProvider.default_splittable_file_enumerator()
          )
          .set_split_assigner(
              FileSplitAssignerProvider.locality_aware_split_assigner()
          )
          .build()
      )
  
      continuous_setting = (
          file_source.get_java_function().getContinuousEnumerationSettings()
      )
      self.assertIsNotNone(continuous_setting)
      self.assertEqual(
          Duration.of_days(1),
          Duration(continuous_setting.getDiscoveryInterval()),
      )
  
      input_paths_field = load_java_class(
          "org.apache.flink.connector.file.src.AbstractFileSource"
      ).getDeclaredField("inputPaths")
      input_paths_field.setAccessible(True)
      input_paths = input_paths_field.get(
          file_source.get_java_function()
      )
      self.assertEqual(len(input_paths), len(paths))
      self.assertEqual(str(input_paths[0]), paths[0])
      self.assertEqual(str(input_paths[1]), paths[1])
  
file_path: flink/flink-python/pyflink/datastream/connectors/tests/test_file_system.py
imports: from pyflink.common import Duration
  from pyflink.common.serialization import Encoder
  from pyflink.common.typeinfo import Types
  from pyflink.datastream.connectors.file_system import FileCompactStrategy, FileCompactor, StreamingFileSink, OutputFileConfig, FileSource, StreamFormat, FileEnumeratorProvider, FileSplitAssignerProvider, RollingPolicy, FileSink, BucketAssigner
  from pyflink.testing.test_case_utils import PyFlinkStreamingTestCase
  from pyflink.util.java_utils import load_java_class
label_desc: Use image node_id 2 for calling the FileSystemTests obj's underlying member method code with example usage: obj.test_file_source() without return types