[03/32] 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/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
Authored: Mon Mar 28 08:32:19 2016 -0500
Committer: Steve Blackmon @steveblackmon
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 schemaFiles;
+
+
List> serializableClasses = detectSerializableClasses();
LOGGER.info("Detected {} serialiables:", serializableClasses.size());
[03/32] 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/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/feature/STREAMS-389,398
Commit: 6501b27cdc148e5044b893197b5dc38d34aa8aeb
Parents: 1c78ecc
Author: Steve Blackmon @steveblackmon
Authored: Mon Mar 28 08:32:19 2016 -0500
Committer: Steve Blackmon @steveblackmon
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 schemaFiles;
+
+
List> serializableClasses = detectSerializableClasses();
LOGGER.info("Detected {} serialiables:", serializableClasses.size());
