class_docstr: Binary datasource, for reading and writing binary files. Ignores None values.
  
  Examples:
      >>> import ray
      >>> from ray.data.datasource import BinaryDatasource
      >>> source = BinaryDatasource() # doctest: +SKIP
      >>> ray.data.read_datasource( # doctest: +SKIP
      ...     source, paths=["/path/to/dir", None]).take()
      [b"file_data", ...]
docstr: Opens a source path for reading and returns the associated Arrow NativeFile.
  
  The default implementation opens the source path as a sequential input stream.
  
  Implementations that do not support streaming reads (e.g. that require random
  access) should override this method.
docstr_tok: ["Opens","a","source","path","for","reading","and","returns","the","associated","Arrow","NativeFile",".","The","default","implementation","opens","the","source","path","as","a","sequential","input","stream",".","Implementations","that","do","not","support","streaming","reads","(","e.g",".","that","require","random","access",")","should","override","this","method","."]
code: def _open_input_source(
      self,
      filesystem: "pyarrow.fs.FileSystem",
      path: str,
      **open_args,
  ) -> "pyarrow.NativeFile":
      """Opens a source path for reading and returns the associated Arrow NativeFile.
  
      The default implementation opens the source path as a sequential input stream.
  
      Implementations that do not support streaming reads (e.g. that require random
      access) should override this method.
      """
      if path is None or is_http(path):
          return contextlib.nullcontext()
      return filesystem.open_input_stream(path, **open_args)
  
imports: import contextlib
  import logging
  from typing import Any, Callable, Dict, Iterable, List, Optional, Tuple, TYPE_CHECKING, Union
  import ray
  import urllib3
  from packaging import version
  from ray.data.block import Block
  from ray.data.context import DatasetContext
  from ray.data.datasource.binary_datasource import BinaryDatasource
  from ray.data.datasource.datasource import Datasource, ReadTask
  from ray.data.datasource.file_based_datasource import _check_pyarrow_version, _resolve_paths_and_filesystem, _S3FileSystemWrapper, _wrap_s3_serialization_workaround, BaseFileMetadataProvider, BlockOutputBuffer, DefaultFileMetadataProvider
  from ludwig.utils.fs_utils import get_bytes_obj_from_http_path, is_http
label_desc: Use image node_id 3 for calling the BinaryIgnoreNoneTypeDatasource obj's underlying member method code with example usage: obj._open_input_source(filesystem, path) and returns: filesystem, contextlib