@Test public void testMissingSource() { String[] types = new String[] { "identity", "hash", "year", "month", "day", "hour", "minute", "dateFormat"}; for (final String type : types) { TestHelpers.assertThrows("Should reject missing source", ValidationException.class, new Runnable() { @Override public void run() { PartitionStrategyParser.parse("[ {\"type\": \"" + type + "\"} ]"); } } ); } }
public static PartitionStrategy parse(String json) { return buildPartitionStrategy(JsonUtil.parse(json)); }
PartitionStrategyParser { public static PartitionStrategy parse(String json) { return buildPartitionStrategy(JsonUtil.parse(json)); } }
PartitionStrategyParser { public static PartitionStrategy parse(String json) { return buildPartitionStrategy(JsonUtil.parse(json)); }  }
PartitionStrategyParser { public static PartitionStrategy parse(String json) { return buildPartitionStrategy(JsonUtil.parse(json)); }  static PartitionStrategy parse(String json); static PartitionStrategy parse(File file); static PartitionStrategy parse(InputStream in); static boolean hasEmbeddedStrategy(Schema schema); static PartitionStrategy parseFromSchema(Schema schema); static Schema removeEmbeddedStrategy(Schema schema); static Schema embedPartitionStrategy(Schema schema, PartitionStrategy strategy); static String toString(PartitionStrategy strategy, boolean pretty); }
PartitionStrategyParser { public static PartitionStrategy parse(String json) { return buildPartitionStrategy(JsonUtil.parse(json)); }  static PartitionStrategy parse(String json); static PartitionStrategy parse(File file); static PartitionStrategy parse(InputStream in); static boolean hasEmbeddedStrategy(Schema schema); static PartitionStrategy parseFromSchema(Schema schema); static Schema removeEmbeddedStrategy(Schema schema); static Schema embedPartitionStrategy(Schema schema, PartitionStrategy strategy); static String toString(PartitionStrategy strategy, boolean pretty);  }