in iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/common/PipeRow.java [121:146]
public Object getObject(final int columnIndex) {
switch (getDataType(columnIndex)) {
case INT32:
return getInt(columnIndex);
case DATE:
return getDate(columnIndex);
case INT64:
case TIMESTAMP:
return getLong(columnIndex);
case FLOAT:
return getFloat(columnIndex);
case DOUBLE:
return getDouble(columnIndex);
case BOOLEAN:
return getBoolean(columnIndex);
case TEXT:
case BLOB:
case STRING:
return getBinary(columnIndex);
default:
throw new UnsupportedOperationException(
String.format(
"unsupported data type %s for column %s",
getDataType(columnIndex), columnNameStringList[columnIndex]));
}
}