@Test public void testExceptionWithoutTypeSchema() { thrown.expect(ValidationException.class); ExecutionEnvironment env = MLEnvironmentFactory.getDefault().getExecutionEnvironment(); DataSet<Row> input = env.fromElements(Row.of("s1")).map(new GenericTypeMap()); DataSetConversionUtil.toTable(MLEnvironmentFactory.DEFAULT_ML_ENVIRONMENT_ID, input, new String[] {"f0"}); }
public static Table toTable(Long sessionId, DataSet <Row> data, TableSchema schema) { return toTable(sessionId, data, schema.getFieldNames(), schema.getFieldTypes()); }
DataSetConversionUtil { public static Table toTable(Long sessionId, DataSet <Row> data, TableSchema schema) { return toTable(sessionId, data, schema.getFieldNames(), schema.getFieldTypes()); } }
DataSetConversionUtil { public static Table toTable(Long sessionId, DataSet <Row> data, TableSchema schema) { return toTable(sessionId, data, schema.getFieldNames(), schema.getFieldTypes()); }  }
DataSetConversionUtil { public static Table toTable(Long sessionId, DataSet <Row> data, TableSchema schema) { return toTable(sessionId, data, schema.getFieldNames(), schema.getFieldTypes()); }  static DataSet <Row> fromTable(Long sessionId, Table table); static Table toTable(Long sessionId, DataSet <Row> data, TableSchema schema); static Table toTable(Long sessionId, DataSet <Row> data, String[] colNames, TypeInformation <?>[] colTypes); static Table toTable(Long sessionId, DataSet <Row> data, String[] colNames); static Table toTable(MLEnvironment session, DataSet <Row> data, String[] colNames, TypeInformation <?>[] colTypes); static Table toTable(MLEnvironment session, DataSet <Row> data, String[] colNames); }
DataSetConversionUtil { public static Table toTable(Long sessionId, DataSet <Row> data, TableSchema schema) { return toTable(sessionId, data, schema.getFieldNames(), schema.getFieldTypes()); }  static DataSet <Row> fromTable(Long sessionId, Table table); static Table toTable(Long sessionId, DataSet <Row> data, TableSchema schema); static Table toTable(Long sessionId, DataSet <Row> data, String[] colNames, TypeInformation <?>[] colTypes); static Table toTable(Long sessionId, DataSet <Row> data, String[] colNames); static Table toTable(MLEnvironment session, DataSet <Row> data, String[] colNames, TypeInformation <?>[] colTypes); static Table toTable(MLEnvironment session, DataSet <Row> data, String[] colNames);  }