Merge branch 'master' into feature/hbase-improvements
Project: http://git-wip-us.apache.org/repos/asf/metamodel/repo Commit: http://git-wip-us.apache.org/repos/asf/metamodel/commit/5e700b5d Tree: http://git-wip-us.apache.org/repos/asf/metamodel/tree/5e700b5d Diff: http://git-wip-us.apache.org/repos/asf/metamodel/diff/5e700b5d Branch: refs/heads/master Commit: 5e700b5d95184bcceac30cc59707e8510e366c4b Parents: 9f40295 a868f71 Author: Arjan Seijkens <[email protected]> Authored: Tue Jun 19 15:43:15 2018 +0200 Committer: Arjan Seijkens <[email protected]> Committed: Tue Jun 19 15:43:15 2018 +0200 ---------------------------------------------------------------------- .../apache/metamodel/AbstractDataContext.java | 2 + .../org/apache/metamodel/BatchUpdateScript.java | 3 + .../java/org/apache/metamodel/DataContext.java | 2 + .../org/apache/metamodel/MetaModelHelper.java | 2 +- .../metamodel/QueryPostprocessDataContext.java | 2 + .../java/org/apache/metamodel/UpdateScript.java | 3 + .../apache/metamodel/UpdateableDataContext.java | 3 + .../annotations/InterfaceStability.java | 56 ++++ .../apache/metamodel/data/AbstractDataSet.java | 1 - .../java/org/apache/metamodel/query/Query.java | 2 + .../org/apache/metamodel/schema/Column.java | 3 + .../org/apache/metamodel/schema/ColumnType.java | 2 + .../apache/metamodel/schema/Relationship.java | 3 + .../org/apache/metamodel/schema/Schema.java | 2 + .../java/org/apache/metamodel/schema/Table.java | 3 + ...del-integrationtest-configuration.properties | 7 + kafka/pom.xml | 52 ++++ .../kafka/ConsumerAndProducerFactory.java | 35 +++ .../kafka/KafkaConsumerAndProducerFactory.java | 162 +++++++++++ .../metamodel/kafka/KafkaDataContext.java | 281 +++++++++++++++++++ .../apache/metamodel/kafka/KafkaDataSet.java | 102 +++++++ .../metamodel/kafka/KafkaInsertBuilder.java | 54 ++++ .../metamodel/kafka/KafkaUpdateCallback.java | 85 ++++++ .../kafka/KafkaDataContextIntegrationTest.java | 186 ++++++++++++ .../metamodel/kafka/KafkaDataContextTest.java | 172 ++++++++++++ .../apache/metamodel/kafka/KafkaTestServer.java | 92 ++++++ .../metamodel/neo4j/ColumnTypeResolver.java | 137 +++++++++ .../neo4j/Neo4jCypherQueryBuilder.java | 53 ++-- .../metamodel/neo4j/Neo4jDataContext.java | 278 ++++++++++-------- .../apache/metamodel/neo4j/Neo4jDataSet.java | 56 +++- .../metamodel/neo4j/Neo4jRequestWrapper.java | 56 ++-- .../metamodel/neo4j/ColumnTypeResolverTest.java | 76 +++++ pom.xml | 1 + ...del-integrationtest-configuration.properties | 7 + 34 files changed, 1785 insertions(+), 196 deletions(-) ----------------------------------------------------------------------
