[jira] [Created] (SAMZA-1968) Samza-sql: Change Calcite sql type for samza sql rel message __key__ to accept any format.

[Aditya (JIRA)]

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)