gcs-storage-stream


License

License

MIT
GroupId

GroupId

com.emarsys
ArtifactId

ArtifactId

gcs-storage-stream_2.13
Last Version

Last Version

2.0.0
Release Date

Release Date

Type

Type

jar
Description

Description

gcs-storage-stream
gcs-storage-stream
Project URL

Project URL

https://github.com/emartech/gcs-bigquery-scala-api
Project Organization

Project Organization

com.emarsys
Source Code Management

Source Code Management

https://github.com/emartech/gcs-bigquery-scala-api

Download gcs-storage-stream_2.13

How to add to project

<!-- https://jarcasting.com/artifacts/com.emarsys/gcs-storage-stream_2.13/ -->
<dependency>
    <groupId>com.emarsys</groupId>
    <artifactId>gcs-storage-stream_2.13</artifactId>
    <version>2.0.0</version>
</dependency>
// https://jarcasting.com/artifacts/com.emarsys/gcs-storage-stream_2.13/
implementation 'com.emarsys:gcs-storage-stream_2.13:2.0.0'
// https://jarcasting.com/artifacts/com.emarsys/gcs-storage-stream_2.13/
implementation ("com.emarsys:gcs-storage-stream_2.13:2.0.0")
'com.emarsys:gcs-storage-stream_2.13:jar:2.0.0'
<dependency org="com.emarsys" name="gcs-storage-stream_2.13" rev="2.0.0">
  <artifact name="gcs-storage-stream_2.13" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.emarsys', module='gcs-storage-stream_2.13', version='2.0.0')
)
libraryDependencies += "com.emarsys" % "gcs-storage-stream_2.13" % "2.0.0"
[com.emarsys/gcs-storage-stream_2.13 "2.0.0"]

Dependencies

compile (4)

Group / Artifact Type Version
org.scala-lang : scala-library jar 2.13.1
com.typesafe.akka : akka-stream_2.13 jar 2.5.31
com.typesafe.akka : akka-actor_2.13 jar 2.5.31
com.google.cloud : google-cloud-storage jar 1.113.0

test (1)

Group / Artifact Type Version
org.scalatest : scalatest_2.13 jar 3.2.0

Project Modules

There are no modules declared in this project.

BigQuery Scala Api

Codeship Status for emartech/gcs-bigquery-scala-api Maven Central Maven Central

Overview

There are many libraries for Google Cloud Platform except for Scala.

Currently we aim at

  • Create BigQuery jobs for running queries and tasks

Getting Started

Create api instance:

    val bigQueryInstance = BigQueryApi(projectName, Config.credentialWrite)

Create TableReference for a BigQuery table:

    val tableReference = BqTableReference("[project]", "[dataSet]", "[table]")

Create command factory which will use the api instance to create commands:

     val commandFactory = new CommandFactory {
          override implicit val bigQuery = bigQueryInstance
     }

Following table commands can be used:

  • drop table
  • create table
  • insert data

Following job commands can be used:

  • copy data to table (TableReference)
  • extract data to url in file format (default csv)
  • insert data from file (default csv)

Testing

Specify the GCS_PROJECT_NAME, GCS_PRIVATE_KEY_ID, GCS_READ_KEY, GCS_EMAIL_PREFIX and GCS_CLIENT_ID env vars in the .env file, then run sbt test or sbt it:test.

Creating a release

This library is using sbt-release-early for releasing artifacts. Every push will be released to maven central, see the plugins documentation on the versioning schema.

To cut a final release:

Choose the appropriate version number according to semver then create and push a tag with it, prefixed with v. For example:

$ git tag -s v1.1.1
$ git push --tag

After pushing the tag, while it is not strictly necessary, please draft a release on github with this tag too.

com.emarsys

Emarsys Technologies Ltd.

Versions

Version
2.0.0
1.3.0