VolumeBulkWriter

VolumeBulkWriter を設定します。これには、collection スキーマ、出力パス、volume 接続が含まれます。

java

public class VolumeBulkWriter

📘注記

VolumeBulkWriter オブジェクトは、Milvus が理解できる形式で生データを Zilliz Cloud Volume に書き換えることを目的としています。

ビルダーメソッド:

withCollectionSchema(CollectionSchemaParam collectionSchema)

CollectionSchemaParam で定義された、対象 collection のスキーマです。ビルダーはこれを内部で v2 collection スキーマに変換します。
withCollectionSchema(CreateCollectionReq.CollectionSchema collectionSchema)

CreateCollectionReq.CollectionSchema で定義された、対象 collection のスキーマです。
withRemotePath(String remotePath)

書き換えられたデータファイルが保存される、対象 volume 内のパスです。
withChunkSize(long chunkSize)

生成される各ファイルセグメントの最大サイズ（バイト単位）です。デフォルト値は 134,217,728 バイト（128 MB）です。
withFileType(BulkFileType fileType)

出力ファイル形式です。使用可能な値については、BulkFileType を参照してください。
withConfig(String key, Object value)

出力ファイル処理用のオプションのキーと値の設定です。CSV 出力の場合は、区切り文字を設定するために sep を使用し、null 値を表す文字列を設定するために nullkey を使用します。
withCloudEndpoint(String cloudEndpoint)

Zilliz Cloud のパブリック API エンドポイントです。この値を https://api.cloud.zilliz.com に設定します。
withApiKey(String apiKey)

リクエストの認証に使用する Zilliz Cloud API key です。
withVolumeName(String volumeName)

対象の Zilliz Cloud volume の名前です。
withConnectType(ConnectType connectType)

volume へのアクセスに使用する接続戦略です。デフォルト値は ConnectType.AUTO です。

Example

collection スキーマ、出力パス、volume 接続を含む VolumeBulkWriter を設定します。

java
VolumeBulkWriterParam params = VolumeBulkWriterParam.newBuilder()
    .withCollectionSchema(collectionSchema)
    .withRemotePath("imports/books")
    .withCloudEndpoint(CLOUD_ENDPOINT)
    .withApiKey(API_KEY)
    .withVolumeName("bulk-data")
    .build();
VolumeBulkWriter writer = new VolumeBulkWriter(params);

Example​

Example