[incubator-streampipes-extensions] branch dev updated: Add method description

[ze...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git


The following commit(s) were added to refs/heads/dev by this push:
     new 3cfe373  Add method description
3cfe373 is described below

commit 3cfe37333225d65bdf94d792d8be26bee8a9a604
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Feb 18 16:57:22 2020 +0100

    Add method description
---
 .../apache/streampipes/sinks/internal/jvm/datalake/DataLake.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
index cd552b3..a3254eb 100644
--- a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
+++ b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
@@ -127,6 +127,12 @@ public class DataLake implements EventSink<DataLakeParameters> {
 
   }
 
+  /**
+   * Adds a new measurement to the StreamPipes data lake
+   * @param measure
+   * @param eventSchema
+   * @throws SpRuntimeException
+   */
   private void registerAtDataLake(String measure, EventSchema eventSchema) throws SpRuntimeException {
     HttpClient httpClient = new DefaultHttpClient();
     String url = SinksInternalJvmConfig.INSTANCE.getStreamPipesBackendUrl();