You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Aditya (JIRA)" <ji...@apache.org> on 2018/10/25 20:37:00 UTC
[jira] [Created] (SAMZA-1968) Samza-sql: Change Calcite sql type
for samza sql rel message __key__ to accept any format.
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)