rename Hive Generator
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/6501b27c Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/6501b27c Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/6501b27c Branch: refs/heads/STREAMS-389 Commit: 6501b27cdc148e5044b893197b5dc38d34aa8aeb Parents: 1c78ecc Author: Steve Blackmon @steveblackmon <sblack...@apache.org> Authored: Mon Mar 28 08:32:19 2016 -0500 Committer: Steve Blackmon @steveblackmon <sblack...@apache.org> Committed: Mon Mar 28 08:32:19 2016 -0500 ---------------------------------------------------------------------- .../streams/plugins/StreamsHiveResourceGenerator.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6501b27c/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/StreamsHiveResourceGenerator.java ---------------------------------------------------------------------- diff --git a/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/StreamsHiveResourceGenerator.java b/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/StreamsHiveResourceGenerator.java index 4edacf0..1efb15e 100644 --- a/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/StreamsHiveResourceGenerator.java +++ b/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/StreamsHiveResourceGenerator.java @@ -27,15 +27,14 @@ public class StreamsHiveResourceGenerator implements Runnable { private final static String LS = System.getProperty("line.separator"); - private StreamsPojoHiveMojo mojo; + private StreamsHiveResourceGeneratorMojo mojo; String inDir = "./target/test-classes/activities"; String outDir = "./target/generated-sources/hive"; - String packages[] = {"org.apache.streams.pojo.json"}; public void main(String[] args) { StreamsHiveResourceGenerator streamsHiveResourceGenerator = new StreamsHiveResourceGenerator(); - Thread thread = new Thread(streamsPojoScala); + Thread thread = new Thread(streamsHiveResourceGenerator); thread.start(); try { thread.join(); @@ -47,7 +46,7 @@ public class StreamsHiveResourceGenerator implements Runnable { return; } - public StreamsHiveResourceGenerator(StreamsPojoHiveMojo mojo) { + public StreamsHiveResourceGenerator(StreamsHiveResourceGeneratorMojo mojo) { this.mojo = mojo; if ( mojo != null && mojo.getTarget() != null && @@ -67,6 +66,9 @@ public class StreamsHiveResourceGenerator implements Runnable { public void run() { + List<File> schemaFiles; + + List<Class<?>> serializableClasses = detectSerializableClasses(); LOGGER.info("Detected {} serialiables:", serializableClasses.size());
