public class dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader extends java.lang.Object
{
private static final org.slf4j.Logger log;
private final com.azure.storage.blob.BlobServiceClient blobServiceClient;
public void <init>(com.azure.storage.blob.BlobServiceClient)
{
com.azure.storage.blob.BlobServiceClient v;
java.lang.Object v;
dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader v;
v := @this: dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader;
v := @parameter: com.azure.storage.blob.BlobServiceClient;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <dev.langchain4j.internal.ValidationUtils: java.lang.Object ensureNotNull(java.lang.Object,java.lang.String)>(v, "blobServiceClient");
v.<dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader: com.azure.storage.blob.BlobServiceClient blobServiceClient> = v;
return;
}
public dev.langchain4j.data.document.Document loadDocument(java.lang.String, java.lang.String, dev.langchain4j.data.document.DocumentParser)
{
com.azure.storage.blob.models.BlobProperties v;
com.azure.storage.blob.BlobContainerClient v;
dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader v;
com.azure.storage.blob.BlobServiceClient v;
com.azure.storage.blob.BlobClient v;
dev.langchain4j.data.document.source.azure.storage.blob.AzureBlobStorageSource v;
dev.langchain4j.data.document.DocumentParser v;
java.lang.String v, v, v;
com.azure.storage.blob.specialized.BlobInputStream v;
dev.langchain4j.data.document.Document v;
v := @this: dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: dev.langchain4j.data.document.DocumentParser;
v = v.<dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader: com.azure.storage.blob.BlobServiceClient blobServiceClient>;
v = virtualinvoke v.<com.azure.storage.blob.BlobServiceClient: com.azure.storage.blob.BlobContainerClient getBlobContainerClient(java.lang.String)>(v);
v = virtualinvoke v.<com.azure.storage.blob.BlobContainerClient: com.azure.storage.blob.BlobClient getBlobClient(java.lang.String)>(v);
v = virtualinvoke v.<com.azure.storage.blob.BlobClient: com.azure.storage.blob.models.BlobProperties getProperties()>();
v = virtualinvoke v.<com.azure.storage.blob.BlobClient: com.azure.storage.blob.specialized.BlobInputStream openInputStream()>();
v = new dev.langchain4j.data.document.source.azure.storage.blob.AzureBlobStorageSource;
v = virtualinvoke v.<com.azure.storage.blob.BlobClient: java.lang.String getAccountName()>();
specialinvoke v.<dev.langchain4j.data.document.source.azure.storage.blob.AzureBlobStorageSource: void <init>(java.io.InputStream,java.lang.String,java.lang.String,java.lang.String,com.azure.storage.blob.models.BlobProperties)>(v, v, v, v, v);
v = staticinvoke <dev.langchain4j.data.document.DocumentLoader: dev.langchain4j.data.document.Document load(dev.langchain4j.data.document.DocumentSource,dev.langchain4j.data.document.DocumentParser)>(v, v);
return v;
}
public java.util.List loadDocuments(java.lang.String, dev.langchain4j.data.document.DocumentParser)
{
com.azure.storage.blob.BlobContainerClient v;
dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader v;
java.util.ArrayList v;
java.util.function.Consumer v;
com.azure.storage.blob.BlobServiceClient v;
dev.langchain4j.data.document.DocumentParser v;
com.azure.core.http.rest.PagedIterable v;
java.lang.String v;
v := @this: dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader;
v := @parameter: java.lang.String;
v := @parameter: dev.langchain4j.data.document.DocumentParser;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader: com.azure.storage.blob.BlobServiceClient blobServiceClient>;
v = virtualinvoke v.<com.azure.storage.blob.BlobServiceClient: com.azure.storage.blob.BlobContainerClient getBlobContainerClient(java.lang.String)>(v);
v = virtualinvoke v.<com.azure.storage.blob.BlobContainerClient: com.azure.core.http.rest.PagedIterable listBlobs()>();
v = staticinvoke <dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader$lambda_loadDocuments_0__1: java.util.function.Consumer bootstrap$(dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader,java.util.List,java.lang.String,dev.langchain4j.data.document.DocumentParser)>(v, v, v, v);
virtualinvoke v.<com.azure.core.http.rest.PagedIterable: void forEach(java.util.function.Consumer)>(v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Ldev/langchain4j/data/document/loader/azure/storage/blob/AzureBlobStorageDocumentLoader;");
<dev.langchain4j.data.document.loader.azure.storage.blob.AzureBlobStorageDocumentLoader: org.slf4j.Logger log> = v;
return;
}
}