Skip to content

Conversation

@shaoting-huang
Copy link
Contributor

…ation

Consolidate S3/FileSystem configuration into MilvusOption to simplify the
codebase and provide a single, unified configuration API.

Changes:

  • Merged all S3 configuration fields from MilvusS3Option into MilvusOption (readerType, s3FileSystemType, s3BucketName, s3RootPath, s3Endpoint, s3AccessKey, s3SecretKey, s3UseSSL, s3PathStyleAccess, s3MaxConnections, s3PreloadPoolSize)
  • Moved helper methods (notEmpty, getConf, getFileSystem, getFilePath) from MilvusS3Option to MilvusOption
  • Updated MilvusOption.apply() to parse S3 configuration fields
  • Removed MilvusS3Option case class and companion object
  • Updated all references across the codebase:
    • sources/MilvusDataSource.scala
    • binlog/MilvusBinlogDataSource.scala
    • read/MilvusPartitionReader.scala
    • read/MilvusPartitionReaderFactory.scala
    • write/MilvusSparkNativeImportWriter.scala
  • Fixed reference to milvusPKType -> collectionPKType in binlog reader

@sre-ci-robot
Copy link
Collaborator

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by: shaoting-huang
To complete the pull request process, please assign czs007 after the PR has been reviewed.
You can assign the PR to them by writing /assign @czs007 in a comment when ready.

The full list of commands accepted by this bot can be found here.

Needs approval from an approver in each of these files:

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

…ation

Consolidate S3/FileSystem configuration into MilvusOption to simplify the
  codebase and provide a single, unified configuration API.

  Changes:
  - Merged all S3 configuration fields from MilvusS3Option into MilvusOption
    (readerType, s3FileSystemType, s3BucketName, s3RootPath, s3Endpoint,
    s3AccessKey, s3SecretKey, s3UseSSL, s3PathStyleAccess, s3MaxConnections,
    s3PreloadPoolSize)
  - Moved helper methods (notEmpty, getConf, getFileSystem, getFilePath)
    from MilvusS3Option to MilvusOption
  - Updated MilvusOption.apply() to parse S3 configuration fields
  - Removed MilvusS3Option case class and companion object
  - Updated all references across the codebase:
    * sources/MilvusDataSource.scala
    * binlog/MilvusBinlogDataSource.scala
    * read/MilvusPartitionReader.scala
    * read/MilvusPartitionReaderFactory.scala
    * write/MilvusSparkNativeImportWriter.scala
  - Fixed reference to milvusPKType -> collectionPKType in binlog reader

Signed-off-by: shaoting-huang <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants