[ignite-extensions] branch master updated: IGNITE-13648 Tests failing for extensions modules - Fixes #29.
This is an automated email from the ASF dual-hosted git repository. samaitra pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git The following commit(s) were added to refs/heads/master by this push: new 0b54bc9 IGNITE-13648 Tests failing for extensions modules - Fixes #29. 0b54bc9 is described below commit 0b54bc993797e57ee44c0aa7813be05c36ae157b Author: samaitra AuthorDate: Sun Jan 10 15:43:53 2021 -0600 IGNITE-13648 Tests failing for extensions modules - Fixes #29. Signed-off-by: samaitra --- modules/kafka-ext/src/test/resources/example-ignite.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/kafka-ext/src/test/resources/example-ignite.xml b/modules/kafka-ext/src/test/resources/example-ignite.xml index f23a306..d3315e9 100644 --- a/modules/kafka-ext/src/test/resources/example-ignite.xml +++ b/modules/kafka-ext/src/test/resources/example-ignite.xml @@ -31,7 +31,7 @@ http://www.springframework.org/schema/util/spring-util.xsd";> - + @@ -62,7 +62,7 @@ -127.0.0.1:47500 +127.0.0.1:47500..47509
[ignite] branch ignite-2.9-docs updated: IGNITE-12951 Update documents for migrated extensions - Fixes #8488.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch ignite-2.9-docs
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/ignite-2.9-docs by this push:
new b31b35c IGNITE-12951 Update documents for migrated extensions - Fixes
#8488.
b31b35c is described below
commit b31b35c263b95a1b4e3612b641df6c2e6d96040f
Author: samaitra
AuthorDate: Thu Nov 26 14:16:27 2020 -0600
IGNITE-12951 Update documents for migrated extensions - Fixes #8488.
Signed-off-by: samaitra
(cherry picked from commit 15a5da500c08948ee081533af97a9f1c2c8330f8)
---
.../_docs/extensions-and-integrations/streaming/camel-streamer.adoc | 6 +++---
.../_docs/extensions-and-integrations/streaming/flink-streamer.adoc | 6 +++---
docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc| 2 +-
docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc | 4 ++--
.../_docs/extensions-and-integrations/streaming/kafka-streamer.adoc | 6 +++---
docs/_docs/extensions-and-integrations/streaming/mqtt-streamer.adoc | 2 +-
.../extensions-and-integrations/streaming/rocketmq-streamer.adoc| 6 +++---
.../_docs/extensions-and-integrations/streaming/storm-streamer.adoc | 6 +++---
.../extensions-and-integrations/streaming/twitter-streamer.adoc | 6 +++---
.../extensions-and-integrations/streaming/zeromq-streamer.adoc | 4 ++--
10 files changed, 24 insertions(+), 24 deletions(-)
diff --git
a/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
index 8734d81..a421293 100644
--- a/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
@@ -43,7 +43,7 @@ to interact with Ignite Caches, Compute, Events, Messaging,
etc. from within a C
== Maven Dependency
-To make use of the `ignite-camel` streamer, you need to add the following
dependency:
+To make use of the `ignite-camel-ext` streamer, you need to add the following
dependency:
[tabs]
--
@@ -52,8 +52,8 @@ tab:pom.xml[]
org.apache.ignite
-ignite-camel
-${ignite.version}
+ignite-camel-ext
+${ignite-camel-ext.version}
--
diff --git
a/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
index f25ed05..92ab398 100644
--- a/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
@@ -21,7 +21,7 @@ Starting data transfer to Ignite cache can be done with the
following steps.
. Import Ignite Flink Sink Module in Maven Project
If you are using Maven to manage dependencies of your project, you can add
Flink module
-dependency like this (replace `${ignite.version}` with actual Ignite version
you are
+dependency like this (replace `${ignite-flink-ext.version}` with actual Ignite
Flink Extension version you are
interested in):
+
[tabs]
@@ -38,8 +38,8 @@ tab:pom.xml[]
...
org.apache.ignite
-ignite-flink
-${ignite.version}
+ignite-flink-ext
+${ignite-flink-ext.version}
...
diff --git a/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
b/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
index 97a741d..3697c7c 100644
--- a/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
@@ -41,7 +41,7 @@ plugins.d/
`-- libext
|-- cache-api-1.0.0.jar
|-- ignite-core-x.x.x.jar
- |-- ignite-flume-x.x.x.jar <-- IgniteSink
+ |-- ignite-flume-ext.x.x.x.jar <-- IgniteSink
|-- ignite-spring-x.x.x.jar
|-- spring-aop-4.1.0.RELEASE.jar
|-- spring-beans-4.1.0.RELEASE.jar
diff --git a/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
index 5c7c883..b3f9be9 100644
--- a/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
@@ -116,8 +116,8 @@ tab:pom.xml[]
org.apache.ignite
-ignite-jms11
-${ignite.version}
+ignite-jms11-ext
+${ignite-jms11-ext.version}
--
diff --git
a/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
index f00946a..a45fa4d 100644
--- a/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
@@ -153,7 +153,7 @@ http://node1:8080/ignite?cmd=size&cacheName=cache1
== Streaming data with Ignite Kafka Streamer Module
If you
[ignite] branch master updated: IGNITE-12951 Update documents for migrated extensions - Fixes #8488.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 15a5da5 IGNITE-12951 Update documents for migrated extensions - Fixes
#8488.
15a5da5 is described below
commit 15a5da500c08948ee081533af97a9f1c2c8330f8
Author: samaitra
AuthorDate: Thu Nov 26 14:16:27 2020 -0600
IGNITE-12951 Update documents for migrated extensions - Fixes #8488.
Signed-off-by: samaitra
---
.../_docs/extensions-and-integrations/streaming/camel-streamer.adoc | 6 +++---
.../_docs/extensions-and-integrations/streaming/flink-streamer.adoc | 6 +++---
docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc| 2 +-
docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc | 4 ++--
.../_docs/extensions-and-integrations/streaming/kafka-streamer.adoc | 6 +++---
docs/_docs/extensions-and-integrations/streaming/mqtt-streamer.adoc | 2 +-
.../extensions-and-integrations/streaming/rocketmq-streamer.adoc| 6 +++---
.../_docs/extensions-and-integrations/streaming/storm-streamer.adoc | 6 +++---
.../extensions-and-integrations/streaming/twitter-streamer.adoc | 6 +++---
.../extensions-and-integrations/streaming/zeromq-streamer.adoc | 4 ++--
10 files changed, 24 insertions(+), 24 deletions(-)
diff --git
a/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
index 8734d81..a421293 100644
--- a/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/camel-streamer.adoc
@@ -43,7 +43,7 @@ to interact with Ignite Caches, Compute, Events, Messaging,
etc. from within a C
== Maven Dependency
-To make use of the `ignite-camel` streamer, you need to add the following
dependency:
+To make use of the `ignite-camel-ext` streamer, you need to add the following
dependency:
[tabs]
--
@@ -52,8 +52,8 @@ tab:pom.xml[]
org.apache.ignite
-ignite-camel
-${ignite.version}
+ignite-camel-ext
+${ignite-camel-ext.version}
--
diff --git
a/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
index f25ed05..92ab398 100644
--- a/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/flink-streamer.adoc
@@ -21,7 +21,7 @@ Starting data transfer to Ignite cache can be done with the
following steps.
. Import Ignite Flink Sink Module in Maven Project
If you are using Maven to manage dependencies of your project, you can add
Flink module
-dependency like this (replace `${ignite.version}` with actual Ignite version
you are
+dependency like this (replace `${ignite-flink-ext.version}` with actual Ignite
Flink Extension version you are
interested in):
+
[tabs]
@@ -38,8 +38,8 @@ tab:pom.xml[]
...
org.apache.ignite
-ignite-flink
-${ignite.version}
+ignite-flink-ext
+${ignite-flink-ext.version}
...
diff --git a/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
b/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
index 97a741d..3697c7c 100644
--- a/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/flume-sink.adoc
@@ -41,7 +41,7 @@ plugins.d/
`-- libext
|-- cache-api-1.0.0.jar
|-- ignite-core-x.x.x.jar
- |-- ignite-flume-x.x.x.jar <-- IgniteSink
+ |-- ignite-flume-ext.x.x.x.jar <-- IgniteSink
|-- ignite-spring-x.x.x.jar
|-- spring-aop-4.1.0.RELEASE.jar
|-- spring-beans-4.1.0.RELEASE.jar
diff --git a/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
index 5c7c883..b3f9be9 100644
--- a/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/jms-streamer.adoc
@@ -116,8 +116,8 @@ tab:pom.xml[]
org.apache.ignite
-ignite-jms11
-${ignite.version}
+ignite-jms11-ext
+${ignite-jms11-ext.version}
--
diff --git
a/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
b/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
index f00946a..a45fa4d 100644
--- a/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
+++ b/docs/_docs/extensions-and-integrations/streaming/kafka-streamer.adoc
@@ -153,7 +153,7 @@ http://node1:8080/ignite?cmd=size&cacheName=cache1
== Streaming data with Ignite Kafka Streamer Module
If you are using Maven to manage dependencies of your project, first of all
you will have to
[ignite-extensions] branch master updated: IGNITE-12951 Update documents for migrated extensions - Fixes #30.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new db7d987 IGNITE-12951 Update documents for migrated extensions - Fixes
#30.
db7d987 is described below
commit db7d9879de76445877cdf65cada2132bfae295b4
Author: samaitra
AuthorDate: Mon Nov 16 20:26:35 2020 -0600
IGNITE-12951 Update documents for migrated extensions - Fixes #30.
Signed-off-by: samaitra
---
modules/camel-ext/README.txt | 2 +-
modules/flink-ext/README.txt | 4 ++--
modules/flume-ext/README.txt | 2 +-
modules/jms11-ext/README.txt | 2 +-
modules/kafka-ext/README.txt | 2 +-
modules/mqtt-ext/README.txt | 2 +-
modules/pub-sub-ext/README.txt | 2 +-
modules/rocketmq-ext/README.txt | 2 +-
modules/spring-boot-autoconfigure-ext/README.txt | 4 ++--
modules/spring-boot-thin-client-autoconfigure-ext/README.txt | 4 ++--
modules/storm-ext/README.txt | 2 +-
modules/twitter-ext/README.txt | 2 +-
12 files changed, 15 insertions(+), 15 deletions(-)
diff --git a/modules/camel-ext/README.txt b/modules/camel-ext/README.txt
index 3786b4b..b300d51 100644
--- a/modules/camel-ext/README.txt
+++ b/modules/camel-ext/README.txt
@@ -26,7 +26,7 @@ interested in):
org.apache.ignite
ignite-camel-ext
-${ignite.version}
+${ignite-camel-ext.version}
...
diff --git a/modules/flink-ext/README.txt b/modules/flink-ext/README.txt
index a198b1b..dff74e9 100644
--- a/modules/flink-ext/README.txt
+++ b/modules/flink-ext/README.txt
@@ -20,8 +20,8 @@ interested in):
...
org.apache.ignite
-ignite-flink
-${ignite.version}
+ignite-flink-ext
+${ignite-flink-ext.version}
...
diff --git a/modules/flume-ext/README.txt b/modules/flume-ext/README.txt
index adcd021..2d4350c 100644
--- a/modules/flume-ext/README.txt
+++ b/modules/flume-ext/README.txt
@@ -4,7 +4,7 @@ Apache Ignite Flume Sink Module
IgniteSink is a Flume sink that extracts Events from an associated Flume
channel and injects into an Ignite cache.
Flume 1.7.0 is supported.
-IgniteSink, which can be found in 'optional/ignite-flume', and its
dependencies have to be included in the agent's classpath,
+IgniteSink, which can be found in 'ignite-flume-ext', and its dependencies
have to be included in the agent's classpath,
as described in the following subsection, before starting the Flume agent.
## Setting up and running
diff --git a/modules/jms11-ext/README.txt b/modules/jms11-ext/README.txt
index 0b61d55..ebf3ba0 100644
--- a/modules/jms11-ext/README.txt
+++ b/modules/jms11-ext/README.txt
@@ -21,7 +21,7 @@ interested in):
org.apache.ignite
ignite-jms11-ext
-${ignite.version}
+${ignite-jms11-ext.version}
...
diff --git a/modules/kafka-ext/README.txt b/modules/kafka-ext/README.txt
index 348d143..2185291 100644
--- a/modules/kafka-ext/README.txt
+++ b/modules/kafka-ext/README.txt
@@ -25,7 +25,7 @@ interested in):
org.apache.ignite
ignite-kafka-ext
-${ignite.version}
+${ignite-kafka-ext.version}
...
diff --git a/modules/mqtt-ext/README.txt b/modules/mqtt-ext/README.txt
index b90d301..b4b0432 100644
--- a/modules/mqtt-ext/README.txt
+++ b/modules/mqtt-ext/README.txt
@@ -21,7 +21,7 @@ interested in):
org.apache.ignite
ignite-mqtt-ext
-${ignite.version}
+${ignite-mqtt-ext.version}
...
diff --git a/modules/pub-sub-ext/README.txt b/modules/pub-sub-ext/README.txt
index 7a09479..604b7f9 100644
--- a/modules/pub-sub-ext/README.txt
+++ b/modules/pub-sub-ext/README.txt
@@ -21,7 +21,7 @@ interested in):
org.apache.ignite
ignite-pub-sub-ext
-${ignite.version}
+${ignite-pub-sub-ext.version}
...
diff --git a/modules/rocketmq-ext/README.txt b/modules/rocketmq-ext/README.txt
index 62e6af6..15be503 100644
--- a/modules/rocketmq-ext/README.txt
+++ b/modules/rocketmq-ext/README.txt
@@ -15,7 +15,7 @@ To use Ignite RocketMQ Streamer module, first import it to
your Maven project.
org.apache.ignite
ignite-rocketmq-ext
-${ignite.version}
+${ignite-rocketmq-ext.version}
[ignite] branch master updated: IGNITE-13539 Remove references for migrated Ignite Extensions modules from the assembly and osgi-karaf - Fixes #8460.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new b8aca2a IGNITE-13539 Remove references for migrated Ignite Extensions
modules from the assembly and osgi-karaf - Fixes #8460.
b8aca2a is described below
commit b8aca2a812cddf094677b9a68ae202da2926dbcf
Author: samaitra
AuthorDate: Mon Nov 16 20:23:21 2020 -0600
IGNITE-13539 Remove references for migrated Ignite Extensions modules from
the assembly and osgi-karaf - Fixes #8460.
Signed-off-by: samaitra
---
assembly/dependencies-apache-ignite-slim.xml | 4 ---
modules/osgi-karaf/src/main/resources/features.xml | 30 +++---
2 files changed, 15 insertions(+), 19 deletions(-)
diff --git a/assembly/dependencies-apache-ignite-slim.xml
b/assembly/dependencies-apache-ignite-slim.xml
index 96b28f8..e98695c 100644
--- a/assembly/dependencies-apache-ignite-slim.xml
+++ b/assembly/dependencies-apache-ignite-slim.xml
@@ -145,20 +145,17 @@
org.apache.ignite:ignite-aop
org.apache.ignite:ignite-aws
-org.apache.ignite:ignite-camel
org.apache.ignite:ignite-cassandra-serializers
org.apache.ignite:ignite-cassandra-store
org.apache.ignite:ignite-cloud
org.apache.ignite:ignite-direct-io
org.apache.ignite:ignite-gce
org.apache.ignite:ignite-jcl
-org.apache.ignite:ignite-jms11
org.apache.ignite:ignite-mesos
org.apache.ignite:ignite-ml
org.apache.ignite:ignite-ml-h2o-model-parser
org.apache.ignite:ignite-ml-spark-model-parser
org.apache.ignite:ignite-ml-xgboost-model-parser
-org.apache.ignite:ignite-mqtt
org.apache.ignite:ignite-osgi
org.apache.ignite:ignite-osgi-karaf
org.apache.ignite:ignite-osgi-paxlogging
@@ -167,7 +164,6 @@
org.apache.ignite:ignite-spark
org.apache.ignite:ignite-spark-2.4
org.apache.ignite:ignite-ssh
-org.apache.ignite:ignite-storm
org.apache.ignite:ignite-web
org.apache.ignite:ignite-yarn
org.apache.ignite:ignite-zookeeper
diff --git a/modules/osgi-karaf/src/main/resources/features.xml
b/modules/osgi-karaf/src/main/resources/features.xml
index 0ff71e4..207941a 100644
--- a/modules/osgi-karaf/src/main/resources/features.xml
+++ b/modules/osgi-karaf/src/main/resources/features.xml
@@ -32,14 +32,14 @@
ignite-core
ignite-aop
ignite-aws
-ignite-camel
-ignite-flume
+ignite-camel-ext
+ignite-flume-ext
ignite-indexing
ignite-jcl
-ignite-jms11
+ignite-jms11-ext
ignite-jta
ignite-kafka-ext
-ignite-mqtt
+ignite-mqtt-ext
ignite-rest-http
@@ -48,7 +48,7 @@
ignite-slf4j
ignite-spring
ignite-ssh
-ignite-twitter
+ignite-twitter-ext
ignite-urideploy
ignite-web
ignite-zookeeper
@@ -82,7 +82,7 @@
mvn:org.apache.ignite/ignite-aws/${project.version}
-
+
camel-core
-mvn:org.apache.ignite/ignite-camel/${project.version}
+mvn:org.apache.ignite/ignite-camel-ext/${ignite-camel-ext.version}
-
+
wrap
wrap:mvn:org.apache.flume/flume-ng-core/${flume.ng.version}$Bundle-SymbolicName=flume-ng-core&Bundle-Version=${flume.ng.version}
-mvn:org.apache.ignite/ignite-flume/${project.version}
+mvn:org.apache.ignite/ignite-flume-ext/${ignite-flume-ext.version}
@@ -139,12 +139,12 @@
mvn:org.apache.ignite/ignite-jcl/${project.version}
-
+
mvn:org.apache.geronimo.specs/geronimo-jms_1.1_spec/${jms.spec.version}
-mvn:org.apache.ignite/ignite-jms11/${project.version}
+mvn:org.apache.ignite/ignite-jms11-ext/${ignite-jms11-ext.version}
@@ -185,7 +185,7 @@
mvn:org.apache.ignite/ignite-log4j/${project.version}
-
+
@@ -193,7 +193,7 @@
mvn:com.google.guava/guava/${guava.version}
mvn:org.eclipse.paho/org.eclipse.paho.client.mqttv3/${paho.version}
wrap:mvn:com.github.rholder/guava-retrying/${guava.retrying.version}$Bundle-SymbolicName=guava-retrying&Bundle-SymbolicName=guava-retrying&Bundle-Version=${guava.retrying.version}
-mvn:org.apache.ignite/ignite-mqtt/${project.version}
+mvn:org.apache.ignite/ignite-mqtt-ext/$
[ignite-extensions] branch master updated: IGNITE-13517 Disable travis build until ignite nightly snapshots packages are published - Fixes #24.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 4187613 IGNITE-13517 Disable travis build until ignite nightly
snapshots packages are published - Fixes #24.
4187613 is described below
commit 418761346efd9a955668f2ee1a996c16af3cd6d9
Author: samaitra
AuthorDate: Sat Oct 17 16:24:28 2020 -0500
IGNITE-13517 Disable travis build until ignite nightly snapshots packages
are published - Fixes #24.
Signed-off-by: samaitra
---
.travis.yml | 46 --
1 file changed, 46 deletions(-)
diff --git a/.travis.yml b/.travis.yml
deleted file mode 100644
index 093d36e..000
--- a/.travis.yml
+++ /dev/null
@@ -1,46 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-matrix:
- include:
-- language: java
- os: linux
- dist: trusty
- install: skip
- jdk: openjdk8
- before_script:
-- echo $JVM_EXTRA_ARGS
- script: mvn clean install
- before_cache: rm -rfv $HOME/.m2/repository/org/apache/ignite
- cache: {directories: [$HOME/.m2/repository]}
-
-- language: java
- os: linux
- dist: trusty
- install: skip
- jdk: openjdk11
- before_script:
-- echo $JVM_EXTRA_ARGS
-- |
- export JVM_EXTRA_ARGS='--illegal-access=permit
- --add-exports=java.base/jdk.internal.misc=ALL-UNNAMED
- --add-exports=java.base/sun.nio.ch=ALL-UNNAMED
- --add-exports=java.management/com.sun.jmx.mbeanserver=ALL-UNNAMED
- --add-exports=jdk.internal.jvmstat/sun.jvmstat.monitor=ALL-UNNAMED
-
--add-exports=java.base/sun.reflect.generics.reflectiveObjects=ALL-UNNAMED
- -Djdk.tls.client.protocols=TLSv1.2'
- script: mvn clean install
- before_cache: rm -rfv $HOME/.m2/repository/org/apache/ignite
- cache: {directories: [$HOME/.m2/repository]}
[ignite] branch master updated: IGNITE-13394 Migrate Kafka module to ignite-extensions - Fixes #8222.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new c64d591 IGNITE-13394 Migrate Kafka module to ignite-extensions -
Fixes #8222.
c64d591 is described below
commit c64d5912cb30add9318c339a955ec8371b4254f0
Author: samaitra
AuthorDate: Sat Oct 10 00:57:20 2020 -0500
IGNITE-13394 Migrate Kafka module to ignite-extensions - Fixes #8222.
Signed-off-by: samaitra
---
assembly/dependencies-apache-ignite-slim.xml | 1 -
assembly/libs/README.txt | 1 -
modules/kafka/README.txt | 210
modules/kafka/licenses/apache-2.0.txt | 202
modules/kafka/pom.xml | 155 -
.../apache/ignite/stream/kafka/KafkaStreamer.java | 205
.../stream/kafka/connect/IgniteSinkConnector.java | 100 --
.../stream/kafka/connect/IgniteSinkConstants.java | 41 ---
.../stream/kafka/connect/IgniteSinkTask.java | 201
.../kafka/connect/IgniteSourceConnector.java | 90 --
.../kafka/connect/IgniteSourceConstants.java | 44 ---
.../stream/kafka/connect/IgniteSourceTask.java | 359 -
.../ignite/stream/kafka/connect/package-info.java | 22 --
.../connect/serialization/CacheEventConverter.java | 67
.../serialization/CacheEventDeserializer.java | 55
.../serialization/CacheEventSerializer.java| 55
.../kafka/connect/serialization/package-info.java | 22 --
.../apache/ignite/stream/kafka/package-info.java | 22 --
.../kafka/IgniteKafkaStreamerSelfTestSuite.java| 45 ---
.../stream/kafka/KafkaIgniteStreamerSelfTest.java | 275
.../ignite/stream/kafka/TestKafkaBroker.java | 237 --
.../kafka/connect/IgniteSinkConnectorMock.java | 30 --
.../kafka/connect/IgniteSinkConnectorTest.java | 307 --
.../stream/kafka/connect/IgniteSinkTaskMock.java | 29 --
.../kafka/connect/IgniteSourceConnectorMock.java | 30 --
.../kafka/connect/IgniteSourceConnectorTest.java | 355
.../stream/kafka/connect/IgniteSourceTaskMock.java | 31 --
.../stream/kafka/connect/TestCacheEventFilter.java | 31 --
.../apache/ignite/stream/kafka/package-info.java | 22 --
.../kafka/src/test/resources/example-ignite.xml| 73 -
modules/osgi-karaf/src/main/resources/features.xml | 6 +-
parent/pom.xml | 1 +
pom.xml| 1 -
33 files changed, 4 insertions(+), 3321 deletions(-)
diff --git a/assembly/dependencies-apache-ignite-slim.xml
b/assembly/dependencies-apache-ignite-slim.xml
index a4122f8..734df54 100644
--- a/assembly/dependencies-apache-ignite-slim.xml
+++ b/assembly/dependencies-apache-ignite-slim.xml
@@ -153,7 +153,6 @@
org.apache.ignite:ignite-gce
org.apache.ignite:ignite-jcl
org.apache.ignite:ignite-jms11
-org.apache.ignite:ignite-kafka
org.apache.ignite:ignite-mesos
org.apache.ignite:ignite-ml
org.apache.ignite:ignite-ml-h2o-model-parser
diff --git a/assembly/libs/README.txt b/assembly/libs/README.txt
index b36ab73..39f342b 100644
--- a/assembly/libs/README.txt
+++ b/assembly/libs/README.txt
@@ -81,7 +81,6 @@ The following modules are available:
- ignite-indexing (for SQL querying and indexing)
- ignite-jcl (for Apache Commons logging)
- ignite-jta (for XA integration)
-- ignite-kafka (for streaming messages from Apache Kafka into Ignite)
- ignite-logj4 (for Log4j logging)
- ignite-log4j2 (for Log4j 2 logging)
- ignite-mesos (for integration with Apache Mesos cluster resource manager)
diff --git a/modules/kafka/README.txt b/modules/kafka/README.txt
deleted file mode 100644
index 686c7ce..000
--- a/modules/kafka/README.txt
+++ /dev/null
@@ -1,210 +0,0 @@
-Apache Ignite Kafka Streamer Module
-
-Apache Ignite Kafka Streamer module provides streaming from Kafka to Ignite
cache.
-
-There are two ways this can be achieved:
-- importing Kafka Streamer module in your Maven project and instantiate
KafkaStreamer for data streaming;
-- using Kafka Connect functionality.
-
-Below are the details.
-
-## Importing Ignite Kafka Streamer Module In Maven Project
-
-If you are using Maven to manage dependencies of your project, you can add
Kafka module
-dependency like this (replace '${ignite.version}' with actual Ignite version
you are
-interested in):
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.
[ignite-extensions] branch master updated: IGNITE-13394 Migrate Kafka module to ignite-extensions - Fixes #23.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new d002b09 IGNITE-13394 Migrate Kafka module to ignite-extensions -
Fixes #23.
d002b09 is described below
commit d002b09811b1bc3c3b96d757fc65bbb458de2255
Author: samaitra
AuthorDate: Sat Sep 12 16:24:45 2020 -0500
IGNITE-13394 Migrate Kafka module to ignite-extensions - Fixes #23.
Signed-off-by: samaitra
---
modules/kafka-ext/README.txt | 210
modules/kafka-ext/licenses/apache-2.0.txt | 202
.../modules/core/src/test/config/log4j-test.xml| 97 ++
.../modules/core/src/test/config/tests.properties | 153 +
modules/kafka-ext/pom.xml | 155 +
.../apache/ignite/stream/kafka/KafkaStreamer.java | 205
.../stream/kafka/connect/IgniteSinkConnector.java | 100 ++
.../stream/kafka/connect/IgniteSinkConstants.java | 41 +++
.../stream/kafka/connect/IgniteSinkTask.java | 201
.../kafka/connect/IgniteSourceConnector.java | 90 ++
.../kafka/connect/IgniteSourceConstants.java | 44 +++
.../stream/kafka/connect/IgniteSourceTask.java | 359 +
.../ignite/stream/kafka/connect/package-info.java | 22 ++
.../connect/serialization/CacheEventConverter.java | 67
.../serialization/CacheEventDeserializer.java | 55
.../serialization/CacheEventSerializer.java| 55
.../kafka/connect/serialization/package-info.java | 22 ++
.../apache/ignite/stream/kafka/package-info.java | 22 ++
.../kafka/IgniteKafkaStreamerSelfTestSuite.java| 38 +++
.../stream/kafka/KafkaIgniteStreamerSelfTest.java | 275
.../ignite/stream/kafka/TestKafkaBroker.java | 237 ++
.../kafka/connect/IgniteSinkConnectorMock.java | 30 ++
.../kafka/connect/IgniteSinkConnectorTest.java | 307 ++
.../stream/kafka/connect/IgniteSinkTaskMock.java | 29 ++
.../kafka/connect/IgniteSourceConnectorMock.java | 30 ++
.../kafka/connect/IgniteSourceConnectorTest.java | 355
.../stream/kafka/connect/IgniteSourceTaskMock.java | 31 ++
.../stream/kafka/connect/TestCacheEventFilter.java | 31 ++
.../apache/ignite/stream/kafka/package-info.java | 22 ++
.../src/test/resources/example-ignite.xml | 73 +
pom.xml| 1 +
31 files changed, 3559 insertions(+)
diff --git a/modules/kafka-ext/README.txt b/modules/kafka-ext/README.txt
new file mode 100644
index 000..348d143
--- /dev/null
+++ b/modules/kafka-ext/README.txt
@@ -0,0 +1,210 @@
+Apache Ignite Kafka Streamer Module
+---
+
+Apache Ignite Kafka Streamer module provides streaming from Kafka to Ignite
cache.
+
+There are two ways this can be achieved:
+- importing Kafka Streamer module in your Maven project and instantiate
KafkaStreamer for data streaming;
+- using Kafka Connect functionality.
+
+Below are the details.
+
+## Importing Ignite Kafka Streamer Module In Maven Project
+
+If you are using Maven to manage dependencies of your project, you can add
Kafka module
+dependency like this (replace '${ignite.version}' with actual Ignite version
you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-kafka-ext
+${ignite.version}
+
+...
+
+...
+
+
+
+## Streaming Data to Ignite via Kafka Connect
+
+Sink Connector will help you export data from Kafka to Ignite cache. It polls
data from Kafka topics and writes it to the user-specified cache.
+For more information on Kafka Connect, see [Kafka
Documentation](http://kafka.apache.org/documentation.html#connect).
+
+Connector can be found in 'optional/ignite-kafka.' It and its dependencies
have to be on the classpath of a Kafka running instance,
+as described in the following subsection.
+
+### Setting up and Running
+
+1. Put the following jar files on Kafka's classpath
+- ignite-kafka-connect-x.x.x-SNAPSHOT.jar
+- ignite-core-x.x.x-SNAPSHOT.jar
+- ignite-spring-x.x.x-SNAPSHOT.jar
+- cache-api-1.0.0.jar
+- spring-aop-4.1.0.RELEASE.jar
+- spring-beans-4.1.0.RELEASE.jar
+- spring-context-4.1.0.RELEASE.jar
+- spring-core-4.1.0.RELEASE.jar
+- spring-expression-4.1.0.RELEASE.jar
+- commons-logging-1.1.1.jar
+
+2. Prepare worker configurations, e.g.,
+```
+bootstrap.servers=localhost:9092
+
+key.converter=org.apache.k
[ignite-extensions] branch master updated: IGNITE-13406 adding support for camel 3.x
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new d744817 IGNITE-13406 adding support for camel 3.x
d744817 is described below
commit d744817dd229309367eb9e336a2dce21544c504d
Author: Scott Feldstein
AuthorDate: Mon Sep 7 12:42:24 2020 -0500
IGNITE-13406 adding support for camel 3.x
This commit breaks compatibility with 2.x - Fixes #21.
Signed-off-by: samaitra
---
modules/camel-ext/pom.xml | 6 +-
.../apache/ignite/stream/camel/CamelStreamer.java | 23 --
.../stream/camel/IgniteCamelStreamerTest.java | 86 +++---
parent/pom.xml | 2 +-
4 files changed, 61 insertions(+), 56 deletions(-)
diff --git a/modules/camel-ext/pom.xml b/modules/camel-ext/pom.xml
index c2f89b1..9f47d19 100644
--- a/modules/camel-ext/pom.xml
+++ b/modules/camel-ext/pom.xml
@@ -95,9 +95,9 @@
-com.squareup.okhttp
-okhttp
-${okhttp.version}
+org.apache.camel
+camel-http
+${camel.version}
test
diff --git
a/modules/camel-ext/src/main/java/org/apache/ignite/stream/camel/CamelStreamer.java
b/modules/camel-ext/src/main/java/org/apache/ignite/stream/camel/CamelStreamer.java
index 369d2a6..51f3ba4 100644
---
a/modules/camel-ext/src/main/java/org/apache/ignite/stream/camel/CamelStreamer.java
+++
b/modules/camel-ext/src/main/java/org/apache/ignite/stream/camel/CamelStreamer.java
@@ -17,8 +17,6 @@
package org.apache.ignite.stream.camel;
-import java.util.Map;
-
import org.apache.camel.CamelContext;
import org.apache.camel.Consumer;
import org.apache.camel.Endpoint;
@@ -26,8 +24,9 @@ import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.ServiceStatus;
import org.apache.camel.impl.DefaultCamelContext;
-import org.apache.camel.util.CamelContextHelper;
-import org.apache.camel.util.ServiceHelper;
+import org.apache.camel.support.CamelContextHelper;
+import org.apache.camel.support.service.BaseService;
+import org.apache.camel.support.service.ServiceHelper;
import org.apache.ignite.IgniteException;
import org.apache.ignite.IgniteLogger;
import org.apache.ignite.internal.util.typedef.internal.A;
@@ -36,6 +35,8 @@ import org.apache.ignite.stream.StreamAdapter;
import org.apache.ignite.stream.StreamMultipleTupleExtractor;
import org.apache.ignite.stream.StreamSingleTupleExtractor;
+import java.util.Map;
+
/**
* This streamer consumes messages from an Apache Camel consumer endpoint and
feeds them into an Ignite data streamer.
*
@@ -84,9 +85,12 @@ public class CamelStreamer extends
StreamAdapter implement
if (camelCtx == null)
camelCtx = new DefaultCamelContext();
-// If the Camel Context is starting or started, reject this call to
start.
-if (camelCtx.getStatus() == ServiceStatus.Started ||
camelCtx.getStatus() == ServiceStatus.Starting)
-throw new IgniteException("Failed to start Camel streamer
(CamelContext already started or starting).");
+// If the camel context is not started then simply start it up
+if (!camelCtx.isStarted())
+camelCtx.start();
+
+if (!camelCtx.isRunAllowed())
+throw new IgniteException("Failed to start Camel streamer
(CamelContext not in a runnable state).");
log = getIgnite().log();
@@ -97,6 +101,7 @@ public class CamelStreamer extends
StreamAdapter implement
catch (Exception e) {
U.error(log, e);
+camelCtx.stop();
throw new IgniteException("Failed to start Camel streamer
[errMsg=" + e.getMessage() + ']');
}
@@ -107,16 +112,18 @@ public class CamelStreamer extends
StreamAdapter implement
catch (Exception e) {
U.error(log, e);
+camelCtx.stop();
throw new IgniteException("Failed to start Camel streamer
[errMsg=" + e.getMessage() + ']');
}
// Start the Camel services.
try {
-ServiceHelper.startServices(camelCtx, endpoint, consumer);
+ServiceHelper.startService(camelCtx, endpoint, consumer);
}
catch (Exception e) {
U.error(log, e);
+camelCtx.stop();
try {
ServiceHelper.stopAndShutdownServices(camelCtx, endpoint,
consumer);
diff --git
a/modules/camel-ext/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTest.java
b/modules/camel-ext/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTest.java
index 9858357..329f3ed 100644
---
a/modules/camel-ext/src/test/java/org/apache/ignite/stream
[ignite-extensions] branch master updated: IGNITE-13407 Upgrade ignite.version to 2.10.0-SNAPSHOT in Ignite Extensions - Fixes #22.
This is an automated email from the ASF dual-hosted git repository. samaitra pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git The following commit(s) were added to refs/heads/master by this push: new 44ee7fa IGNITE-13407 Upgrade ignite.version to 2.10.0-SNAPSHOT in Ignite Extensions - Fixes #22. 44ee7fa is described below commit 44ee7fad9a71567321a54e721a33424edf8f652b Author: samaitra AuthorDate: Mon Sep 7 12:30:39 2020 -0500 IGNITE-13407 Upgrade ignite.version to 2.10.0-SNAPSHOT in Ignite Extensions - Fixes #22. Signed-off-by: samaitra --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 4ad485d..9610e2a 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -36,7 +36,7 @@ 1.8 1.8 -2.9.0-SNAPSHOT +2.10.0-SNAPSHOT apache-ignite UTF-8
[ignite] branch master updated: IGNITE-12364 Migrate JMS module to ignite-extensions - Fixes #8198.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 974f290 IGNITE-12364 Migrate JMS module to ignite-extensions - Fixes
#8198.
974f290 is described below
commit 974f290d426af1bdc7bc5e78c9b4d93508735378
Author: samaitra
AuthorDate: Mon Aug 31 20:08:44 2020 -0500
IGNITE-12364 Migrate JMS module to ignite-extensions - Fixes #8198.
Signed-off-by: samaitra
---
assembly/libs/README.txt | 1 -
modules/jms11/README.txt | 29 -
modules/jms11/licenses/apache-2.0.txt | 202 --
modules/jms11/pom.xml | 104 ---
.../apache/ignite/stream/jms11/JmsStreamer.java| 565
.../ignite/stream/jms11/MessageTransformer.java| 41 --
.../apache/ignite/stream/jms11/package-info.java | 22 -
.../ignite/stream/jms11/IgniteJmsStreamerTest.java | 708 -
.../stream/jms11/IgniteJmsStreamerTestSuite.java | 34 -
.../ignite/stream/jms11/TestTransformers.java | 127
.../apache/ignite/stream/jms11/package-info.java | 22 -
pom.xml| 1 -
12 files changed, 1856 deletions(-)
diff --git a/assembly/libs/README.txt b/assembly/libs/README.txt
index 8bb3bad..b36ab73 100644
--- a/assembly/libs/README.txt
+++ b/assembly/libs/README.txt
@@ -80,7 +80,6 @@ The following modules are available:
- ignite-hibernate5 (for Hibernate5 integration)
- ignite-indexing (for SQL querying and indexing)
- ignite-jcl (for Apache Commons logging)
-- ignite-jms11 (for streaming messaging from JMS queue or topic into Ignite)
- ignite-jta (for XA integration)
- ignite-kafka (for streaming messages from Apache Kafka into Ignite)
- ignite-logj4 (for Log4j logging)
diff --git a/modules/jms11/README.txt b/modules/jms11/README.txt
deleted file mode 100644
index 3f0d213..000
--- a/modules/jms11/README.txt
+++ /dev/null
@@ -1,29 +0,0 @@
-Apache Ignite JMS 1.1 Module
-
-
-Apache Ignite JMS 1.1 module provides a streamer to consume JMS queue and
topic messages into
-Apache Ignite caches.
-
-Importing Apache Ignite JMS 1.1 Module In Maven Project
-
-
-If you are using Maven to manage dependencies of your project, you can add the
JMS 1.1 module
-dependency like this (replace '${ignite.version}' with actual Ignite version
you are
-interested in):
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.apache.org/xsd/maven-4.0.0.xsd";>
-...
-
-...
-
-org.apache.ignite
-ignite-jms11
-${ignite.version}
-
-...
-
-...
-
diff --git a/modules/jms11/licenses/apache-2.0.txt
b/modules/jms11/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/jms11/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work&quo
[ignite-extensions] branch master updated: IGNITE-12364 Migrate JMS module to ignite-extensions - Fixes #20.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 1f4cd8c IGNITE-12364 Migrate JMS module to ignite-extensions - Fixes
#20.
1f4cd8c is described below
commit 1f4cd8c38deb2e5ccf5a33985eb3f2b9e3c00704
Author: samaitra
AuthorDate: Mon Aug 31 19:50:44 2020 -0500
IGNITE-12364 Migrate JMS module to ignite-extensions - Fixes #20.
Signed-off-by: samaitra
---
modules/jms11-ext/README.txt | 29 +
modules/jms11-ext/licenses/apache-2.0.txt | 202 ++
.../modules/core/src/test/config/log4j-test.xml| 97 +++
.../modules/core/src/test/config/tests.properties | 153 +
modules/jms11-ext/pom.xml | 104 +++
.../apache/ignite/stream/jms11/JmsStreamer.java| 565
.../ignite/stream/jms11/MessageTransformer.java| 41 ++
.../apache/ignite/stream/jms11/package-info.java | 22 +
.../ignite/stream/jms11/IgniteJmsStreamerTest.java | 708 +
.../stream/jms11/IgniteJmsStreamerTestSuite.java | 34 +
.../ignite/stream/jms11/TestTransformers.java | 127
.../apache/ignite/stream/jms11/package-info.java | 22 +
pom.xml| 1 +
13 files changed, 2105 insertions(+)
diff --git a/modules/jms11-ext/README.txt b/modules/jms11-ext/README.txt
new file mode 100644
index 000..0b61d55
--- /dev/null
+++ b/modules/jms11-ext/README.txt
@@ -0,0 +1,29 @@
+Apache Ignite JMS 1.1 Module
+
+
+Apache Ignite JMS 1.1 module provides a streamer to consume JMS queue and
topic messages into
+Apache Ignite caches.
+
+Importing Apache Ignite JMS 1.1 Module In Maven Project
+
+
+If you are using Maven to manage dependencies of your project, you can add the
JMS 1.1 module
+dependency like this (replace '${ignite.version}' with actual Ignite version
you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-jms11-ext
+${ignite.version}
+
+...
+
+...
+
diff --git a/modules/jms11-ext/licenses/apache-2.0.txt
b/modules/jms11-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/jms11-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other m
[ignite] branch master updated: IGNITE-12363 Migrate Camel module to ignite-extensions - Fixes #8132.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 674841e IGNITE-12363 Migrate Camel module to ignite-extensions -
Fixes #8132.
674841e is described below
commit 674841e14bb6d872910d2e754764119d10400846
Author: samaitra
AuthorDate: Wed Aug 12 23:02:46 2020 -0500
IGNITE-12363 Migrate Camel module to ignite-extensions - Fixes #8132.
Signed-off-by: samaitra
---
assembly/libs/README.txt | 1 -
modules/camel/README.txt | 34 --
modules/camel/licenses/apache-2.0.txt | 202 --
modules/camel/pom.xml | 116 --
.../apache/ignite/stream/camel/CamelStreamer.java | 237 ---
.../apache/ignite/stream/camel/package-info.java | 22 --
.../stream/camel/IgniteCamelStreamerTest.java | 432 -
.../stream/camel/IgniteCamelStreamerTestSuite.java | 29 --
.../apache/ignite/stream/camel/package-info.java | 22 --
.../camel/src/test/resources/camel.test.properties | 18 -
pom.xml| 1 -
11 files changed, 1114 deletions(-)
diff --git a/assembly/libs/README.txt b/assembly/libs/README.txt
index a551f18..8bb3bad 100644
--- a/assembly/libs/README.txt
+++ b/assembly/libs/README.txt
@@ -73,7 +73,6 @@ All optional modules can be imported just like the core
module, but with differe
The following modules are available:
- ignite-aop (for AOP-based grid-enabling)
- ignite-aws (for seemless cluster discovery on AWS S3)
-- ignite-camel (for Apache Camel integration)
- ignite-cassandra (for Apache Cassandra integration)
- ignite-cloud (for Apache JClouds integration)
- ignite-gce (for automatic cluster discovery on Google Compute Engine)
diff --git a/modules/camel/README.txt b/modules/camel/README.txt
deleted file mode 100644
index ca119ae..000
--- a/modules/camel/README.txt
+++ /dev/null
@@ -1,34 +0,0 @@
-Apache Ignite Camel Module
---
-
-Apache Ignite Camel provides a streamer to consume cache tuples from a Camel
endpoint such as
-HTTP, TCP, File, FTP, AMQP, SNMP, databases, etc. For more information on
available components,
-refer to http://camel.apache.org/components.html.
-
-To enable the Camel module when starting a standalone node, move
'optional/ignite-camel' folder
-to 'libs' folder before running 'ignite.{sh|bat}' script. The content of the
module folder will
-be added to classpath in this case.
-
-Importing the Camel module in a Maven project
--
-
-If you are using Maven to manage dependencies of your project, you can add the
Camel module
-dependency like this (replace '${ignite.version}' with actual Ignite version
you are
-interested in):
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.apache.org/xsd/maven-4.0.0.xsd";>
-...
-
-...
-
-org.apache.ignite
-ignite-camel
-${ignite.version}
-
-...
-
-...
-
diff --git a/modules/camel/licenses/apache-2.0.txt
b/modules/camel/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/camel/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to softwa
[ignite-extensions] branch master updated: IGNITE-12363 Migrate Camel module to ignite-extensions - Fixes #19.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new d001be6 IGNITE-12363 Migrate Camel module to ignite-extensions -
Fixes #19.
d001be6 is described below
commit d001be60c9f57750fde2a7501090c8dbaf4acf01
Author: samaitra
AuthorDate: Wed Aug 12 22:57:08 2020 -0500
IGNITE-12363 Migrate Camel module to ignite-extensions - Fixes #19.
Signed-off-by: samaitra
---
modules/camel-ext/README.txt | 34 ++
modules/camel-ext/licenses/apache-2.0.txt | 202 ++
.../modules/core/src/test/config/log4j-test.xml| 97 +
.../modules/core/src/test/config/tests.properties | 153
modules/camel-ext/pom.xml | 116 ++
.../apache/ignite/stream/camel/CamelStreamer.java | 237 +++
.../apache/ignite/stream/camel/package-info.java | 22 ++
.../stream/camel/IgniteCamelStreamerTest.java | 432 +
.../stream/camel/IgniteCamelStreamerTestSuite.java | 29 ++
.../apache/ignite/stream/camel/package-info.java | 22 ++
.../src/test/resources/camel.test.properties | 18 +
pom.xml| 1 +
12 files changed, 1363 insertions(+)
diff --git a/modules/camel-ext/README.txt b/modules/camel-ext/README.txt
new file mode 100644
index 000..3786b4b
--- /dev/null
+++ b/modules/camel-ext/README.txt
@@ -0,0 +1,34 @@
+Apache Ignite Camel Module
+--
+
+Apache Ignite Camel provides a streamer to consume cache tuples from a Camel
endpoint such as
+HTTP, TCP, File, FTP, AMQP, SNMP, databases, etc. For more information on
available components,
+refer to http://camel.apache.org/components.html.
+
+To enable the Camel module when starting a standalone node, move
'optional/ignite-camel' folder
+to 'libs' folder before running 'ignite.{sh|bat}' script. The content of the
module folder will
+be added to classpath in this case.
+
+Importing the Camel module in a Maven project
+-
+
+If you are using Maven to manage dependencies of your project, you can add the
Camel module
+dependency like this (replace '${ignite.version}' with actual Ignite version
you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-camel-ext
+${ignite.version}
+
+...
+
+...
+
diff --git a/modules/camel-ext/licenses/apache-2.0.txt
b/modules/camel-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/camel-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is in
[ignite] branch master updated: IGNITE-12360 Migrate Storm module to ignite-extensions - Fixes #8083.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new f3eff27 IGNITE-12360 Migrate Storm module to ignite-extensions -
Fixes #8083.
f3eff27 is described below
commit f3eff27856cc1ded92d92f1cedf15a870d93a93c
Author: samaitra
AuthorDate: Thu Jul 30 23:15:24 2020 -0500
IGNITE-12360 Migrate Storm module to ignite-extensions - Fixes #8083.
Signed-off-by: samaitra
---
assembly/libs/README.txt | 1 -
modules/storm/README.txt | 37 ---
modules/storm/licenses/apache-2.0.txt | 202 --
modules/storm/pom.xml | 98 ---
.../apache/ignite/stream/storm/StormStreamer.java | 300 -
.../apache/ignite/stream/storm/package-info.java | 22 --
.../storm/IgniteStormStreamerSelfTestSuite.java| 31 ---
.../stream/storm/StormIgniteStreamerSelfTest.java | 185 -
.../apache/ignite/stream/storm/TestStormSpout.java | 132 -
.../storm/src/test/resources/example-ignite.xml| 71 -
pom.xml| 1 -
11 files changed, 1080 deletions(-)
diff --git a/assembly/libs/README.txt b/assembly/libs/README.txt
index 5c36d61..a551f18 100644
--- a/assembly/libs/README.txt
+++ b/assembly/libs/README.txt
@@ -98,7 +98,6 @@ The following modules are available:
- ignite-spark (for shared in-memory RDDs and faster SQL for Apache Spark)
- ignite-spring (for Spring-based configuration support)
- ignite-ssh (for starting grid nodes on remote machines)
-- ignite-storm (for streaming events from Apache Storm into Ignite)
- ignite-urideploy (for URI-based deployment)
- ignite-web (for Web Sessions Clustering)
- ignite-yarn (for integration with Apache Hadoop Yarn)
diff --git a/modules/storm/README.txt b/modules/storm/README.txt
deleted file mode 100644
index 684fdb5..000
--- a/modules/storm/README.txt
+++ /dev/null
@@ -1,37 +0,0 @@
-Apache Ignite Storm Streamer Module
-
-Apache Ignite Storm Streamer module provides streaming via Storm to Ignite
cache.
-
-Starting data transfer to Ignite cache can be done with the following steps.
-
-1. Import Ignite Storm Streamer Module In Maven Project
-
-If you are using Maven to manage dependencies of your project, you can add
Storm module
-dependency like this (replace '${ignite.version}' with actual Ignite version
you are
-interested in):
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.apache.org/xsd/maven-4.0.0.xsd";>
-...
-
-...
-
-org.apache.ignite
-ignite-storm
-${ignite.version}
-
-...
-
-...
-
-
-2. Create an Ignite configuration file (see example-ignite.xml) and make sure
it is accessible from the streamer.
-
-3. Make sure your key-value data input to the streamer is specified with the
field named "ignite"
-(or a different one you configure with StormStreamer.setIgniteTupleField(...)).
-See TestStormSpout.declareOutputFields(...) for an example.
-
-4. Create a topology with the streamer and start.
diff --git a/modules/storm/licenses/apache-2.0.txt
b/modules/storm/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/storm/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mea
[ignite-extensions] branch master updated: IGNITE-12360 Migrate Storm module to ignite-extensions - Fixes #18.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 2ee47c8 IGNITE-12360 Migrate Storm module to ignite-extensions -
Fixes #18.
2ee47c8 is described below
commit 2ee47c8dff1c6f8573037fb171ae5476599d1545
Author: samaitra
AuthorDate: Thu Jul 30 23:13:05 2020 -0500
IGNITE-12360 Migrate Storm module to ignite-extensions - Fixes #18.
Signed-off-by: samaitra
---
modules/storm-ext/README.txt | 37 +++
modules/storm-ext/licenses/apache-2.0.txt | 202 ++
.../modules/core/src/test/config/log4j-test.xml| 97 +++
.../modules/core/src/test/config/tests.properties | 153 +++
modules/storm-ext/pom.xml | 98 +++
.../apache/ignite/stream/storm/StormStreamer.java | 300 +
.../apache/ignite/stream/storm/package-info.java | 22 ++
.../storm/IgniteStormStreamerSelfTestSuite.java| 31 +++
.../stream/storm/StormIgniteStreamerSelfTest.java | 185 +
.../apache/ignite/stream/storm/TestStormSpout.java | 132 +
.../src/test/resources/example-ignite.xml | 71 +
pom.xml| 1 +
12 files changed, 1329 insertions(+)
diff --git a/modules/storm-ext/README.txt b/modules/storm-ext/README.txt
new file mode 100644
index 000..79edcb1
--- /dev/null
+++ b/modules/storm-ext/README.txt
@@ -0,0 +1,37 @@
+Apache Ignite Storm Streamer Module
+---
+
+Apache Ignite Storm Streamer module provides streaming via Storm to Ignite
cache.
+
+Starting data transfer to Ignite cache can be done with the following steps.
+
+1. Import Ignite Storm Streamer Module In Maven Project
+
+If you are using Maven to manage dependencies of your project, you can add
Storm module
+dependency like this (replace '${ignite.version}' with actual Ignite version
you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-storm-ext
+${ignite.version}
+
+...
+
+...
+
+
+2. Create an Ignite configuration file (see example-ignite.xml) and make sure
it is accessible from the streamer.
+
+3. Make sure your key-value data input to the streamer is specified with the
field named "ignite"
+(or a different one you configure with StormStreamer.setIgniteTupleField(...)).
+See TestStormSpout.declareOutputFields(...) for an example.
+
+4. Create a topology with the streamer and start.
diff --git a/modules/storm-ext/licenses/apache-2.0.txt
b/modules/storm-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/storm-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, mad
[ignite] branch master updated: IGNITE-12362 Migrate MQTT module to ignite-extensions - Fixes #7950.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 3bd9870 IGNITE-12362 Migrate MQTT module to ignite-extensions - Fixes
#7950.
3bd9870 is described below
commit 3bd9870f1f860fd7969982a72f4110804e1fe89f
Author: samaitra
AuthorDate: Sun Jul 12 16:55:06 2020 -0500
IGNITE-12362 Migrate MQTT module to ignite-extensions - Fixes #7950.
Signed-off-by: samaitra
---
assembly/libs/README.txt | 4 -
modules/mqtt/README.txt| 29 -
modules/mqtt/licenses/apache-2.0.txt | 202 --
modules/mqtt/pom.xml | 123
.../apache/ignite/stream/mqtt/MqttStreamer.java| 707 -
.../apache/ignite/stream/mqtt/package-info.java| 22 -
.../ignite/stream/mqtt/IgniteMqttStreamerTest.java | 647 ---
.../stream/mqtt/IgniteMqttStreamerTestSuite.java | 32 -
.../apache/ignite/stream/mqtt/package-info.java| 22 -
pom.xml| 1 -
10 files changed, 1789 deletions(-)
diff --git a/assembly/libs/README.txt b/assembly/libs/README.txt
index fc40956..4e6ecf8 100644
--- a/assembly/libs/README.txt
+++ b/assembly/libs/README.txt
@@ -76,8 +76,6 @@ The following modules are available:
- ignite-camel (for Apache Camel integration)
- ignite-cassandra (for Apache Cassandra integration)
- ignite-cloud (for Apache JClouds integration)
-- ignite-flink (for streaming from Apache Flink into Ignite)
-- ignite-flume (for streaming events from Apache Flume into Ignite)
- ignite-gce (for automatic cluster discovery on Google Compute Engine)
- ignite-hadoop (for Apache Hadoop Accelerator)
- ignite-hibernate (for Hibernate integration)
@@ -90,7 +88,6 @@ The following modules are available:
- ignite-logj4 (for Log4j logging)
- ignite-log4j2 (for Log4j 2 logging)
- ignite-mesos (for integration with Apache Mesos cluster resource manager)
-- ignite-mqtt (for streaming MQTT topic messages into Ignite)
- ignite-osgi (to allow Ignite run seemlessly in OSGI containers)
- ignite-osgi-karaf (to seemlessly intall ignite into Apache Karaf container)
- ignite-osgi-paxlogging (to expose PAX Logging API to Log4j if needed)
@@ -103,7 +100,6 @@ The following modules are available:
- ignite-spring (for Spring-based configuration support)
- ignite-ssh (for starting grid nodes on remote machines)
- ignite-storm (for streaming events from Apache Storm into Ignite)
-- ignite-twitter (for streaming tweets from Twitter into Ignite)
- ignite-urideploy (for URI-based deployment)
- ignite-web (for Web Sessions Clustering)
- ignite-yarn (for integration with Apache Hadoop Yarn)
diff --git a/modules/mqtt/README.txt b/modules/mqtt/README.txt
deleted file mode 100644
index 62a1589..000
--- a/modules/mqtt/README.txt
+++ /dev/null
@@ -1,29 +0,0 @@
-Apache Ignite MQTT Module
--
-
-Apache Ignite MQTT module provides a streamer to consume MQTT topic messages
into
-Apache Ignite caches.
-
-Importing Apache Ignite MQTT Module In Maven Project
-
-
-If you are using Maven to manage dependencies of your project, you can add the
MQTT module
-dependency like this (replace '${ignite.version}' with actual Ignite version
you are
-interested in):
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.apache.org/xsd/maven-4.0.0.xsd";>
-...
-
-...
-
-org.apache.ignite
-ignite-mqtt
-${ignite.version}
-
-...
-
-...
-
diff --git a/modules/mqtt/licenses/apache-2.0.txt
b/modules/mqtt/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/mqtt/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the
[ignite-extensions] branch master updated: IGNITE-12362 Migrate MQTT module to ignite-extensions - Fixes #17.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new c1dc651 IGNITE-12362 Migrate MQTT module to ignite-extensions - Fixes
#17.
c1dc651 is described below
commit c1dc651c8e3fbda067da67d07e23e54af291db81
Author: samaitra
AuthorDate: Sun Jul 12 16:14:02 2020 -0500
IGNITE-12362 Migrate MQTT module to ignite-extensions - Fixes #17.
Signed-off-by: samaitra
---
modules/mqtt-ext/README.txt| 29 +
modules/mqtt-ext/licenses/apache-2.0.txt | 202 ++
.../modules/core/src/test/config/log4j-test.xml| 97 +++
.../modules/core/src/test/config/tests.properties | 153 +
modules/mqtt-ext/pom.xml | 123
.../apache/ignite/stream/mqtt/MqttStreamer.java| 709 +
.../apache/ignite/stream/mqtt/package-info.java| 22 +
.../ignite/stream/mqtt/IgniteMqttStreamerTest.java | 649 +++
.../stream/mqtt/IgniteMqttStreamerTestSuite.java | 32 +
.../apache/ignite/stream/mqtt/package-info.java| 22 +
pom.xml| 1 +
11 files changed, 2039 insertions(+)
diff --git a/modules/mqtt-ext/README.txt b/modules/mqtt-ext/README.txt
new file mode 100644
index 000..b90d301
--- /dev/null
+++ b/modules/mqtt-ext/README.txt
@@ -0,0 +1,29 @@
+Apache Ignite MQTT Module
+-
+
+Apache Ignite MQTT module provides a streamer to consume MQTT topic messages
into
+Apache Ignite caches.
+
+Importing Apache Ignite MQTT Module In Maven Project
+
+
+If you are using Maven to manage dependencies of your project, you can add the
MQTT module
+dependency like this (replace '${ignite.version}' with actual Ignite version
you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-mqtt-ext
+${ignite.version}
+
+...
+
+...
+
diff --git a/modules/mqtt-ext/licenses/apache-2.0.txt
b/modules/mqtt-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/mqtt-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include wo
[ignite-extensions] branch master updated: IGNITE-12952 Enable travis ci for ignite-extensions - Fixes #15.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new b0a2318 IGNITE-12952 Enable travis ci for ignite-extensions - Fixes
#15.
b0a2318 is described below
commit b0a23188a44a9fb479229880275c5063dbc6b480
Author: samaitra
AuthorDate: Sat Jun 13 11:57:00 2020 -0500
IGNITE-12952 Enable travis ci for ignite-extensions - Fixes #15.
Signed-off-by: samaitra
---
.travis.yml | 46 ++
1 file changed, 46 insertions(+)
diff --git a/.travis.yml b/.travis.yml
new file mode 100644
index 000..093d36e
--- /dev/null
+++ b/.travis.yml
@@ -0,0 +1,46 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+matrix:
+ include:
+- language: java
+ os: linux
+ dist: trusty
+ install: skip
+ jdk: openjdk8
+ before_script:
+- echo $JVM_EXTRA_ARGS
+ script: mvn clean install
+ before_cache: rm -rfv $HOME/.m2/repository/org/apache/ignite
+ cache: {directories: [$HOME/.m2/repository]}
+
+- language: java
+ os: linux
+ dist: trusty
+ install: skip
+ jdk: openjdk11
+ before_script:
+- echo $JVM_EXTRA_ARGS
+- |
+ export JVM_EXTRA_ARGS='--illegal-access=permit
+ --add-exports=java.base/jdk.internal.misc=ALL-UNNAMED
+ --add-exports=java.base/sun.nio.ch=ALL-UNNAMED
+ --add-exports=java.management/com.sun.jmx.mbeanserver=ALL-UNNAMED
+ --add-exports=jdk.internal.jvmstat/sun.jvmstat.monitor=ALL-UNNAMED
+
--add-exports=java.base/sun.reflect.generics.reflectiveObjects=ALL-UNNAMED
+ -Djdk.tls.client.protocols=TLSv1.2'
+ script: mvn clean install
+ before_cache: rm -rfv $HOME/.m2/repository/org/apache/ignite
+ cache: {directories: [$HOME/.m2/repository]}
[ignite] branch master updated: IGNITE-12359 Migrate RocketMQ module to ignite-extensions - Fixes #7809.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 0139490 IGNITE-12359 Migrate RocketMQ module to ignite-extensions -
Fixes #7809.
0139490 is described below
commit 01394900b36d5ae0ec1d23486cf3b7940b6da9be
Author: samaitra
AuthorDate: Sun May 31 15:26:19 2020 -0500
IGNITE-12359 Migrate RocketMQ module to ignite-extensions - Fixes #7809.
Signed-off-by: samaitra
---
assembly/libs/README.txt | 1 -
modules/rocketmq/README.txt| 25 ---
modules/rocketmq/licenses/apache-2.0.txt | 202 ---
modules/rocketmq/pom.xml | 94 -
.../ignite/stream/rocketmq/RocketMQStreamer.java | 151 ---
.../ignite/stream/rocketmq/package-info.java | 21 --
.../stream/rocketmq/RocketMQStreamerTest.java | 215 -
.../stream/rocketmq/RocketMQStreamerTestSuite.java | 31 ---
.../ignite/stream/rocketmq/TestRocketMQServer.java | 148 --
.../ignite/stream/rocketmq/package-info.java | 21 --
parent/pom.xml | 5 -
pom.xml| 1 -
12 files changed, 915 deletions(-)
diff --git a/assembly/libs/README.txt b/assembly/libs/README.txt
index 1365cc1..fc40956 100644
--- a/assembly/libs/README.txt
+++ b/assembly/libs/README.txt
@@ -95,7 +95,6 @@ The following modules are available:
- ignite-osgi-karaf (to seemlessly intall ignite into Apache Karaf container)
- ignite-osgi-paxlogging (to expose PAX Logging API to Log4j if needed)
- ignite-rest-http (for HTTP REST messages)
-- ignite-rocketmq (for streaming messages from Apache RocketMQ into Ignite)
- ignite-scalar (for ignite Scala API)
- ignite-scalar_2.10 (for Ignite Scala 2.10 API)
- ignite-schedule (for Cron-based task scheduling)
diff --git a/modules/rocketmq/README.txt b/modules/rocketmq/README.txt
deleted file mode 100644
index 55a117b..000
--- a/modules/rocketmq/README.txt
+++ /dev/null
@@ -1,25 +0,0 @@
-Apache Ignite RocketMQ Streamer Module
---
-
-Apache Ignite RocketMQ Streamer module provides streaming from RocketMQ to
Ignite cache.
-
-To use Ignite RocketMQ Streamer module, first import it to your Maven project.
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.apache.org/xsd/maven-4.0.0.xsd";>
-...
-
-...
-
-org.apache.ignite
-ignite-rocketmq
-${ignite.version}
-
-...
-
-...
-
-
-Then, initialize and start it as, for instance, done in
RocketMQStreamerTest.java.
diff --git a/modules/rocketmq/licenses/apache-2.0.txt
b/modules/rocketmq/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/rocketmq/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Sour
[ignite-extensions] branch master updated: IGNITE-12359 Migrate RocketMQ module to ignite-extensions - Fixes #14.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new d43d964 IGNITE-12359 Migrate RocketMQ module to ignite-extensions -
Fixes #14.
d43d964 is described below
commit d43d9643a9faf40cf51e5d0874caca9c065d3a4d
Author: samaitra
AuthorDate: Sun May 31 14:55:35 2020 -0500
IGNITE-12359 Migrate RocketMQ module to ignite-extensions - Fixes #14.
Signed-off-by: samaitra
---
modules/rocketmq-ext/README.txt| 25 +++
modules/rocketmq-ext/licenses/apache-2.0.txt | 202 +++
.../modules/core/src/test/config/log4j-test.xml| 97 ++
.../modules/core/src/test/config/tests.properties | 153 +++
modules/rocketmq-ext/pom.xml | 94 +
.../ignite/stream/rocketmq/RocketMQStreamer.java | 151 +++
.../ignite/stream/rocketmq/package-info.java | 21 ++
.../stream/rocketmq/RocketMQStreamerTest.java | 215 +
.../stream/rocketmq/RocketMQStreamerTestSuite.java | 31 +++
.../ignite/stream/rocketmq/TestRocketMQServer.java | 148 ++
.../ignite/stream/rocketmq/package-info.java | 21 ++
pom.xml| 1 +
12 files changed, 1159 insertions(+)
diff --git a/modules/rocketmq-ext/README.txt b/modules/rocketmq-ext/README.txt
new file mode 100644
index 000..62e6af6
--- /dev/null
+++ b/modules/rocketmq-ext/README.txt
@@ -0,0 +1,25 @@
+Apache Ignite RocketMQ Streamer Module
+--
+
+Apache Ignite RocketMQ Streamer module provides streaming from RocketMQ to
Ignite cache.
+
+To use Ignite RocketMQ Streamer module, first import it to your Maven project.
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-rocketmq-ext
+${ignite.version}
+
+...
+
+...
+
+
+Then, initialize and start it as, for instance, done in
RocketMQStreamerTest.java.
diff --git a/modules/rocketmq-ext/licenses/apache-2.0.txt
b/modules/rocketmq-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/rocketmq-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall
[ignite-extensions] branch master updated: IGNITE-12997 Rename pub-sub module to pub-sub-ext - Fixes #13.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new e997fe4 IGNITE-12997 Rename pub-sub module to pub-sub-ext - Fixes #13.
e997fe4 is described below
commit e997fe4c317fc5bb6bfeff37a63dab172a4cfd8e
Author: samaitra
AuthorDate: Sun May 10 11:01:19 2020 -0500
IGNITE-12997 Rename pub-sub module to pub-sub-ext - Fixes #13.
Signed-off-by: samaitra
---
modules/{pub-sub => pub-sub-ext}/README.txt | 2 +-
modules/{pub-sub => pub-sub-ext}/config/example-ignite.xml | 0
modules/{pub-sub => pub-sub-ext}/licenses/apache-2.0.txt| 0
modules/{pub-sub => pub-sub-ext}/pom.xml| 2 +-
.../src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java | 0
.../src/main/java/org/apache/ignite/stream/pubsub/package-info.java | 0
.../src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java | 0
.../java/org/apache/ignite/stream/pubsub/PubSubStreamerSelfTest.java| 0
.../java/org/apache/ignite/stream/pubsub/PubSubStreamerTestSuite.java | 0
modules/{pub-sub => pub-sub-ext}/src/test/resources/example-ignite.xml | 0
pom.xml | 2 +-
11 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/modules/pub-sub/README.txt b/modules/pub-sub-ext/README.txt
similarity index 95%
rename from modules/pub-sub/README.txt
rename to modules/pub-sub-ext/README.txt
index 65e7754..7a09479 100644
--- a/modules/pub-sub/README.txt
+++ b/modules/pub-sub-ext/README.txt
@@ -20,7 +20,7 @@ interested in):
...
org.apache.ignite
-ignite-pub-sub
+ignite-pub-sub-ext
${ignite.version}
...
diff --git a/modules/pub-sub/config/example-ignite.xml
b/modules/pub-sub-ext/config/example-ignite.xml
similarity index 100%
rename from modules/pub-sub/config/example-ignite.xml
rename to modules/pub-sub-ext/config/example-ignite.xml
diff --git a/modules/pub-sub/licenses/apache-2.0.txt
b/modules/pub-sub-ext/licenses/apache-2.0.txt
similarity index 100%
rename from modules/pub-sub/licenses/apache-2.0.txt
rename to modules/pub-sub-ext/licenses/apache-2.0.txt
diff --git a/modules/pub-sub/pom.xml b/modules/pub-sub-ext/pom.xml
similarity index 98%
rename from modules/pub-sub/pom.xml
rename to modules/pub-sub-ext/pom.xml
index 05a147c..e73b5e6 100644
--- a/modules/pub-sub/pom.xml
+++ b/modules/pub-sub-ext/pom.xml
@@ -32,7 +32,7 @@
../../parent
-ignite-pub-sub
+ignite-pub-sub-ext
2.9.0-SNAPSHOT
http://ignite.apache.org
diff --git
a/modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
b/modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
similarity index 100%
rename from
modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
rename to
modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
diff --git
a/modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/package-info.java
b/modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/package-info.java
similarity index 100%
rename from
modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/package-info.java
rename to
modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/package-info.java
diff --git
a/modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
b/modules/pub-sub-ext/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
similarity index 100%
rename from
modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
rename to
modules/pub-sub-ext/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
diff --git
a/modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerSelfTest.java
b/modules/pub-sub-ext/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerSelfTest.java
similarity index 100%
rename from
modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerSelfTest.java
rename to
modules/pub-sub-ext/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerSelfTest.java
diff --git
a/modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerTestSuite.java
b/modules/pub-sub-ext/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerTestSuite.java
similarity index 100%
rename from
modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerTestSuite.java
rename to
modules/pub-sub-ext/src/test/java/org/apache/ignite/stream/pubsub/PubSubStreamerTestSuite.java
diff --git a/modules/pub-sub/src/test/resources/example-ignite.xml
b/modules/pub-s
[ignite] branch master updated: IGNITE-12357 Migrate Twitter module to ignite-extensions - Fixes #7733.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 8218349 IGNITE-12357 Migrate Twitter module to ignite-extensions -
Fixes #7733.
8218349 is described below
commit 821834948eb87bba64a623add103c33dca7e24b8
Author: samaitra
AuthorDate: Fri May 1 20:46:56 2020 -0500
IGNITE-12357 Migrate Twitter module to ignite-extensions - Fixes #7733.
Signed-off-by: samaitra
---
modules/twitter/README.txt | 32 ---
modules/twitter/licenses/apache-2.0.txt| 202 --
modules/twitter/pom.xml| 131 -
.../ignite/stream/twitter/OAuthSettings.java | 86 --
.../ignite/stream/twitter/TwitterStreamer.java | 294 -
.../apache/ignite/stream/twitter/package-info.java | 22 --
.../stream/twitter/IgniteTwitterStreamerTest.java | 252 --
.../twitter/IgniteTwitterStreamerTestSuite.java| 31 ---
.../ignite/stream/twitter/TwitterStreamerImpl.java | 79 --
.../apache/ignite/stream/twitter/package-info.java | 22 --
pom.xml| 1 -
11 files changed, 1152 deletions(-)
diff --git a/modules/twitter/README.txt b/modules/twitter/README.txt
deleted file mode 100644
index 1c412f9..000
--- a/modules/twitter/README.txt
+++ /dev/null
@@ -1,32 +0,0 @@
-Apache Ignite Twitter Streamer Module
-
-
-Apache Ignite Twitter Streamer module provides streaming from Twitter to
Ignite cache.
-
-To enable Twitter Streamer module when starting a standalone node, move
'optional/ignite-twitter' folder to
-'libs' folder before running 'ignite.{sh|bat}' script. The content of the
module folder will
-be added to classpath in this case.
-
-Importing Ignite Twitter Streamer Module In Maven Project
--
-
-If you are using Maven to manage dependencies of your project, you can add JCL
module
-dependency like this (replace '${ignite.version}' with actual Ignite version
you are
-interested in):
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.apache.org/xsd/maven-4.0.0.xsd";>
-...
-
-...
-
-org.apache.ignite
-ignite-twitter
-${ignite.version}
-
-...
-
-...
-
diff --git a/modules/twitter/licenses/apache-2.0.txt
b/modules/twitter/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/twitter/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that
[ignite-extensions] branch master updated: IGNITE-12357 Migrate Twitter module to ignite-extensions - Fixes #12.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 5a5537d IGNITE-12357 Migrate Twitter module to ignite-extensions -
Fixes #12.
5a5537d is described below
commit 5a5537ddea0fd6791e9226f32830f4d75da0
Author: samaitra
AuthorDate: Fri May 1 20:33:08 2020 -0500
IGNITE-12357 Migrate Twitter module to ignite-extensions - Fixes #12.
Signed-off-by: samaitra
---
modules/twitter-ext/README.txt | 32 +++
modules/twitter-ext/licenses/apache-2.0.txt| 202 ++
.../modules/core/src/test/config/log4j-test.xml| 145 ++
.../modules/core/src/test/config/tests.properties | 153 +++
modules/twitter-ext/pom.xml| 131 +
.../ignite/stream/twitter/OAuthSettings.java | 86 ++
.../ignite/stream/twitter/TwitterStreamer.java | 294 +
.../apache/ignite/stream/twitter/package-info.java | 22 ++
.../stream/twitter/IgniteTwitterStreamerTest.java | 252 ++
.../twitter/IgniteTwitterStreamerTestSuite.java| 31 +++
.../ignite/stream/twitter/TwitterStreamerImpl.java | 79 ++
.../apache/ignite/stream/twitter/package-info.java | 22 ++
pom.xml| 1 +
13 files changed, 1450 insertions(+)
diff --git a/modules/twitter-ext/README.txt b/modules/twitter-ext/README.txt
new file mode 100644
index 000..5215786
--- /dev/null
+++ b/modules/twitter-ext/README.txt
@@ -0,0 +1,32 @@
+Apache Ignite Twitter Streamer Module
+
+
+Apache Ignite Twitter Streamer module provides streaming from Twitter to
Ignite cache.
+
+To enable Twitter Streamer module when starting a standalone node, move
'optional/ignite-twitter' folder to
+'libs' folder before running 'ignite.{sh|bat}' script. The content of the
module folder will
+be added to classpath in this case.
+
+Importing Ignite Twitter Streamer Module In Maven Project
+-
+
+If you are using Maven to manage dependencies of your project, you can add JCL
module
+dependency like this (replace '${ignite.version}' with actual Ignite version
you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-twitter-ext
+${ignite.version}
+
+...
+
+...
+
diff --git a/modules/twitter-ext/licenses/apache-2.0.txt
b/modules/twitter-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/twitter-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the
[ignite] branch master updated: IGNITE-12361 Migrate Flume module to ignite-extensions - Fixes #7227.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 3ac680f IGNITE-12361 Migrate Flume module to ignite-extensions -
Fixes #7227.
3ac680f is described below
commit 3ac680f5bae0c48a4740f935d07ace9e2a4d5049
Author: samaitra
AuthorDate: Sun Apr 12 14:01:21 2020 -0500
IGNITE-12361 Migrate Flume module to ignite-extensions - Fixes #7227.
Signed-off-by: samaitra
---
modules/flume/README.txt | 48 -
modules/flume/licenses/apache-2.0.txt | 202 -
modules/flume/pom.xml | 88 -
.../ignite/stream/flume/EventTransformer.java | 36
.../org/apache/ignite/stream/flume/IgniteSink.java | 196
.../ignite/stream/flume/IgniteSinkConstants.java | 35
.../apache/ignite/stream/flume/package-info.java | 22 ---
.../apache/ignite/stream/flume/IgniteSinkTest.java | 139 --
.../ignite/stream/flume/IgniteSinkTestSuite.java | 29 ---
.../ignite/stream/flume/TestEventTransformer.java | 66 ---
.../apache/ignite/stream/flume/package-info.java | 22 ---
.../flume/src/test/resources/example-ignite.xml| 71
parent/pom.xml | 1 -
pom.xml| 1 -
14 files changed, 956 deletions(-)
diff --git a/modules/flume/README.txt b/modules/flume/README.txt
deleted file mode 100644
index adcd021..000
--- a/modules/flume/README.txt
+++ /dev/null
@@ -1,48 +0,0 @@
-Apache Ignite Flume Sink Module
-
-IgniteSink is a Flume sink that extracts Events from an associated Flume
channel and injects into an Ignite cache.
-Flume 1.7.0 is supported.
-
-IgniteSink, which can be found in 'optional/ignite-flume', and its
dependencies have to be included in the agent's classpath,
-as described in the following subsection, before starting the Flume agent.
-
-## Setting up and running
-
-1. Create a transformer by implementing EventTransformer interface.
-2. Create 'ignite' directory inside plugins.d directory which is located in
${FLUME_HOME}. If the plugins.d directory is not there, create it.
-3. Build it and copy to ${FLUME_HOME}/plugins.d/ignite-sink/lib.
-4. Copy other Ignite-related jar files from Apache Ignite distribution to
${FLUME_HOME}/plugins.d/ignite-sink/libext to have them as shown below.
-
-```
-plugins.d/
-`-- ignite
-|-- lib
-| `-- ignite-flume-transformer-x.x.x.jar <-- your jar
-`-- libext
-|-- cache-api-1.0.0.jar
-|-- ignite-core-x.x.x.jar
-|-- ignite-flume-x.x.x.jar <-- IgniteSink
-|-- ignite-spring-x.x.x.jar
-|-- spring-aop-4.1.0.RELEASE.jar
-|-- spring-beans-4.1.0.RELEASE.jar
-|-- spring-context-4.1.0.RELEASE.jar
-|-- spring-core-4.1.0.RELEASE.jar
-`-- spring-expression-4.1.0.RELEASE.jar
-```
-
-4. In Flume configuration file, specify Ignite configuration XML file's
location with cache properties
-(see [Apache Ignite](https://apacheignite.readme.io/) with cache name
specified for cache creation,
-cache name (same as in Ignite configuration file), your EventTransformer's
implementation class,
-and, optionally, batch size (default -- 100).
-
-```
-# Describe the sink
-a1.sinks.k1.type = org.apache.ignite.stream.flume.IgniteSink
-a1.sinks.k1.igniteCfg = /some-path/ignite.xml
-a1.sinks.k1.cacheName = testCache
-a1.sinks.k1.eventTransformer = my.company.MyEventTransformer
-a1.sinks.k1.batchSize = 100
-```
-
-After specifying your source and channel (see Flume's docs), you are ready to
run a Flume agent.
diff --git a/modules/flume/licenses/apache-2.0.txt
b/modules/flume/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/flume/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of su
[ignite] branch master updated: IGNITE-12358 Migrate ZeroMQ module to ignite-extensions - Fixes #7240.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 1d4db11 IGNITE-12358 Migrate ZeroMQ module to ignite-extensions -
Fixes #7240.
1d4db11 is described below
commit 1d4db11e4c2a0ca5dcc32573eb926b57004c112f
Author: samaitra
AuthorDate: Sun Apr 12 13:59:40 2020 -0500
IGNITE-12358 Migrate ZeroMQ module to ignite-extensions - Fixes #7240.
Signed-off-by: samaitra
---
modules/zeromq/README.txt | 37 ---
modules/zeromq/licenses/apache-2.0.txt | 202
modules/zeromq/pom.xml | 75 --
.../ignite/stream/zeromq/IgniteZeroMqStreamer.java | 151
.../ignite/stream/zeromq/ZeroMqTypeSocket.java | 56 -
.../apache/ignite/stream/zeromq/package-info.java | 21 --
.../stream/zeromq/IgniteZeroMqStreamerTest.java| 261 -
.../zeromq/IgniteZeroMqStreamerTestSuite.java | 31 ---
.../zeromq/ZeroMqStringSingleTupleExtractor.java | 46
.../apache/ignite/stream/zeromq/package-info.java | 21 --
pom.xml| 1 -
11 files changed, 902 deletions(-)
diff --git a/modules/zeromq/README.txt b/modules/zeromq/README.txt
deleted file mode 100644
index aeb86f8..000
--- a/modules/zeromq/README.txt
+++ /dev/null
@@ -1,37 +0,0 @@
-Apache Ignite ZeroMQ Streamer Module
-
-
-Apache Ignite ZeroMQ Streamer module provides streaming from ZeroMQ to Ignite
cache.
-
-Starting data transfer to Ignite cache can be done with the following steps.
-
-1. Import Ignite ZeroMQ Streamer Module In Maven Project
-
-If you are using Maven to manage dependencies of your project, you can add
ZeroMQ module
-dependency like this (replace '${ignite.version}' with actual Ignite version
you are
-interested in):
-
-http://maven.apache.org/POM/4.0.0";
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
-xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
-http://maven.apache.org/xsd/maven-4.0.0.xsd";>
-...
-
-...
-
-org.apache.ignite
-ignite-zeromq
-${ignite.version}
-
-...
-
-...
-
-
-2. Create an Ignite configuration file (see example-ignite.xml) and make sure
it is accessible from the streamer.
-
-3. Create your StreamSingleTupleExtractor or StreamMultipleTupleExtractor, an
example can be found in the tests folder
-ZeroMqStringSingleTupleExtractor.java. Now it is necessary to add in a streamer
-IgniteZeroMqStreamer.setSingleTupleExtractor(...).
-
-4. Create a topology with the streamer and start.
diff --git a/modules/zeromq/licenses/apache-2.0.txt
b/modules/zeromq/licenses/apache-2.0.txt
deleted file mode 100644
index d645695..000
--- a/modules/zeromq/licenses/apache-2.0.txt
+++ /dev/null
@@ -1,202 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
-http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attache
[ignite-extensions] branch master updated: IGNITE-12361 Migrate Flume module to ignite-extensions - Fixes #4.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new aa0d155 IGNITE-12361 Migrate Flume module to ignite-extensions -
Fixes #4.
aa0d155 is described below
commit aa0d15597a1c5755e39aa66f0a9fab4835bfb376
Author: samaitra
AuthorDate: Fri Apr 3 04:59:01 2020 -0500
IGNITE-12361 Migrate Flume module to ignite-extensions - Fixes #4.
Signed-off-by: samaitra
---
modules/flume-ext/README.txt | 48 +
modules/flume-ext/licenses/apache-2.0.txt | 202 +
.../modules/core/src/test/config/log4j-test.xml| 145 +++
.../modules/core/src/test/config/tests.properties | 153
modules/flume-ext/pom.xml | 94 ++
.../ignite/stream/flume/EventTransformer.java | 36
.../org/apache/ignite/stream/flume/IgniteSink.java | 197
.../ignite/stream/flume/IgniteSinkConstants.java | 35
.../apache/ignite/stream/flume/package-info.java | 22 +++
.../apache/ignite/stream/flume/IgniteSinkTest.java | 135 ++
.../ignite/stream/flume/IgniteSinkTestSuite.java | 29 +++
.../ignite/stream/flume/TestEventTransformer.java | 66 +++
.../apache/ignite/stream/flume/package-info.java | 22 +++
.../src/test/resources/example-ignite.xml | 71
pom.xml| 1 +
15 files changed, 1256 insertions(+)
diff --git a/modules/flume-ext/README.txt b/modules/flume-ext/README.txt
new file mode 100644
index 000..adcd021
--- /dev/null
+++ b/modules/flume-ext/README.txt
@@ -0,0 +1,48 @@
+Apache Ignite Flume Sink Module
+---
+
+IgniteSink is a Flume sink that extracts Events from an associated Flume
channel and injects into an Ignite cache.
+Flume 1.7.0 is supported.
+
+IgniteSink, which can be found in 'optional/ignite-flume', and its
dependencies have to be included in the agent's classpath,
+as described in the following subsection, before starting the Flume agent.
+
+## Setting up and running
+
+1. Create a transformer by implementing EventTransformer interface.
+2. Create 'ignite' directory inside plugins.d directory which is located in
${FLUME_HOME}. If the plugins.d directory is not there, create it.
+3. Build it and copy to ${FLUME_HOME}/plugins.d/ignite-sink/lib.
+4. Copy other Ignite-related jar files from Apache Ignite distribution to
${FLUME_HOME}/plugins.d/ignite-sink/libext to have them as shown below.
+
+```
+plugins.d/
+`-- ignite
+|-- lib
+| `-- ignite-flume-transformer-x.x.x.jar <-- your jar
+`-- libext
+|-- cache-api-1.0.0.jar
+|-- ignite-core-x.x.x.jar
+|-- ignite-flume-x.x.x.jar <-- IgniteSink
+|-- ignite-spring-x.x.x.jar
+|-- spring-aop-4.1.0.RELEASE.jar
+|-- spring-beans-4.1.0.RELEASE.jar
+|-- spring-context-4.1.0.RELEASE.jar
+|-- spring-core-4.1.0.RELEASE.jar
+`-- spring-expression-4.1.0.RELEASE.jar
+```
+
+4. In Flume configuration file, specify Ignite configuration XML file's
location with cache properties
+(see [Apache Ignite](https://apacheignite.readme.io/) with cache name
specified for cache creation,
+cache name (same as in Ignite configuration file), your EventTransformer's
implementation class,
+and, optionally, batch size (default -- 100).
+
+```
+# Describe the sink
+a1.sinks.k1.type = org.apache.ignite.stream.flume.IgniteSink
+a1.sinks.k1.igniteCfg = /some-path/ignite.xml
+a1.sinks.k1.cacheName = testCache
+a1.sinks.k1.eventTransformer = my.company.MyEventTransformer
+a1.sinks.k1.batchSize = 100
+```
+
+After specifying your source and channel (see Flume's docs), you are ready to
run a Flume agent.
diff --git a/modules/flume-ext/licenses/apache-2.0.txt
b/modules/flume-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/flume-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this defini
[ignite-extensions] branch master updated: IGNITE-12358 Migrate ZeroMQ module to ignite-extensions - Fixes #5.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new fce59f2 IGNITE-12358 Migrate ZeroMQ module to ignite-extensions -
Fixes #5.
fce59f2 is described below
commit fce59f25213e648415ddfabdf60ac5e767d9dee1
Author: samaitra
AuthorDate: Fri Mar 27 18:09:37 2020 -0500
IGNITE-12358 Migrate ZeroMQ module to ignite-extensions - Fixes #5.
Signed-off-by: samaitra
---
modules/zeromq-ext/README.txt | 37 +++
modules/zeromq-ext/licenses/apache-2.0.txt | 202
.../modules/core/src/test/config/log4j-test.xml| 145
.../modules/core/src/test/config/tests.properties | 153
modules/zeromq-ext/pom.xml | 76 ++
.../ignite/stream/zeromq/IgniteZeroMqStreamer.java | 151
.../ignite/stream/zeromq/ZeroMqTypeSocket.java | 56 +
.../apache/ignite/stream/zeromq/package-info.java | 21 ++
.../stream/zeromq/IgniteZeroMqStreamerTest.java| 262 +
.../zeromq/IgniteZeroMqStreamerTestSuite.java | 31 +++
.../zeromq/ZeroMqStringSingleTupleExtractor.java | 46
.../apache/ignite/stream/zeromq/package-info.java | 21 ++
pom.xml| 1 +
13 files changed, 1202 insertions(+)
diff --git a/modules/zeromq-ext/README.txt b/modules/zeromq-ext/README.txt
new file mode 100644
index 000..c7c0d2f
--- /dev/null
+++ b/modules/zeromq-ext/README.txt
@@ -0,0 +1,37 @@
+Apache Ignite ZeroMQ Streamer Module
+
+
+Apache Ignite ZeroMQ Streamer module provides streaming from ZeroMQ to Ignite
cache.
+
+Starting data transfer to Ignite cache can be done with the following steps.
+
+1. Import Ignite ZeroMQ Streamer Module In Maven Project
+
+If you are using Maven to manage dependencies of your project, you can add
ZeroMQ module
+dependency like this (replace '${ignite-zeromq-ext.version}' with actual
Ignite version you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-zeromq-ext
+${ignite-zeromq-ext.version}
+
+...
+
+...
+
+
+2. Create an Ignite configuration file (see example-ignite.xml) and make sure
it is accessible from the streamer.
+
+3. Create your StreamSingleTupleExtractor or StreamMultipleTupleExtractor, an
example can be found in the tests folder
+ZeroMqStringSingleTupleExtractor.java. Now it is necessary to add in a streamer
+IgniteZeroMqStreamer.setSingleTupleExtractor(...).
+
+4. Create a topology with the streamer and start.
diff --git a/modules/zeromq-ext/licenses/apache-2.0.txt
b/modules/zeromq-ext/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/zeromq-ext/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work&
[ignite-extensions] branch master updated: Fix ignite sink startup - Fixes #9.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 5ada52a Fix ignite sink startup - Fixes #9.
5ada52a is described below
commit 5ada52ab55e5d1de08115553bfe0e0dad40bafaa
Author: Dominik Przybysz
AuthorDate: Sat Mar 14 15:11:51 2020 -0500
Fix ignite sink startup - Fixes #9.
Signed-off-by: samaitra
---
.../main/java/org/apache/ignite/sink/flink/IgniteSink.java | 14 +++---
1 file changed, 11 insertions(+), 3 deletions(-)
diff --git
a/modules/flink-ext/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
b/modules/flink-ext/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
index 8deb0d7..a9add62 100644
---
a/modules/flink-ext/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
+++
b/modules/flink-ext/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
@@ -143,10 +143,18 @@ public class IgniteSink extends RichSinkFunction {
A.notNull(cacheName, "Cache name");
try {
-// if an ignite instance is already started in same JVM then use
it.
-this.ignite = Ignition.ignite();
-} catch (IgniteIllegalStateException e) {
this.ignite = Ignition.start(igniteCfgFile);
+} catch (IgniteException e) {
+if (e.getMessage().contains("instance has already been started."))
{
+// ignite instance is already started in same JVM then use it
+try {
+this.ignite = Ignition.ignite();
+} catch(IgniteIllegalStateException illegalStateException){
+throw new IgniteException("Cannot connect to existing
ignite instance", e);
+}
+} else {
+throw e;
+}
}
this.ignite.getOrCreateCache(cacheName);
[ignite-extensions] branch master updated: Added acknowledgement for pub/sub Streamer - Fixes #8.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 173f116 Added acknowledgement for pub/sub Streamer - Fixes #8.
173f116 is described below
commit 173f1166404eb017162a124d26df6bcb5fd99ba5
Author: gkatzioura
AuthorDate: Sat Mar 14 15:00:34 2020 -0500
Added acknowledgement for pub/sub Streamer - Fixes #8.
Signed-off-by: samaitra
---
.../ignite/stream/pubsub/PubSubStreamer.java | 10
.../ignite/stream/pubsub/MockPubSubServer.java | 28 ++
2 files changed, 34 insertions(+), 4 deletions(-)
diff --git
a/modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
b/modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
index 13384d2..3a4b689 100644
---
a/modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
+++
b/modules/pub-sub/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java
@@ -35,6 +35,7 @@ import org.apache.ignite.stream.StreamAdapter;
import com.google.cloud.pubsub.v1.stub.GrpcSubscriberStub;
import com.google.cloud.pubsub.v1.stub.SubscriberStub;
import com.google.cloud.pubsub.v1.stub.SubscriberStubSettings;
+import com.google.pubsub.v1.AcknowledgeRequest;
import com.google.pubsub.v1.ProjectTopicName;
import com.google.pubsub.v1.PubsubMessage;
import com.google.pubsub.v1.PullRequest;
@@ -224,9 +225,18 @@ public class PubSubStreamer extends
StreamAdapter {
PullResponse pullResponse =
subscriberStub.pullCallable().call(pullRequest);
+List ackIds = new ArrayList<>();
for (ReceivedMessage message :
pullResponse.getReceivedMessagesList()) {
addMessage(message.getMessage());
+ackIds.add(message.getAckId());
}
+
+AcknowledgeRequest acknowledgeRequest =
AcknowledgeRequest.newBuilder()
+
.setSubscription(subscriptionName)
+
.addAllAckIds(ackIds)
+
.build();
+
+
subscriberStub.acknowledgeCallable().call(acknowledgeRequest);
}
} finally {
subscriberStub.close();
diff --git
a/modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
b/modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
index 20fe767..714961c 100644
---
a/modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
+++
b/modules/pub-sub/src/test/java/org/apache/ignite/stream/pubsub/MockPubSubServer.java
@@ -24,15 +24,15 @@ import com.google.api.gax.grpc.GrpcTransportChannel;
import com.google.api.gax.rpc.FixedTransportChannelProvider;
import com.google.cloud.pubsub.v1.Publisher;
import com.google.cloud.pubsub.v1.stub.SubscriberStubSettings;
+import com.google.protobuf.Empty;
+import com.google.pubsub.v1.AcknowledgeRequest;
import com.google.pubsub.v1.PubsubMessage;
import com.google.pubsub.v1.PullRequest;
import com.google.pubsub.v1.PullResponse;
import com.google.pubsub.v1.ReceivedMessage;
import java.io.IOException;
-import java.util.ArrayList;
import java.util.HashMap;
-import java.util.List;
import java.util.Map;
import java.util.Queue;
import java.util.UUID;
@@ -68,7 +68,6 @@ class MockPubSubServer {
public static final int MESSAGES_PER_REQUEST = 10;
private final Map publishers = new HashMap<>();
-private final List topicMessages = new ArrayList<>();
private final Queue blockingQueue = new
LinkedBlockingDeque<>();
public SubscriberStubSettings createSubscriberStub() throws IOException {
@@ -87,10 +86,31 @@ class MockPubSubServer {
@NotNull
private ManagedChannel managedChannel() {
ManagedChannel managedChannel = Mockito.mock(ManagedChannel.class);
-
when(managedChannel.newCall(any(MethodDescriptor.class),any(CallOptions.class))).thenAnswer((la)
-> clientCall());
+
when(managedChannel.newCall(any(MethodDescriptor.class),any(CallOptions.class))).thenAnswer((la)
-> {
+MethodDescriptor methodDescriptor = (MethodDescriptor)
la.getArguments()[0];
+
if(methodDescriptor.getFullMethodName().equals("google.pubsub.v1.Subscriber/Acknowledge"))
{
+return acknowledgeCall();
+}
+
+return clientCall();
+});
return managedChannel;
}
+private ClientCall acknowledgeCall() {
+ClientCall clientCall =
Mockito.mock(
[ignite-extensions] branch master updated: IGNITE-12517 Upgrade flink module version to 1.9.1 in ignite-extensions - Fixes #3.
This is an automated email from the ASF dual-hosted git repository. samaitra pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git The following commit(s) were added to refs/heads/master by this push: new f322752 IGNITE-12517 Upgrade flink module version to 1.9.1 in ignite-extensions - Fixes #3. f322752 is described below commit f322752f44de959391fd88e4e91dc07d2f702627 Author: samaitra AuthorDate: Wed Jan 1 10:03:45 2020 -0600 IGNITE-12517 Upgrade flink module version to 1.9.1 in ignite-extensions - Fixes #3. Signed-off-by: samaitra --- modules/flink-ext/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/flink-ext/pom.xml b/modules/flink-ext/pom.xml index 08b4be7..6a8bbd5 100644 --- a/modules/flink-ext/pom.xml +++ b/modules/flink-ext/pom.xml @@ -38,7 +38,7 @@ 2.9.0-SNAPSHOT 2.9.0-SNAPSHOT 2.9.0-SNAPSHOT -1.5.0 +1.9.1 0.42
[ignite-extensions] branch master updated: IGNITE-12262 Implement a Pub/Sub Data Streamer - Fixes #2.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new e5f9f98 IGNITE-12262 Implement a Pub/Sub Data Streamer - Fixes #2.
e5f9f98 is described below
commit e5f9f9815b9404f20171922b5061e55a56a2240b
Author: gkatzioura
AuthorDate: Sun Dec 29 12:28:49 2019 -0600
IGNITE-12262 Implement a Pub/Sub Data Streamer - Fixes #2.
Signed-off-by: samaitra
---
modules/pub-sub/README.txt | 33 +++
modules/pub-sub/config/example-ignite.xml | 73 +
modules/pub-sub/licenses/apache-2.0.txt| 202 ++
modules/pub-sub/pom.xml| 102 +++
.../ignite/stream/pubsub/PubSubStreamer.java | 248 +
.../apache/ignite/stream/pubsub/package-info.java | 21 ++
.../ignite/stream/pubsub/MockPubSubServer.java | 147 ++
.../stream/pubsub/PubSubStreamerSelfTest.java | 310 +
.../stream/pubsub/PubSubStreamerTestSuite.java | 29 ++
.../pub-sub/src/test/resources/example-ignite.xml | 73 +
parent/pom.xml | 4 +
pom.xml| 1 +
12 files changed, 1243 insertions(+)
diff --git a/modules/pub-sub/README.txt b/modules/pub-sub/README.txt
new file mode 100644
index 000..65e7754
--- /dev/null
+++ b/modules/pub-sub/README.txt
@@ -0,0 +1,33 @@
+Apache Ignite Pub/Sub Module
+---
+
+Pub/Sub module is a streaming connector to inject Pub/Sub data into Ignite
cache.
+
+Starting data transfer to Ignite can be done with the following steps.
+
+1. Import Ignite Pub/Sub Module in Maven Project
+
+If you are using Maven to manage dependencies of your project, you can add
Pub/Sub module
+dependency like this (replace '${ignite.version}' with actual Ignite version
you are
+interested in):
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+...
+
+...
+
+org.apache.ignite
+ignite-pub-sub
+${ignite.version}
+
+...
+
+...
+
+
+2. Create an Ignite configuration file (see example-ignite.xml) and make sure
it is accessible from the sink.
+
+3. Make sure your data input to the sink is specified. For example
`input.addSink(igniteSinkObject)`
diff --git a/modules/pub-sub/config/example-ignite.xml
b/modules/pub-sub/config/example-ignite.xml
new file mode 100644
index 000..d4f4dc1
--- /dev/null
+++ b/modules/pub-sub/config/example-ignite.xml
@@ -0,0 +1,73 @@
+
+
+
+
+
+http://www.springframework.org/schema/beans";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xmlns:util="http://www.springframework.org/schema/util";
+ xsi:schemaLocation="
+http://www.springframework.org/schema/beans
+http://www.springframework.org/schema/beans/spring-beans.xsd
+http://www.springframework.org/schema/util
+http://www.springframework.org/schema/util/spring-util.xsd";>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+127.0.0.1:47500..47509
+
+
+
+
+
+
+
+
diff --git a/modules/pub-sub/licenses/apache-2.0.txt
b/modules/pub-sub/licenses/apache-2.0.txt
new file mode 100644
index 000..d645695
--- /dev/null
+++ b/modules/pub-sub/licenses/apache-2.0.txt
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are un
[ignite-extensions] branch master updated: adding scripts for applying pull requests
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 4be45b5 adding scripts for applying pull requests
4be45b5 is described below
commit 4be45b521f393bf0dcec5bd1dd085b4bd56269ce
Author: samaitra
AuthorDate: Sat Dec 28 14:04:02 2019 -0600
adding scripts for applying pull requests
---
scripts/apply-pull-request.sh | 220 +
scripts/git-format-patch.sh| 91 +++
scripts/git-patch-functions.sh | 131 ++
scripts/git-patch-prop.sh | 24
scripts/git-remoteless-branches.sh | 35 ++
scripts/update-versions.sh | 35 ++
6 files changed, 536 insertions(+)
diff --git a/scripts/apply-pull-request.sh b/scripts/apply-pull-request.sh
new file mode 100755
index 000..ef27e52
--- /dev/null
+++ b/scripts/apply-pull-request.sh
@@ -0,0 +1,220 @@
+#!/bin/bash
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+#
+# Pull request applier.
+#
+
+#
+# Start of Functions.
+#
+
+#
+# Prints usage.
+#
+usage () {
+echo 'Usage: scripts/apply-pull-request.sh
[-tb|--targetbranch ]'
+echo 'The script takes pull-request by given id and merges (with squash)
all changes to target branch (master by default).'
+echo "Argument 'pull-request-id' is mandatory."
+echo "Target branch can be overwritten by using [-tb|--targetbranch
] argument paramethers."
+}
+
+#
+# End of Functions.
+#
+
+if [ "${GIT_HOME}" = "" ]; then
+GIT_HOME="$(dirname "$(cd "$(dirname "$0")"; "pwd")")";
+fi
+
+cd ${GIT_HOME}
+
+if [ "${SCRIPTS_HOME}" = "" ]; then
+SCRIPTS_HOME="${GIT_HOME}/scripts/"
+fi
+
+. ${SCRIPTS_HOME}/git-patch-functions.sh # Import patch functions.
+
+PR_ID=$1
+
+#
+# Start reading of command line params.
+#
+if [ "${PR_ID}" = "" ]; then
+echo $0", ERROR:"
+echo >&2 "You have to specify 'pull-request-id'."
+echo
+usage
+exit 1
+fi
+
+if [ "${PR_ID}" = "-h" ]; then
+usage
+exit 0
+fi
+
+if [ "${PR_ID}" = "--help" ]; then
+usage
+exit 0
+fi
+
+
+while [[ $# > 2 ]]
+do
+key="$2"
+
+case $key in
+-tb|--targetbranch)
+TARGET_BRANCH="$3"
+shift
+;;
+
+*)
+echo "Unknown parameter: ${key}"
+echo
+usage
+;;
+esac
+shift
+done
+#
+# Enf reading of command line params.
+#
+
+
+# Script variables.
+if [ "${APACHE_GIT}" = "" ]; then
+APACHE_GIT="https://gitbox.apache.org/repos/asf/ignite-extensions.git";
+fi
+
+if [ "${GITHUB_MIRROR}" = "" ]; then
+GITHUB_MIRROR="https://github.com/apache/ignite-extensions.git";
+fi
+
+if [ "${TARGET_BRANCH}" = "" ]; then
+TARGET_BRANCH="master"
+fi
+
+requireCleanWorkTree ${GIT_HOME}
+
+CURRENT_BRANCH=`git rev-parse --abbrev-ref HEAD`
+
+if [ "$CURRENT_BRANCH" != "${TARGET_BRANCH}" ]; then
+echo $0", ERROR:"
+echo "You have to be on ${TARGET_BRANCH} branch."
+
+exit 1
+fi
+
+# Check that target branch is up-to-date.
+APACHE_GIT_TARGET_BRANCH="apache-git-target-br-tmp"
+
+git fetch ${APACHE_GIT} ${TARGET_BRANCH}:${APACHE_GIT_TARGET_BRANCH} &>
/dev/null
+if test $? != 0; then
+echo $0", ERROR:"
+echo >&2 "Couldn't fetch '${TARGET_BRANCH}' branch from ${APACHE_GIT}."
+exit 1
+fi
+
+LOCAL_TARGET_BR_HASH=$(git rev-parse @)
+REMOTE_TARGET_BR_HASH=$(git rev-parse ${APACHE_GIT_TARGET_BRANCH})
+BASE_HASH=$(git merge-base @ ${APACHE_GIT_TARGET_BRANCH})
+
+git branch -D ${APACHE_GIT_TARGET_BRANCH} &> /dev/null
+
+if [ $LOCAL_TARGET_BR_HASH != $REMOTE_TARGET_BR_HASH ]; then
+echo $0", E
[ignite] branch master updated: IGNITE-7285 Add default query timeout - Fixes #6490.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 0140234 IGNITE-7285 Add default query timeout - Fixes #6490.
0140234 is described below
commit 014023453ac8c3bbdb5f9636a2b3d843de91d2f6
Author: samaitra
AuthorDate: Fri Nov 15 18:40:49 2019 -0600
IGNITE-7285 Add default query timeout - Fixes #6490.
Signed-off-by: samaitra
---
.../apache/ignite/cache/query/SqlFieldsQuery.java | 5 +-
.../ignite/configuration/IgniteConfiguration.java | 36
.../processors/odbc/odbc/OdbcRequestHandler.java | 4 +-
.../cache/ClientCacheSqlFieldsQueryRequest.java| 6 +-
.../processors/query/h2/QueryParameters.java | 39 +---
.../internal/processors/query/h2/QueryParser.java | 56 +-
...acheDistributedQueryDefaultTimeoutSelfTest.java | 197 +
...gniteCacheLocalQueryDefaultTimeoutSelfTest.java | 152
.../IgniteBinaryCacheQueryTestSuite2.java | 7 +-
9 files changed, 453 insertions(+), 49 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java
b/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java
index f00d882..6d6e167 100644
---
a/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java
+++
b/modules/core/src/main/java/org/apache/ignite/cache/query/SqlFieldsQuery.java
@@ -51,6 +51,9 @@ public class SqlFieldsQuery extends Query> {
/** Default value of the update internal batch size. */
private static final int DFLT_UPDATE_BATCH_SIZE = 1;
+/** Default value of Query timeout. Default is -1 means no timeout is set.
*/
+private static final int DFLT_QUERY_TIMEOUT = -1;
+
/** Do not remove. For tests only. */
@SuppressWarnings("NonConstantFieldWithUpperCaseName")
private static boolean DFLT_LAZY;
@@ -66,7 +69,7 @@ public class SqlFieldsQuery extends Query> {
private boolean collocated;
/** Query timeout in millis. */
-private int timeout;
+private int timeout = DFLT_QUERY_TIMEOUT;
/** */
private boolean enforceJoinOrder;
diff --git
a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
index 664fd12..ce30c3a 100644
---
a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
+++
b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
@@ -46,6 +46,7 @@ import org.apache.ignite.events.EventType;
import org.apache.ignite.failure.FailureHandler;
import
org.apache.ignite.internal.managers.eventstorage.GridEventStorageManager;
import org.apache.ignite.internal.processors.odbc.ClientListenerProcessor;
+import org.apache.ignite.internal.util.typedef.internal.A;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteAsyncCallback;
import org.apache.ignite.lang.IgniteInClosure;
@@ -242,6 +243,9 @@ public class IgniteConfiguration {
/** Default SQL query history size. */
public static final int DFLT_SQL_QUERY_HISTORY_SIZE = 1000;
+/** Default query timeout. */
+public static final long DFLT_QRY_TIMEOUT = 0;
+
/** Optional local Ignite instance name. */
private String igniteInstanceName;
@@ -293,6 +297,9 @@ public class IgniteConfiguration {
/** SQL query history size. */
private int sqlQryHistSize = DFLT_SQL_QUERY_HISTORY_SIZE;
+/** Default query timeout. */
+private long dfltQryTimeout = DFLT_QRY_TIMEOUT;
+
/** Ignite installation folder. */
private String igniteHome;
@@ -623,6 +630,7 @@ public class IgniteConfiguration {
consistentId = cfg.getConsistentId();
daemon = cfg.isDaemon();
dataStreamerPoolSize = cfg.getDataStreamerThreadPoolSize();
+dfltQryTimeout = cfg.getDefaultQueryTimeout();
deployMode = cfg.getDeploymentMode();
discoStartupDelay = cfg.getDiscoveryStartupDelay();
execCfgs = cfg.getExecutorConfiguration();
@@ -1076,6 +1084,34 @@ public class IgniteConfiguration {
}
/**
+ * Defines the default query timeout.
+ *
+ * Defaults to {@link #DFLT_QRY_TIMEOUT}.
+ * {@code 0} means there is no timeout (this
+ * is a default value)
+ *
+ * @return Default query timeout.
+ */
+public long getDefaultQueryTimeout() {
+return dfltQryTimeout;
+}
+
+/**
+ * Sets timeout in milliseconds for default query timeout.
+ * {@code 0} means there is no timeout (this
+ * is a default value)
+ *
+ * @param dfltQryTimeout Timeout in milliseconds.
+ * @return {@code this} for chaining.
+ */
+public IgniteConfiguration setDefaultQueryTimeout(lon
[ignite] branch master updated: IGNITE-12018 Web Agent docker image: 'functions.sh' not found - Fixes #6808.
This is an automated email from the ASF dual-hosted git repository.
samaitra pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 851e022 IGNITE-12018 Web Agent docker image: 'functions.sh' not found
- Fixes #6808.
851e022 is described below
commit 851e02288186425b878dbb31b66bb91c1652603a
Author: samaitra
AuthorDate: Mon Sep 2 10:28:21 2019 -0500
IGNITE-12018 Web Agent docker image: 'functions.sh' not found - Fixes #6808.
Signed-off-by: samaitra
---
docker/web-agent/Dockerfile | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docker/web-agent/Dockerfile b/docker/web-agent/Dockerfile
index 7c4cdd3..7e45ad3 100644
--- a/docker/web-agent/Dockerfile
+++ b/docker/web-agent/Dockerfile
@@ -39,7 +39,7 @@ RUN apk --no-cache \
add bash
# Copy main binary archive
-COPY ignite-web-agent*/* ./
+COPY ignite-web-agent* ./
# Entrypoint
CMD ./ignite-web-agent.sh -d ${DRIVER_FOLDER} -n ${NODE_URI} -s ${SERVER_URI}
-t ${TOKENS}
ignite git commit: IGNITE-5695 FlinkIgniteSinkSelfTest is failing due to conflicting default test timeout and default flush frequency - Fixes #2241.
Repository: ignite
Updated Branches:
refs/heads/master 80c95ff79 -> 836906c89
IGNITE-5695 FlinkIgniteSinkSelfTest is failing due to conflicting default test
timeout and default flush frequency - Fixes #2241.
Signed-off-by: samaitra
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/836906c8
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/836906c8
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/836906c8
Branch: refs/heads/master
Commit: 836906c89dfb880ac602046c37b3a2dba3ebdc46
Parents: 80c95ff
Author: samaitra
Authored: Wed Jul 5 23:28:15 2017 -0500
Committer: samaitra
Committed: Wed Jul 5 23:28:15 2017 -0500
--
.../java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/ignite/blob/836906c8/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
--
diff --git
a/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
b/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
index 083457c..50eedb8 100644
---
a/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
+++
b/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
@@ -53,7 +53,7 @@ public class FlinkIgniteSinkSelfTest extends
GridCommonAbstractTest {
/** {@inheritDoc} */
@Override protected long getTestTimeout() {
-return 10_000;
+return 20_000;
}
/** {@inheritDoc} */
ignite git commit: IGNITE-3963 FlinkIgniteSinkSelfTest fails with exception IllegalArgumentException - Fixes #1112.
Repository: ignite
Updated Branches:
refs/heads/master 3e4042b6d -> f600750cd
IGNITE-3963 FlinkIgniteSinkSelfTest fails with exception
IllegalArgumentException - Fixes #1112.
Signed-off-by: samaitra
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f600750c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f600750c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f600750c
Branch: refs/heads/master
Commit: f600750cda85ab859ba370bed0d22d875c6e29cf
Parents: 3e4042b
Author: samaitra
Authored: Sat Oct 8 00:16:20 2016 +0530
Committer: samaitra
Committed: Sat Oct 8 00:16:20 2016 +0530
--
.../src/main/java/org/apache/ignite/sink/flink/IgniteSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/ignite/blob/f600750c/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
--
diff --git
a/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
b/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
index e0ae783..2f18f80 100644
--- a/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
+++ b/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
@@ -34,7 +34,7 @@ public class IgniteSink extends RichSinkFunction {
private static final long DFLT_FLUSH_FREQ = 1L;
/** Logger. */
-private final IgniteLogger log;
+private final transient IgniteLogger log;
/** Automatic flush frequency. */
private long autoFlushFrequency = DFLT_FLUSH_FREQ;
