[incubator-pinot] branch master updated: adding column data type to result set (#5679)

[kishoreg]

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

kishoreg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new 020bb74  adding column data type to result set (#5679)
020bb74 is described below

commit 020bb743569ac241d686da43de5e39681fe3571b
Author: Kartik Khare <kharekar...@gmail.com>
AuthorDate: Sun Jul 12 12:10:05 2020 +0530

    adding column data type to result set (#5679)
    
    Co-authored-by: Kartik Khare <kartikkhare@Kartiks-MacBook-Pro.local>
---
 .../src/main/java/org/apache/pinot/client/AbstractResultSet.java  | 6 ++++++
 .../src/main/java/org/apache/pinot/client/ResultSet.java          | 8 ++++++++
 .../main/java/org/apache/pinot/client/ResultTableResultSet.java   | 5 +++++
 3 files changed, 19 insertions(+)

diff --git 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/AbstractResultSet.java
 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/AbstractResultSet.java
index 87cb98c..e1dbdd2 100644
--- 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/AbstractResultSet.java
+++ 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/AbstractResultSet.java
@@ -22,6 +22,12 @@ package org.apache.pinot.client;
  * Shared implementation between the different ResultSets.
  */
 abstract class AbstractResultSet implements ResultSet {
+
+  @Override
+  public String getColumnDataType(int columnIndex) {
+    return null;
+  }
+
   @Override
   public int getInt(int rowIndex) {
     return getInt(rowIndex, 0);
diff --git 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultSet.java
 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultSet.java
index 05e1e21..502d8e4 100644
--- 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultSet.java
+++ 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultSet.java
@@ -45,6 +45,14 @@ public interface ResultSet {
   String getColumnName(int columnIndex);
 
   /**
+   * Returns the column type at a given index.
+   *
+   * @param columnIndex The index of the column for which to retrieve the name
+   * @return The data type of the column at the given column index. null if 
data type is not supported
+   */
+  String getColumnDataType(int columnIndex);
+
+  /**
    * Obtains the integer value for the given row.
    *
    * @param rowIndex The index of the row
diff --git 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultTableResultSet.java
 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultTableResultSet.java
index 86a7c17..a913622 100644
--- 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultTableResultSet.java
+++ 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/ResultTableResultSet.java
@@ -54,6 +54,11 @@ class ResultTableResultSet extends AbstractResultSet {
   }
 
   @Override
+  public String getColumnDataType(int columnIndex) {
+    return _columnDataTypesArray.get(columnIndex).asText();
+  }
+
+  @Override
   public String getString(int rowIndex, int columnIndex) {
     JsonNode jsonValue = _rowsArray.get(rowIndex).get(columnIndex);
     if (jsonValue.isTextual()) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org