You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2016/10/12 17:41:37 UTC
[04/38] incubator-streams git commit: rename Hive Generator
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/7d318c3f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/7d318c3f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/7d318c3f
Branch: refs/heads/master
Commit: 7d318c3fba9faf106eed8797263d52114a312d6c
Parents: ded4ad6
Author: Steve Blackmon @steveblackmon <sb...@apache.org>
Authored: Mon Mar 28 08:32:19 2016 -0500
Committer: Steve Blackmon @steveblackmon <sb...@apache.org>
Committed: Wed Jun 1 12:49:27 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/7d318c3f/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());