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 <[email protected]>
AuthorDate: Sun Jul 12 12:10:05 2020 +0530
adding column data type to result set (#5679)
Co-authored-by: Kartik Khare <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
