Aditya created SAMZA-1968: ----------------------------- Summary: Samza-sql: Change Calcite sql type for samza sql rel message __key__ to accept any format. Key: SAMZA-1968 URL: https://issues.apache.org/jira/browse/SAMZA-1968 Project: Samza Issue Type: Bug Reporter: Aditya Assignee: Aditya
Currently, it is set to VARCHAR. private Table createTableFromRelSchema(RelDataType relationalSchema) { return new AbstractTable() { public RelDataType getRowType(RelDataTypeFactory typeFactory) { List<RelDataTypeField> fieldsList = new ArrayList<>(); fieldsList.add(new RelDataTypeFieldImpl(SamzaSqlRelMessage.KEY_NAME, 0, typeFactory.createTypeWithNullability(typeFactory.createSqlType(SqlTypeName.VARCHAR), true))); fieldsList.addAll(relationalSchema.getFieldList()); return new RelRecordType(fieldsList); } }; } -- This message was sent by Atlassian JIRA (v7.6.3#76005)