This is an automated email from the ASF dual-hosted git repository.
djkevincr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/gora.git.
from c7cae4d Merge pull request #155 from madhawa-gunasekara/GORA-545
new 0361086 GORA-548 Apache Flink support for Gora
new 405bbf6 Add Flink job test utils
new b4b0228 Merge branch 'master' of https://github.com/apache/gora into
flink_backend
new 2325c61 Improve Flink module with custom serializer
new c4e29f3 Merge branch 'master' of https://github.com/apache/gora into
flink_backend
new e6e6c2d Fix HBase Store Flink
new 62ac8bb Fix javadoc issues
new 8bb377b Merge pull request #140 from djkevincr/flink_backend
The 1141 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
gora-core/pom.xml | 28 ++-
.../apache/gora/examples/flink/FlinkWordCount.java | 165 ++++++++++++++++
.../org/apache/gora/flink/GoraFlinkEngine.java | 132 +++++++++++++
.../org/apache/gora/flink/PersistentTypeInfo.java | 46 +++++
.../gora/flink/PersistentTypeInfoFactory.java | 44 +++++
.../gora/flink/PersistentTypeSerializer.java | 117 +++++++++++
.../apache/gora/{spark => flink}/package-info.java | 4 +-
.../org/apache/gora/mapreduce/GoraInputSplit.java | 5 +-
.../gora/persistency/impl/PersistentBase.java | 3 +
.../java/org/apache/gora/query/impl/QueryBase.java | 2 +-
.../apache/gora/mapreduce/MapReduceTestUtils.java | 31 +++
.../hbase/mapreduce/TestHBaseStoreWordCount.java | 5 +
.../mongodb/mapreduce/TestMongoStoreWordCount.java | 5 +
.../apache/gora/orientdb/store/OrientDBStore.java | 5 +
.../mapreduce/TestOrientDBStoreWordCount.java | 32 +--
gora-tutorial/pom.xml | 28 ++-
.../gora/tutorial/log/LogAnalyticsFlink.java | 220 +++++++++++++++++++++
pom.xml | 41 +++-
18 files changed, 891 insertions(+), 22 deletions(-)
create mode 100644
gora-core/src/examples/java/org/apache/gora/examples/flink/FlinkWordCount.java
create mode 100644
gora-core/src/main/java/org/apache/gora/flink/GoraFlinkEngine.java
create mode 100644
gora-core/src/main/java/org/apache/gora/flink/PersistentTypeInfo.java
create mode 100644
gora-core/src/main/java/org/apache/gora/flink/PersistentTypeInfoFactory.java
create mode 100644
gora-core/src/main/java/org/apache/gora/flink/PersistentTypeSerializer.java
copy gora-core/src/main/java/org/apache/gora/{spark =>
flink}/package-info.java (89%)
copy
gora-mongodb/src/test/java/org/apache/gora/mongodb/mapreduce/TestMongoStoreWordCount.java
=>
gora-orientdb/src/test/java/org/apache/gora/orientdb/mapreduce/TestOrientDBStoreWordCount.java
(62%)
create mode 100644
gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalyticsFlink.java
