8054290840

Committed 26 Feb 2024 07:11PM CUT coverage: 62.707%. First build

Build # 8054290840

Build Type

Pull #14164

github

Committed by

web-flow

Commit Message

Merge e9fdbe61f into e805c4308

Pull Request Pull Request #14164: release/530-release-candidate

Run Details

8964 of 14295 relevant lines covered (62.71%)

0.63 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/scala/com/johnsnowlabs/client/azure/AzureClient.scala

package com.johnsnowlabs.client.azure

import com.johnsnowlabs.client.{CloudClient, CloudStorage}
import com.johnsnowlabs.util.ConfigHelper

class AzureClient(parameters: Map[String, String] = Map.empty) extends CloudClient {

  private lazy val azureStorageConnection = cloudConnect()

  override protected def cloudConnect(): CloudStorage = {
    val storageAccountName = parameters.getOrElse(
      "storageAccountName",
      throw new Exception("Azure client requires storageAccountName"))
    val accountKey =
      parameters.getOrElse("accountKey", ConfigHelper.getHadoopAzureConfig(storageAccountName))
    new AzureGateway(storageAccountName, accountKey)
  }

  override def doesBucketPathExist(bucketName: String, filePath: String): Boolean = {
    azureStorageConnection.doesBucketPathExist(bucketName, filePath)
  }

  override def copyInputStreamToBucket(
      bucketName: String,
      filePath: String,
      sourceFilePath: String): Unit = {
    azureStorageConnection.copyInputStreamToBucket(bucketName, filePath, sourceFilePath)
  }

  override def downloadFilesFromBucketToDirectory(
      bucketName: String,
      filePath: String,
      directoryPath: String,
      isIndex: Boolean): Unit = {
    azureStorageConnection.downloadFilesFromBucketToDirectory(
      bucketName,
      filePath,
      directoryPath,
      isIndex)
  }

}

1	package com.johnsnowlabs.client.azure
2
3	import com.johnsnowlabs.client.{CloudClient, CloudStorage}
4	import com.johnsnowlabs.util.ConfigHelper
5
6	class AzureClient(parameters: Map[String, String] = Map.empty) extends CloudClient {
7
8	private lazy val azureStorageConnection = cloudConnect()
9
10	override protected def cloudConnect(): CloudStorage = {
11	val storageAccountName = parameters.getOrElse(	×
12	"storageAccountName",	×
13	throw new Exception("Azure client requires storageAccountName"))	×
14	val accountKey =
15	parameters.getOrElse("accountKey", ConfigHelper.getHadoopAzureConfig(storageAccountName))	×
16	new AzureGateway(storageAccountName, accountKey)	×
17	}
18
19	override def doesBucketPathExist(bucketName: String, filePath: String): Boolean = {
20	azureStorageConnection.doesBucketPathExist(bucketName, filePath)	×
21	}
22
23	override def copyInputStreamToBucket(
24	bucketName: String,
25	filePath: String,
26	sourceFilePath: String): Unit = {
27	azureStorageConnection.copyInputStreamToBucket(bucketName, filePath, sourceFilePath)	×
28	}
29
30	override def downloadFilesFromBucketToDirectory(
31	bucketName: String,
32	filePath: String,
33	directoryPath: String,
34	isIndex: Boolean): Unit = {
35	azureStorageConnection.downloadFilesFromBucketToDirectory(	×
36	bucketName,
37	filePath,
38	directoryPath,
39	isIndex)
40	}
41
42	}

JohnSnowLabs / spark-nlp / 8054290840

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous