public static ParamType getSchemaFromType(final Type type) {
    return getSchemaFromType(type, JAVA_TO_ARG_TYPE);
  }
@Test(expected = KsqlException.class)
  public void shouldThrowExceptionIfClassDoesntMapToSchema() {
    UdfUtil.getSchemaFromType(System.class);
  }