Skip to content

Commit 7ba0474

Browse files
author
Ajay Kannan
committed
---
yaml --- r: 4519 b: refs/heads/logging-alpha c: a68a0b6 h: refs/heads/master i: 4517: d1f299c 4515: 6e43420 4511: 2f3d867
1 parent e2702b8 commit 7ba0474

38 files changed

Lines changed: 325 additions & 308 deletions

File tree

‎[refs]‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ refs/heads/compute-alpha: 969cba2627f1d53d352cc4a5ffe0879dacf65e6c
1212
refs/heads/dns-alpha: 2f90e7e338349287ace33375896907af0f032ca1
1313
refs/heads/dns-alpha-batch: 17442b07867021b85d0452f5f3eda29a3413288f
1414
refs/heads/gcs-nio: 283aeaf15efdcf3621eb6859f05e55ad7764375d
15-
refs/heads/logging-alpha: 9412d69a48f4062e45758bbe394a4811c3c29a09
15+
refs/heads/logging-alpha: a68a0b60c09f990073b0d5103b11dcd9596e73ea
1616
refs/tags/v0.1.0: a615317f7424ed58621b1f65d5c4d8cbbe8a6ed8
1717
refs/tags/v0.1.1: 7a7f6985fe465e9dd6a075af55493f42b4933be0
1818
refs/tags/v0.1.2: 3eb3fe866ba22487686048f45d927b8c8638ea3f

‎branches/logging-alpha/README.md‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,6 @@ Java idiomatic client for [Google Cloud Platform][cloud-platform] services.
66
[![Build Status](https://travis-ci.org/GoogleCloudPlatform/gcloud-java.svg?branch=master)](https://travis-ci.org/GoogleCloudPlatform/gcloud-java)
77
[![Coverage Status](https://coveralls.io/repos/GoogleCloudPlatform/gcloud-java/badge.svg?branch=master)](https://coveralls.io/r/GoogleCloudPlatform/gcloud-java?branch=master)
88
[![Maven](https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java.svg)]( https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java.svg)
9-
[![Codacy Badge](https://api.codacy.com/project/badge/grade/9da006ad7c3a4fe1abd142e77c003917)](https://www.codacy.com/app/mziccard/gcloud-java)
10-
[![Dependency Status](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969/badge.svg?style=flat)](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969)
119

1210
- [Homepage] (https://googlecloudplatform.github.io/gcloud-java/)
1311
- [API Documentation] (http://googlecloudplatform.github.io/gcloud-java/apidocs)

‎branches/logging-alpha/codacy-conf.json‎

Lines changed: 0 additions & 1 deletion
This file was deleted.

‎branches/logging-alpha/gcloud-java-bigquery/README.md‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,6 @@ Java idiomatic client for [Google Cloud BigQuery] (https://cloud.google.com/bigq
66
[![Build Status](https://travis-ci.org/GoogleCloudPlatform/gcloud-java.svg?branch=master)](https://travis-ci.org/GoogleCloudPlatform/gcloud-java)
77
[![Coverage Status](https://coveralls.io/repos/GoogleCloudPlatform/gcloud-java/badge.svg?branch=master)](https://coveralls.io/r/GoogleCloudPlatform/gcloud-java?branch=master)
88
[![Maven](https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)]( https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)
9-
[![Codacy Badge](https://api.codacy.com/project/badge/grade/9da006ad7c3a4fe1abd142e77c003917)](https://www.codacy.com/app/mziccard/gcloud-java)
10-
[![Dependency Status](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969/badge.svg?style=flat)](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969)
119

1210
- [Homepage] (https://googlecloudplatform.github.io/gcloud-java/)
1311
- [API Documentation] (http://googlecloudplatform.github.io/gcloud-java/apidocs/index.html?com/google/gcloud/bigquery/package-summary.html)

‎branches/logging-alpha/gcloud-java-bigquery/pom.xml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
<dependency>
3131
<groupId>com.google.apis</groupId>
3232
<artifactId>google-api-services-bigquery</artifactId>
33-
<version>v2-rev261-1.21.0</version>
33+
<version>v2-rev254-1.21.0</version>
3434
<scope>compile</scope>
3535
<exclusions>
3636
<exclusion>
@@ -48,7 +48,7 @@
4848
<dependency>
4949
<groupId>org.easymock</groupId>
5050
<artifactId>easymock</artifactId>
51-
<version>3.4</version>
51+
<version>3.3</version>
5252
<scope>test</scope>
5353
</dependency>
5454
</dependencies>

‎branches/logging-alpha/gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/InsertAllRequest.java‎

Lines changed: 29 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -52,15 +52,15 @@ public class InsertAllRequest implements Serializable {
5252
* id used by BigQuery to detect duplicate insertion requests on a best-effort basis.
5353
*
5454
* <p>Example usage of creating a row to insert:
55-
* <pre> {@code
56-
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
57-
* Map<String, Object> recordContent = new HashMap<String, Object>();
58-
* recordContent.put("subfieldName1", "value");
59-
* recordContent.put("subfieldName2", repeatedFieldValue);
60-
* Map<String, Object> rowContent = new HashMap<String, Object>();
61-
* rowContent.put("fieldName1", true);
62-
* rowContent.put("fieldName2", recordContent);
63-
* RowToInsert row = new RowToInsert("rowId", rowContent);
55+
* <pre> {@code
56+
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
57+
* Map<String, Object> recordContent = new HashMap<String, Object>();
58+
* recordContent.put("subfieldName1", "value");
59+
* recordContent.put("subfieldName2", repeatedFieldValue);
60+
* Map<String, Object> rowContent = new HashMap<String, Object>();
61+
* rowContent.put("fieldName1", true);
62+
* rowContent.put("fieldName2", recordContent);
63+
* RowToInsert row = new RowToInsert("rowId", rowContent);
6464
* }</pre>
6565
*
6666
* @see <a href ="https://cloud.google.com/bigquery/streaming-data-into-bigquery#dataconsistency">
@@ -177,16 +177,16 @@ public Builder addRow(RowToInsert rowToInsert) {
177177
* Adds a row to be inserted with associated id.
178178
*
179179
* <p>Example usage of adding a row with associated id:
180-
* <pre> {@code
181-
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
182-
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
183-
* Map<String, Object> recordContent = new HashMap<String, Object>();
184-
* recordContent.put("subfieldName1", "value");
185-
* recordContent.put("subfieldName2", repeatedFieldValue);
186-
* Map<String, Object> rowContent = new HashMap<String, Object>();
187-
* rowContent.put("fieldName1", true);
188-
* rowContent.put("fieldName2", recordContent);
189-
* builder.addRow("rowId", rowContent);
180+
* <pre> {@code
181+
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
182+
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
183+
* Map<String, Object> recordContent = new HashMap<String, Object>();
184+
* recordContent.put("subfieldName1", "value");
185+
* recordContent.put("subfieldName2", repeatedFieldValue);
186+
* Map<String, Object> rowContent = new HashMap<String, Object>();
187+
* rowContent.put("fieldName1", true);
188+
* rowContent.put("fieldName2", recordContent);
189+
* builder.addRow("rowId", rowContent);
190190
* }</pre>
191191
*/
192192
public Builder addRow(String id, Map<String, Object> content) {
@@ -198,16 +198,16 @@ public Builder addRow(String id, Map<String, Object> content) {
198198
* Adds a row to be inserted without an associated id.
199199
*
200200
* <p>Example usage of adding a row without an associated id:
201-
* <pre> {@code
202-
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
203-
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
204-
* Map<String, Object> recordContent = new HashMap<String, Object>();
205-
* recordContent.put("subfieldName1", "value");
206-
* recordContent.put("subfieldName2", repeatedFieldValue);
207-
* Map<String, Object> rowContent = new HashMap<String, Object>();
208-
* rowContent.put("fieldName1", true);
209-
* rowContent.put("fieldName2", recordContent);
210-
* builder.addRow(rowContent);
201+
* <pre> {@code
202+
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
203+
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
204+
* Map<String, Object> recordContent = new HashMap<String, Object>();
205+
* recordContent.put("subfieldName1", "value");
206+
* recordContent.put("subfieldName2", repeatedFieldValue);
207+
* Map<String, Object> rowContent = new HashMap<String, Object>();
208+
* rowContent.put("fieldName1", true);
209+
* rowContent.put("fieldName2", recordContent);
210+
* builder.addRow(rowContent);
211211
* }</pre>
212212
*/
213213
public Builder addRow(Map<String, Object> content) {

‎branches/logging-alpha/gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/QueryRequest.java‎

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -35,26 +35,26 @@
3535
* {@link QueryResponse#jobCompleted()} returns {@code true}.
3636
*
3737
* <p>Example usage of a query request:
38-
* <pre> {@code
39-
* // Substitute "field", "table" and "dataset" with real field, table and dataset identifiers
40-
* QueryRequest request = QueryRequest.builder("SELECT field FROM table")
41-
* .defaultDataset(DatasetId.of("dataset"))
42-
* .maxWaitTime(60000L)
43-
* .maxResults(1000L)
44-
* .build();
45-
* QueryResponse response = bigquery.query(request);
46-
* while (!response.jobCompleted()) {
47-
* Thread.sleep(1000);
48-
* response = bigquery.getQueryResults(response.jobId());
49-
* }
50-
* List<BigQueryError> executionErrors = response.executionErrors();
51-
* // look for errors in executionErrors
52-
* QueryResult result = response.result();
53-
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
54-
* while(rowIterator.hasNext()) {
55-
* List<FieldValue> row = rowIterator.next();
56-
* // do something with row
57-
* }
38+
* <pre> {@code
39+
* // Substitute "field", "table" and "dataset" with real field, table and dataset identifiers
40+
* QueryRequest request = QueryRequest.builder("SELECT field FROM table")
41+
* .defaultDataset(DatasetId.of("dataset"))
42+
* .maxWaitTime(60000L)
43+
* .maxResults(1000L)
44+
* .build();
45+
* QueryResponse response = bigquery.query(request);
46+
* while (!response.jobCompleted()) {
47+
* Thread.sleep(1000);
48+
* response = bigquery.getQueryResults(response.jobId());
49+
* }
50+
* List<BigQueryError> executionErrors = response.executionErrors();
51+
* // look for errors in executionErrors
52+
* QueryResult result = response.result();
53+
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
54+
* while(rowIterator.hasNext()) {
55+
* List<FieldValue> row = rowIterator.next();
56+
* // do something with row
57+
* }
5858
* }</pre>
5959
*
6060
* @see <a href="https://cloud.google.com/bigquery/docs/reference/v2/jobs/query">Query</a>

‎branches/logging-alpha/gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/QueryResponse.java‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -29,20 +29,20 @@
2929
* Query Request ({@link BigQuery#query(QueryRequest)}).
3030
*
3131
* <p>Example usage of a query response:
32-
* <pre> {@code
33-
* QueryResponse response = bigquery.query(request);
34-
* while (!response.jobCompleted()) {
35-
* Thread.sleep(1000);
36-
* response = bigquery.getQueryResults(response.jobId());
37-
* }
38-
* List<BigQueryError> executionErrors = response.executionErrors();
39-
* // look for errors in executionErrors
40-
* QueryResult result = response.result();
41-
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
42-
* while(rowIterator.hasNext()) {
43-
* List<FieldValue> row = rowIterator.next();
44-
* // do something with row
45-
* }
32+
* <pre> {@code
33+
* QueryResponse response = bigquery.query(request);
34+
* while (!response.jobCompleted()) {
35+
* Thread.sleep(1000);
36+
* response = bigquery.getQueryResults(response.jobId());
37+
* }
38+
* List<BigQueryError> executionErrors = response.executionErrors();
39+
* // look for errors in executionErrors
40+
* QueryResult result = response.result();
41+
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
42+
* while(rowIterator.hasNext()) {
43+
* List<FieldValue> row = rowIterator.next();
44+
* // do something with row
45+
* }
4646
* }</pre>
4747
*
4848
* @see <a href="https://cloud.google.com/bigquery/docs/reference/v2/jobs/getQueryResults">Get Query

branches/logging-alpha/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/it/ITBigQueryTest.java renamed to branches/logging-alpha/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/ITBigQueryTest.java

Lines changed: 25 additions & 53 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,14 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.google.gcloud.bigquery.it;
18-
17+
package com.google.gcloud.bigquery;
18+
19+
import static com.google.gcloud.bigquery.BigQuery.DatasetField;
20+
import static com.google.gcloud.bigquery.BigQuery.JobField;
21+
import static com.google.gcloud.bigquery.BigQuery.JobListOption;
22+
import static com.google.gcloud.bigquery.BigQuery.JobOption;
23+
import static com.google.gcloud.bigquery.BigQuery.TableField;
24+
import static com.google.gcloud.bigquery.BigQuery.TableOption;
1925
import static org.junit.Assert.assertEquals;
2026
import static org.junit.Assert.assertFalse;
2127
import static org.junit.Assert.assertNotNull;
@@ -26,43 +32,7 @@
2632
import com.google.common.collect.ImmutableList;
2733
import com.google.common.collect.ImmutableMap;
2834
import com.google.gcloud.Page;
29-
import com.google.gcloud.WriteChannel;
30-
import com.google.gcloud.bigquery.BigQuery;
31-
import com.google.gcloud.bigquery.BigQuery.DatasetField;
3235
import com.google.gcloud.bigquery.BigQuery.DatasetOption;
33-
import com.google.gcloud.bigquery.BigQuery.JobField;
34-
import com.google.gcloud.bigquery.BigQuery.JobListOption;
35-
import com.google.gcloud.bigquery.BigQuery.JobOption;
36-
import com.google.gcloud.bigquery.BigQuery.TableField;
37-
import com.google.gcloud.bigquery.BigQuery.TableOption;
38-
import com.google.gcloud.bigquery.BigQueryError;
39-
import com.google.gcloud.bigquery.BigQueryException;
40-
import com.google.gcloud.bigquery.CopyJobConfiguration;
41-
import com.google.gcloud.bigquery.Dataset;
42-
import com.google.gcloud.bigquery.DatasetId;
43-
import com.google.gcloud.bigquery.DatasetInfo;
44-
import com.google.gcloud.bigquery.ExternalTableDefinition;
45-
import com.google.gcloud.bigquery.ExtractJobConfiguration;
46-
import com.google.gcloud.bigquery.Field;
47-
import com.google.gcloud.bigquery.FieldValue;
48-
import com.google.gcloud.bigquery.FormatOptions;
49-
import com.google.gcloud.bigquery.InsertAllRequest;
50-
import com.google.gcloud.bigquery.InsertAllResponse;
51-
import com.google.gcloud.bigquery.Job;
52-
import com.google.gcloud.bigquery.JobInfo;
53-
import com.google.gcloud.bigquery.JobStatistics;
54-
import com.google.gcloud.bigquery.LoadJobConfiguration;
55-
import com.google.gcloud.bigquery.QueryJobConfiguration;
56-
import com.google.gcloud.bigquery.QueryRequest;
57-
import com.google.gcloud.bigquery.QueryResponse;
58-
import com.google.gcloud.bigquery.Schema;
59-
import com.google.gcloud.bigquery.StandardTableDefinition;
60-
import com.google.gcloud.bigquery.Table;
61-
import com.google.gcloud.bigquery.TableDefinition;
62-
import com.google.gcloud.bigquery.TableId;
63-
import com.google.gcloud.bigquery.TableInfo;
64-
import com.google.gcloud.bigquery.ViewDefinition;
65-
import com.google.gcloud.bigquery.WriteChannelConfiguration;
6636
import com.google.gcloud.bigquery.testing.RemoteBigQueryHelper;
6737
import com.google.gcloud.storage.BlobInfo;
6838
import com.google.gcloud.storage.BucketInfo;
@@ -75,6 +45,7 @@
7545
import org.junit.Test;
7646
import org.junit.rules.Timeout;
7747

48+
import java.io.FileNotFoundException;
7849
import java.io.IOException;
7950
import java.nio.ByteBuffer;
8051
import java.nio.charset.StandardCharsets;
@@ -169,7 +140,7 @@ public class ITBigQueryTest {
169140
public Timeout globalTimeout = Timeout.seconds(300);
170141

171142
@BeforeClass
172-
public static void beforeClass() throws InterruptedException {
143+
public static void beforeClass() throws IOException, InterruptedException {
173144
RemoteBigQueryHelper bigqueryHelper = RemoteBigQueryHelper.create();
174145
RemoteGcsHelper gcsHelper = RemoteGcsHelper.create();
175146
bigquery = bigqueryHelper.options().service();
@@ -198,9 +169,8 @@ public static void afterClass() throws ExecutionException, InterruptedException
198169
if (bigquery != null) {
199170
RemoteBigQueryHelper.forceDelete(bigquery, DATASET);
200171
}
201-
if (storage != null) {
202-
boolean wasDeleted = RemoteGcsHelper.forceDelete(storage, BUCKET, 10, TimeUnit.SECONDS);
203-
if (!wasDeleted && LOG.isLoggable(Level.WARNING)) {
172+
if (storage != null && !RemoteGcsHelper.forceDelete(storage, BUCKET, 10, TimeUnit.SECONDS)) {
173+
if (LOG.isLoggable(Level.WARNING)) {
204174
LOG.log(Level.WARNING, "Deletion of bucket {0} timed out, bucket is not empty", BUCKET);
205175
}
206176
}
@@ -684,9 +654,10 @@ public void testQuery() throws InterruptedException {
684654
rowCount++;
685655
}
686656
assertEquals(2, rowCount);
687-
Job queryJob = bigquery.getJob(response.jobId());
688-
JobStatistics.QueryStatistics statistics = queryJob.statistics();
689-
assertNotNull(statistics.queryPlan());
657+
// todo(mziccard) uncomment as soon as #624 is closed
658+
// Job queryJob = bigquery.getJob(response.jobId());
659+
// JobStatistics.QueryStatistics statistics = queryJob.statistics();
660+
// assertNotNull(statistics.queryPlan());
690661
}
691662

692663
@Test
@@ -714,7 +685,7 @@ public void testListJobsWithSelectedFields() {
714685
}
715686

716687
@Test
717-
public void testCreateAndGetJob() {
688+
public void testCreateAndGetJob() throws InterruptedException {
718689
String sourceTableName = "test_create_and_get_job_source_table";
719690
String destinationTableName = "test_create_and_get_job_destination_table";
720691
TableId sourceTable = TableId.of(DATASET, sourceTableName);
@@ -746,7 +717,7 @@ public void testCreateAndGetJob() {
746717
}
747718

748719
@Test
749-
public void testCreateAndGetJobWithSelectedFields() {
720+
public void testCreateAndGetJobWithSelectedFields() throws InterruptedException {
750721
String sourceTableName = "test_create_and_get_job_with_selected_fields_source_table";
751722
String destinationTableName = "test_create_and_get_job_with_selected_fields_destination_table";
752723
TableId sourceTable = TableId.of(DATASET, sourceTableName);
@@ -851,9 +822,10 @@ public void testQueryJob() throws InterruptedException {
851822
}
852823
assertEquals(2, rowCount);
853824
assertTrue(bigquery.delete(DATASET, tableName));
854-
Job queryJob = bigquery.getJob(remoteJob.jobId());
855-
JobStatistics.QueryStatistics statistics = queryJob.statistics();
856-
assertNotNull(statistics.queryPlan());
825+
// todo(mziccard) uncomment as soon as #624 is closed
826+
// Job queryJob = bigquery.getJob(remoteJob.jobId());
827+
// JobStatistics.QueryStatistics statistics = queryJob.statistics();
828+
// assertNotNull(statistics.queryPlan());
857829
}
858830

859831
@Test
@@ -902,20 +874,20 @@ public void testCancelJob() throws InterruptedException {
902874
}
903875

904876
@Test
905-
public void testCancelNonExistingJob() {
877+
public void testCancelNonExistingJob() throws InterruptedException {
906878
assertFalse(bigquery.cancel("test_cancel_non_existing_job"));
907879
}
908880

909881
@Test
910-
public void testInsertFromFile() throws InterruptedException {
882+
public void testInsertFromFile() throws InterruptedException, FileNotFoundException {
911883
String destinationTableName = "test_insert_from_file_table";
912884
TableId tableId = TableId.of(DATASET, destinationTableName);
913885
WriteChannelConfiguration configuration = WriteChannelConfiguration.builder(tableId)
914886
.formatOptions(FormatOptions.json())
915887
.createDisposition(JobInfo.CreateDisposition.CREATE_IF_NEEDED)
916888
.schema(TABLE_SCHEMA)
917889
.build();
918-
try (WriteChannel channel = bigquery.writer(configuration)) {
890+
try (TableDataWriteChannel channel = bigquery.writer(configuration)) {
919891
channel.write(ByteBuffer.wrap(JSON_CONTENT.getBytes(StandardCharsets.UTF_8)));
920892
} catch (IOException e) {
921893
fail("IOException was not expected");

‎branches/logging-alpha/gcloud-java-contrib/README.md‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,6 @@ Google Cloud Java Contributions
33

44
Packages that provide higher-level abstraction/functionality for common gcloud-java use cases.
55

6-
[![Build Status](https://travis-ci.org/GoogleCloudPlatform/gcloud-java.svg?branch=master)](https://travis-ci.org/GoogleCloudPlatform/gcloud-java)
7-
[![Coverage Status](https://coveralls.io/repos/GoogleCloudPlatform/gcloud-java/badge.svg?branch=master)](https://coveralls.io/r/GoogleCloudPlatform/gcloud-java?branch=master)
8-
[![Maven](https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)]( https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)
9-
[![Codacy Badge](https://api.codacy.com/project/badge/grade/9da006ad7c3a4fe1abd142e77c003917)](https://www.codacy.com/app/mziccard/gcloud-java)
10-
[![Dependency Status](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969/badge.svg?style=flat)](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969)
11-
126
Quickstart
137
----------
148
If you are using Maven, add this to your pom.xml file

0 commit comments

Comments
 (0)