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)