Merge branch 'STREAMS-389' # Conflicts: # streams-plugins/pom.xml # streams-plugins/streams-plugin-scala/pom.xml
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/abc58b42 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/abc58b42 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/abc58b42 Branch: refs/heads/master Commit: abc58b42db71cad1a9baad51c7a479e56ca4ab4c Parents: 8e929eb d9674f7 Author: Steve Blackmon @steveblackmon <[email protected]> Authored: Wed Oct 12 12:27:15 2016 -0500 Committer: Steve Blackmon @steveblackmon <[email protected]> Committed: Wed Oct 12 12:27:15 2016 -0500 ---------------------------------------------------------------------- pom.xml | 7 +- streams-config/pom.xml | 2 +- .../src/main/jsonschema/com/twitter/tweet.json | 6 +- streams-plugins/pom.xml | 6 + .../streams-plugin-cassandra/pom.xml | 251 ++++++++++++ .../StreamsCassandraGenerationConfig.java | 81 ++++ .../StreamsCassandraResourceGenerator.java | 366 ++++++++++++++++++ .../StreamsCassandraResourceGeneratorMojo.java | 62 +++ .../src/site/markdown/index.md | 36 ++ ...treamsCassandraResourceGeneratorCLITest.java | 52 +++ ...reamsCassandraResourceGeneratorMojoTest.java | 78 ++++ .../StreamsCassandraResourceGeneratorTest.java | 80 ++++ .../resources/streams-plugin-cassandra/pom.xml | 76 ++++ .../streams-plugin-elasticsearch/pom.xml | 252 ++++++++++++ .../StreamsElasticsearchGenerationConfig.java | 81 ++++ .../StreamsElasticsearchResourceGenerator.java | 380 +++++++++++++++++++ ...reamsElasticsearchResourceGeneratorMojo.java | 72 ++++ .../src/site/markdown/index.md | 38 ++ ...msElasticsearchResourceGeneratorCLITest.java | 39 ++ ...sElasticsearchResourceGeneratorMojoTest.java | 50 +++ ...reamsElasticsearchResourceGeneratorTest.java | 110 ++++++ .../streams-plugin-elasticsearch/pom.xml | 76 ++++ streams-plugins/streams-plugin-hbase/pom.xml | 251 ++++++++++++ .../hbase/StreamsHbaseGenerationConfig.java | 90 +++++ .../hbase/StreamsHbaseResourceGenerator.java | 193 ++++++++++ .../StreamsHbaseResourceGeneratorMojo.java | 71 ++++ .../src/site/markdown/index.md | 40 ++ .../StreamsHbaseResourceGeneratorCLITest.java | 41 ++ .../StreamsHbaseResourceGeneratorMojoTest.java | 65 ++++ .../test/StreamsHbaseResourceGeneratorTest.java | 102 +++++ .../test/resources/streams-plugin-hbase/pom.xml | 77 ++++ streams-plugins/streams-plugin-hive/pom.xml | 251 ++++++++++++ .../hive/StreamsHiveGenerationConfig.java | 83 ++++ .../hive/StreamsHiveResourceGenerator.java | 308 +++++++++++++++ .../hive/StreamsHiveResourceGeneratorMojo.java | 63 +++ .../src/site/markdown/index.md | 40 ++ .../StreamsHiveResourceGeneratorCLITest.java | 41 ++ .../StreamsHiveResourceGeneratorMojoTest.java | 64 ++++ .../test/StreamsHiveResourceGeneratorTest.java | 102 +++++ .../src/test/resources/Tweet.hql | 297 +++++++++++++++ .../src/test/resources/expected/activity.hql | 203 ++++++++++ .../src/test/resources/expected/collection.hql | 47 +++ .../src/test/resources/expected/media_link.hql | 11 + .../src/test/resources/expected/object.hql | 61 +++ .../resources/expected/objectTypes/place.hql | 79 ++++ .../test/resources/expected/verbs/purchase.hql | 203 ++++++++++ .../test/resources/streams-plugin-hive/pom.xml | 76 ++++ streams-plugins/streams-plugin-pig/pom.xml | 251 ++++++++++++ .../plugins/pig/StreamsPigGenerationConfig.java | 83 ++++ .../pig/StreamsPigResourceGenerator.java | 305 +++++++++++++++ .../pig/StreamsPigResourceGeneratorMojo.java | 61 +++ .../src/site/markdown/index.md | 38 ++ .../StreamsPigResourceGeneratorCLITest.java | 39 ++ .../StreamsPigResourceGeneratorMojoTest.java | 64 ++++ .../test/StreamsPigResourceGeneratorTest.java | 100 +++++ .../src/test/resources/expected/media_link.pig | 1 + .../resources/expected/objectTypes/file.pig | 1 + .../expected/objectTypes/photo-album.pig | 1 + .../test/resources/streams-plugin-pig/pom.xml | 76 ++++ streams-plugins/streams-plugin-pojo/pom.xml | 253 ++++++++++++ .../plugins/StreamsPojoGenerationConfig.java | 68 ++++ .../plugins/StreamsPojoSourceGenerator.java | 75 ++++ .../plugins/StreamsPojoSourceGeneratorMojo.java | 95 +++++ .../src/site/markdown/index.md | 38 ++ .../test/StreamsPojoSourceGeneratorCLITest.java | 43 +++ .../StreamsPojoSourceGeneratorMojoTest.java | 68 ++++ .../test/StreamsPojoSourceGeneratorTest.java | 72 ++++ .../test/resources/streams-plugin-pojo/pom.xml | 131 +++++++ streams-plugins/streams-plugin-scala/pom.xml | 12 + .../plugins/StreamsScalaSourceGenerator.java | 351 +++++++++++++++++ .../StreamsScalaSourceGeneratorMojo.java | 59 +++ .../src/site/markdown/index.md | 36 ++ .../test/StreamsScalaSourceGeneratorTest.java | 55 +++ streams-pojo/pom.xml | 6 + streams-runtimes/streams-runtime-local/pom.xml | 2 +- streams-schemas/pom.xml | 39 ++ .../streams-schema-activitystreams/pom.xml | 82 ++++ .../src/main/jsonschema/activity.json | 108 ++++++ .../src/main/jsonschema/collection.json | 47 +++ .../src/main/jsonschema/media_link.json | 34 ++ .../src/main/jsonschema/object.json | 98 +++++ .../src/main/jsonschema/objectTypes/alert.json | 19 + .../jsonschema/objectTypes/application.json | 19 + .../main/jsonschema/objectTypes/article.json | 19 + .../src/main/jsonschema/objectTypes/audio.json | 19 + .../src/main/jsonschema/objectTypes/badge.json | 19 + .../src/main/jsonschema/objectTypes/binary.json | 19 + .../main/jsonschema/objectTypes/bookmark.json | 19 + .../main/jsonschema/objectTypes/comment.json | 19 + .../src/main/jsonschema/objectTypes/device.json | 19 + .../src/main/jsonschema/objectTypes/event.json | 51 +++ .../src/main/jsonschema/objectTypes/file.json | 25 ++ .../src/main/jsonschema/objectTypes/folder.json | 19 + .../src/main/jsonschema/objectTypes/game.json | 19 + .../src/main/jsonschema/objectTypes/group.json | 19 + .../src/main/jsonschema/objectTypes/image.json | 22 ++ .../src/main/jsonschema/objectTypes/issue.json | 25 ++ .../src/main/jsonschema/objectTypes/job.json | 19 + .../src/main/jsonschema/objectTypes/list.json | 28 ++ .../src/main/jsonschema/objectTypes/note.json | 19 + .../src/main/jsonschema/objectTypes/offer.json | 19 + .../jsonschema/objectTypes/organization.json | 19 + .../src/main/jsonschema/objectTypes/page.json | 19 + .../main/jsonschema/objectTypes/permission.json | 36 ++ .../src/main/jsonschema/objectTypes/person.json | 25 ++ .../jsonschema/objectTypes/photo-album.json | 19 + .../src/main/jsonschema/objectTypes/photo.json | 23 ++ .../src/main/jsonschema/objectTypes/place.json | 39 ++ .../main/jsonschema/objectTypes/playlist.json | 19 + .../main/jsonschema/objectTypes/process.json | 19 + .../main/jsonschema/objectTypes/product.json | 25 ++ .../main/jsonschema/objectTypes/property.json | 48 +++ .../main/jsonschema/objectTypes/question.json | 28 ++ .../src/main/jsonschema/objectTypes/review.json | 22 ++ .../src/main/jsonschema/objectTypes/role.json | 25 ++ .../main/jsonschema/objectTypes/service.json | 19 + .../src/main/jsonschema/objectTypes/song.json | 19 + .../src/main/jsonschema/objectTypes/status.json | 19 + .../src/main/jsonschema/objectTypes/task.json | 40 ++ .../src/main/jsonschema/objectTypes/team.json | 19 + .../src/main/jsonschema/objectTypes/video.json | 19 + .../src/main/jsonschema/verbs/accept.json | 24 ++ .../src/main/jsonschema/verbs/access.json | 24 ++ .../src/main/jsonschema/verbs/acknowledge.json | 24 ++ .../src/main/jsonschema/verbs/add.json | 24 ++ .../src/main/jsonschema/verbs/agree.json | 24 ++ .../src/main/jsonschema/verbs/append.json | 24 ++ .../src/main/jsonschema/verbs/approve.json | 24 ++ .../src/main/jsonschema/verbs/archive.json | 24 ++ .../src/main/jsonschema/verbs/assign.json | 24 ++ .../src/main/jsonschema/verbs/at.json | 24 ++ .../src/main/jsonschema/verbs/attach.json | 24 ++ .../src/main/jsonschema/verbs/attend.json | 24 ++ .../src/main/jsonschema/verbs/author.json | 24 ++ .../src/main/jsonschema/verbs/authorize.json | 24 ++ .../src/main/jsonschema/verbs/borrow.json | 24 ++ .../src/main/jsonschema/verbs/build.json | 24 ++ .../src/main/jsonschema/verbs/cancel.json | 24 ++ .../src/main/jsonschema/verbs/checkin.json | 24 ++ .../src/main/jsonschema/verbs/close.json | 24 ++ .../src/main/jsonschema/verbs/complete.json | 24 ++ .../src/main/jsonschema/verbs/confirm.json | 24 ++ .../src/main/jsonschema/verbs/consume.json | 24 ++ .../src/main/jsonschema/verbs/create.json | 24 ++ .../src/main/jsonschema/verbs/delete.json | 24 ++ .../src/main/jsonschema/verbs/deliver.json | 24 ++ .../src/main/jsonschema/verbs/deny.json | 24 ++ .../src/main/jsonschema/verbs/disagree.json | 24 ++ .../src/main/jsonschema/verbs/dislike.json | 24 ++ .../src/main/jsonschema/verbs/experience.json | 24 ++ .../src/main/jsonschema/verbs/favorite.json | 24 ++ .../src/main/jsonschema/verbs/find.json | 24 ++ .../jsonschema/verbs/flag-as-inappropriate.json | 24 ++ .../src/main/jsonschema/verbs/follow.json | 24 ++ .../src/main/jsonschema/verbs/give.json | 24 ++ .../src/main/jsonschema/verbs/host.json | 24 ++ .../src/main/jsonschema/verbs/ignore.json | 24 ++ .../src/main/jsonschema/verbs/insert.json | 24 ++ .../src/main/jsonschema/verbs/install.json | 24 ++ .../src/main/jsonschema/verbs/interact.json | 24 ++ .../src/main/jsonschema/verbs/invite.json | 24 ++ .../src/main/jsonschema/verbs/join.json | 24 ++ .../src/main/jsonschema/verbs/leave.json | 24 ++ .../src/main/jsonschema/verbs/like.json | 24 ++ .../src/main/jsonschema/verbs/listen.json | 24 ++ .../src/main/jsonschema/verbs/lose.json | 24 ++ .../src/main/jsonschema/verbs/make-friend.json | 24 ++ .../src/main/jsonschema/verbs/open.json | 24 ++ .../src/main/jsonschema/verbs/play.json | 24 ++ .../src/main/jsonschema/verbs/post.json | 24 ++ .../src/main/jsonschema/verbs/present.json | 24 ++ .../src/main/jsonschema/verbs/purchase.json | 24 ++ .../src/main/jsonschema/verbs/qualify.json | 24 ++ .../src/main/jsonschema/verbs/read.json | 24 ++ .../src/main/jsonschema/verbs/receive.json | 24 ++ .../src/main/jsonschema/verbs/reject.json | 24 ++ .../main/jsonschema/verbs/remove-friend.json | 24 ++ .../src/main/jsonschema/verbs/remove.json | 24 ++ .../src/main/jsonschema/verbs/replace.json | 24 ++ .../main/jsonschema/verbs/request-friend.json | 24 ++ .../src/main/jsonschema/verbs/request.json | 24 ++ .../src/main/jsonschema/verbs/resolve.json | 24 ++ .../src/main/jsonschema/verbs/retract.json | 24 ++ .../src/main/jsonschema/verbs/return.json | 24 ++ .../src/main/jsonschema/verbs/rsvp-maybe.json | 24 ++ .../src/main/jsonschema/verbs/rsvp-no.json | 24 ++ .../src/main/jsonschema/verbs/rsvp-yes.json | 24 ++ .../src/main/jsonschema/verbs/satisfy.json | 24 ++ .../src/main/jsonschema/verbs/save.json | 24 ++ .../src/main/jsonschema/verbs/schedule.json | 24 ++ .../src/main/jsonschema/verbs/search.json | 24 ++ .../src/main/jsonschema/verbs/sell.json | 24 ++ .../src/main/jsonschema/verbs/send.json | 24 ++ .../src/main/jsonschema/verbs/share.json | 24 ++ .../src/main/jsonschema/verbs/sponsor.json | 24 ++ .../src/main/jsonschema/verbs/start.json | 24 ++ .../main/jsonschema/verbs/stop-following.json | 24 ++ .../src/main/jsonschema/verbs/submit.json | 24 ++ .../src/main/jsonschema/verbs/tag.json | 24 ++ .../src/main/jsonschema/verbs/terminate.json | 24 ++ .../src/main/jsonschema/verbs/tie.json | 24 ++ .../src/main/jsonschema/verbs/unfavorite.json | 24 ++ .../src/main/jsonschema/verbs/unlike.json | 24 ++ .../src/main/jsonschema/verbs/unsatisfy.json | 24 ++ .../src/main/jsonschema/verbs/unsave.json | 24 ++ .../src/main/jsonschema/verbs/unshare.json | 24 ++ .../src/main/jsonschema/verbs/update.json | 34 ++ .../src/main/jsonschema/verbs/use.json | 24 ++ .../src/main/jsonschema/verbs/watch.json | 24 ++ .../src/main/jsonschema/verbs/win.json | 24 ++ .../src/main/xmlschema/activity.xsd | 94 +++++ streams-util/pom.xml | 89 ++++- .../java/org/apache/streams/util/GuidUtils.java | 2 +- .../org/apache/streams/util/RegexUtils.java | 3 + .../apache/streams/util/SerializationUtil.java | 3 +- .../apache/streams/util/schema/FieldType.java | 14 + .../apache/streams/util/schema/FieldUtil.java | 34 ++ .../apache/streams/util/schema/FileUtil.java | 77 ++++ .../streams/util/schema/GenerationConfig.java | 116 ++++++ .../org/apache/streams/util/schema/Schema.java | 57 +++ .../apache/streams/util/schema/SchemaStore.java | 42 ++ .../streams/util/schema/SchemaStoreImpl.java | 347 +++++++++++++++++ .../apache/streams/util/schema/SchemaUtil.java | 49 +++ .../org/apache/streams/util/schema/URIUtil.java | 30 ++ .../util/schema/test/SchemaOrderingTest.java | 150 ++++++++ .../util/schema/test/SchemaStoreTest.java | 71 ++++ .../src/test/resources/activities/accept.json | 16 + .../src/test/resources/activities/access.json | 17 + .../test/resources/activities/acknowledge.json | 16 + .../src/test/resources/activities/add.json | 21 + .../src/test/resources/activities/agree.json | 15 + .../src/test/resources/activities/append.json | 16 + .../src/test/resources/activities/approve.json | 20 + .../src/test/resources/activities/archive.json | 15 + .../src/test/resources/activities/assign.json | 20 + .../src/test/resources/activities/at.json | 15 + .../src/test/resources/activities/attach.json | 20 + .../src/test/resources/activities/attend.json | 15 + .../src/test/resources/activities/author.json | 15 + .../test/resources/activities/authorize.json | 23 ++ .../src/test/resources/activities/borrow.json | 21 + .../src/test/resources/activities/build.json | 16 + .../src/test/resources/activities/cancel.json | 16 + .../src/test/resources/activities/checkin.json | 16 + .../src/test/resources/activities/close.json | 16 + .../src/test/resources/activities/complete.json | 16 + .../src/test/resources/activities/confirm.json | 17 + .../src/test/resources/activities/consume.json | 16 + .../src/test/resources/activities/create.json | 15 + .../src/test/resources/activities/delete.json | 16 + .../src/test/resources/activities/deliver.json | 20 + .../src/test/resources/activities/deny.json | 23 ++ .../src/test/resources/activities/disagree.json | 30 ++ .../src/test/resources/activities/dislike.json | 15 + .../test/resources/activities/experience.json | 16 + .../src/test/resources/activities/favorite.json | 15 + .../src/test/resources/activities/find.json | 19 + .../activities/flag-as-inappropriate.json | 24 ++ .../src/test/resources/activities/follow.json | 15 + .../src/test/resources/activities/give.json | 28 ++ .../src/test/resources/activities/host.json | 15 + .../src/test/resources/activities/ignore.json | 15 + .../src/test/resources/activities/insert.json | 19 + .../src/test/resources/activities/install.json | 18 + .../src/test/resources/activities/interact.json | 16 + .../src/test/resources/activities/invite.json | 19 + .../src/test/resources/activities/join.json | 15 + .../src/test/resources/activities/leave.json | 15 + .../src/test/resources/activities/like.json | 22 ++ .../src/test/resources/activities/listen.json | 15 + .../src/test/resources/activities/lose.json | 15 + .../test/resources/activities/make-friend.json | 15 + .../src/test/resources/activities/open.json | 15 + .../src/test/resources/activities/play.json | 15 + .../src/test/resources/activities/post.json | 25 ++ .../src/test/resources/activities/present.json | 15 + .../src/test/resources/activities/purchase.json | 16 + .../src/test/resources/activities/qualify.json | 15 + .../src/test/resources/activities/read.json | 16 + .../src/test/resources/activities/receive.json | 16 + .../src/test/resources/activities/reject.json | 15 + .../resources/activities/remove-friend.json | 15 + .../src/test/resources/activities/remove.json | 23 ++ .../src/test/resources/activities/replace.json | 19 + .../resources/activities/request-friend.json | 16 + .../src/test/resources/activities/request.json | 23 ++ .../src/test/resources/activities/resolve.json | 15 + .../src/test/resources/activities/retract.json | 26 ++ .../src/test/resources/activities/return.json | 19 + .../test/resources/activities/rsvp-maybe.json | 16 + .../src/test/resources/activities/rsvp-no.json | 16 + .../src/test/resources/activities/rsvp-yes.json | 16 + .../src/test/resources/activities/satisfy.json | 21 + .../src/test/resources/activities/save.json | 20 + .../src/test/resources/activities/schedule.json | 15 + .../src/test/resources/activities/search.json | 21 + .../src/test/resources/activities/sell.json | 19 + .../src/test/resources/activities/send.json | 19 + .../src/test/resources/activities/share.json | 16 + .../src/test/resources/activities/sponsor.json | 17 + .../src/test/resources/activities/start.json | 15 + .../resources/activities/stop-following.json | 15 + .../src/test/resources/activities/submit.json | 15 + .../src/test/resources/activities/tag.json | 19 + .../test/resources/activities/terminate.json | 15 + .../src/test/resources/activities/tie.json | 24 ++ .../test/resources/activities/unfavorite.json | 15 + .../src/test/resources/activities/unlike.json | 15 + .../test/resources/activities/unsatisfy.json | 20 + .../src/test/resources/activities/unsave.json | 15 + .../src/test/resources/activities/unshare.json | 15 + .../src/test/resources/activities/update.json | 15 + .../src/test/resources/activities/use.json | 15 + .../src/test/resources/activities/watch.json | 16 + .../src/test/resources/activities/win.json | 15 + streams-util/src/test/resources/media_link.json | 7 + .../src/test/resources/objects/event.json | 18 + .../src/test/resources/objects/group.json | 16 + .../src/test/resources/objects/issue.json | 9 + .../src/test/resources/objects/note.json | 12 + .../src/test/resources/objects/permission.json | 9 + .../src/test/resources/objects/place.json | 9 + .../src/test/resources/objects/task.json | 16 + .../src/test/resources/objects/video.json | 8 + 324 files changed, 13757 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/abc58b42/pom.xml ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/abc58b42/streams-config/pom.xml ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/abc58b42/streams-pojo/pom.xml ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/abc58b42/streams-runtimes/streams-runtime-local/pom.xml ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/abc58b42/streams-util/pom.xml ----------------------------------------------------------------------
