You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by be...@apache.org on 2021/04/07 16:10:24 UTC
[incubator-wayang] branch debugger updated (a3342a0 -> 9b7e6fb)
This is an automated email from the ASF dual-hosted git repository.
bertty pushed a change to branch debugger
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git.
from a3342a0 [WAYANG-28] add OneElementIterator.java
new 8f1f5f7 [WAYANG-28] add Wrappers of the tagger function
new 995d6fb [WAYANG-28] add empty implementation on Shipper components
new dd4e5af [WAYANG-28] add basic implementation on Sniff
new 7873dfe [WAYANG-28] creation module shipper of hackit
new b054d4f [WAYANG-28] adding missing headers
new 9b7e6fb [WAYANG-28] adding empty module of shipper using RabbitMQ
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
wayang-plugins/wayang-hackit/pom.xml | 1 +
.../hackit/core/iterator/ElementPlusIterator.java | 17 +++++++++
.../hackit/core/iterator/OneElementIterator.java | 17 +++++++++
.../hackit/core/sniffer/clone/BasicCloner.java | 17 +++++++++
.../hackit/core/sniffer/inject/EmptyInjector.java | 17 +++++++++
.../receiver/{Receiver.java => EmptyReceiver.java} | 20 +++++++----
.../sender/{Sender.java => EmptySender.java} | 18 ++++++----
.../{Sniff.java => CollectionTagsToSniff.java} | 29 ++++++++++++---
.../sniff/{Sniff.java => SingleTagToSniff.java} | 25 ++++++++++---
.../wrapper/FlatmapWrapperHackit.java} | 24 ++++++++++---
.../wrapper/FunctionWrapperHackit.java} | 19 ++++++----
.../wrapper/PredicateWrapperHackit.java} | 20 +++++++----
.../tagger/wrapper/template/FlatMapTemplate.java | 9 +++--
.../tagger/wrapper/template/FunctionTemplate.java | 9 ++---
.../wayang-hackit/wayang-hackit-shipper/pom.xml | 41 ++++++++++++++++++++++
.../wayang-hackit-shipper-rabbitmq/pom.xml | 37 +++++++++++++++++++
16 files changed, 271 insertions(+), 49 deletions(-)
copy wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/receiver/{Receiver.java => EmptyReceiver.java} (71%)
copy wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/sender/{Sender.java => EmptySender.java} (77%)
copy wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/{Sniff.java => CollectionTagsToSniff.java} (57%)
copy wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/{Sniff.java => SingleTagToSniff.java} (55%)
copy wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/{iterator/HackitIterator.java => tagger/wrapper/FlatmapWrapperHackit.java} (52%)
copy wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/{iterator/HackitIterator.java => tagger/wrapper/FunctionWrapperHackit.java} (54%)
copy wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/{iterator/HackitIterator.java => tagger/wrapper/PredicateWrapperHackit.java} (54%)
copy wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java => wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FlatMapTemplate.java (81%)
copy wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java => wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FunctionTemplate.java (84%)
create mode 100644 wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
create mode 100644 wayang-plugins/wayang-hackit/wayang-hackit-shipper/wayang-hackit-shipper-rabbitmq/pom.xml
[incubator-wayang] 04/06: [WAYANG-28] creation module shipper of
hackit
Posted by be...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bertty pushed a commit to branch debugger
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 7873dfe96dde3d5cb96527bcd4cdcf1e3953e120
Author: Bertty Contreras-Rojas <be...@scalytics.io>
AuthorDate: Tue Apr 6 13:42:24 2021 -0400
[WAYANG-28] creation module shipper of hackit
---
wayang-plugins/wayang-hackit/pom.xml | 1 +
.../wayang-hackit/wayang-hackit-shipper/pom.xml | 37 ++++++++++++++++++++++
2 files changed, 38 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/pom.xml b/wayang-plugins/wayang-hackit/pom.xml
index 4e44394..d86fb5d 100644
--- a/wayang-plugins/wayang-hackit/pom.xml
+++ b/wayang-plugins/wayang-hackit/pom.xml
@@ -38,6 +38,7 @@
</description>
<modules>
<module>wayang-hackit-core</module>
+ <module>wayang-hackit-shipper</module>
</modules>
<properties>
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml b/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
new file mode 100644
index 0000000..cd8c838
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ 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.
+ -->
+
+<project xmlns="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">
+ <parent>
+ <artifactId>wayang-hackit</artifactId>
+ <groupId>org.apache.wayang</groupId>
+ <version>0.6.0-SNAPSHOT</version>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+
+ <artifactId>wayang-hackit-shipper</artifactId>
+
+ <properties>
+ <maven.compiler.source>8</maven.compiler.source>
+ <maven.compiler.target>8</maven.compiler.target>
+ </properties>
+
+</project>
[incubator-wayang] 01/06: [WAYANG-28] add Wrappers of the tagger
function
Posted by be...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bertty pushed a commit to branch debugger
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 8f1f5f7f61fc7ec840dac2e0dace2d1dbfe33467
Author: Bertty Contreras-Rojas <be...@scalytics.io>
AuthorDate: Tue Apr 6 13:22:25 2021 -0400
[WAYANG-28] add Wrappers of the tagger function
---
.../core/tagger/wrapper/FlatmapWrapperHackit.java | 45 ++++++++++++++++++++++
.../core/tagger/wrapper/FunctionWrapperHackit.java | 38 ++++++++++++++++++
.../tagger/wrapper/PredicateWrapperHackit.java | 39 +++++++++++++++++++
.../tagger/wrapper/template/FlatMapTemplate.java | 25 ++++++++++++
.../tagger/wrapper/template/FunctionTemplate.java | 23 +++++++++++
5 files changed, 170 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/FlatmapWrapperHackit.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/FlatmapWrapperHackit.java
new file mode 100644
index 0000000..a57cd23
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/FlatmapWrapperHackit.java
@@ -0,0 +1,45 @@
+/*
+ * 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.
+ */
+package org.apache.wayang.plugin.hackit.core.tagger.wrapper;
+
+import org.apache.wayang.plugin.hackit.core.tagger.HackitTagger;
+import org.apache.wayang.plugin.hackit.core.tagger.wrapper.template.FlatMapTemplate;
+import org.apache.wayang.plugin.hackit.core.tuple.HackitTuple;
+
+import java.util.Iterator;
+
+public class FlatmapWrapperHackit<IDType, I, O>
+ extends HackitTagger
+ implements FlatMapTemplate<HackitTuple<IDType, I>, HackitTuple<IDType, O>> {
+
+ private FlatMapTemplate<I, O> function;
+
+ public FlatmapWrapperHackit(
+ FlatMapTemplate<I, O> function
+ ) {
+ this.function = function;
+ }
+
+
+ @Override
+ public Iterator<HackitTuple<IDType, O>> execute(HackitTuple<IDType, I> kiHackItTuple) {
+ this.preTaggingTuple(kiHackItTuple);
+ Iterator<O> result = this.function.execute(kiHackItTuple.getValue());
+ return this.postTaggingTuple(kiHackItTuple, result);
+ }
+}
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/FunctionWrapperHackit.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/FunctionWrapperHackit.java
new file mode 100644
index 0000000..c244eb0
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/FunctionWrapperHackit.java
@@ -0,0 +1,38 @@
+/*
+ * 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.
+ */
+package org.apache.wayang.plugin.hackit.core.tagger.wrapper;
+
+import org.apache.wayang.plugin.hackit.core.tagger.HackitTagger;
+import org.apache.wayang.plugin.hackit.core.tagger.wrapper.template.FunctionTemplate;
+import org.apache.wayang.plugin.hackit.core.tuple.HackitTuple;
+
+public class FunctionWrapperHackit <IDType, I, O> extends HackitTagger implements FunctionTemplate<HackitTuple<IDType, I>, HackitTuple<IDType, O>> {
+
+ private FunctionTemplate<I, O> function;
+
+ public FunctionWrapperHackit(FunctionTemplate<I, O> function) {
+ this.function = function;
+ }
+
+ @Override
+ public HackitTuple<IDType, O> execute(HackitTuple<IDType, I> v1) {
+ this.preTaggingTuple(v1);
+ O result = this.function.execute(v1.getValue());
+ return this.postTaggingTuple(v1, result);
+ }
+}
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/PredicateWrapperHackit.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/PredicateWrapperHackit.java
new file mode 100644
index 0000000..c2636e2
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/PredicateWrapperHackit.java
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+package org.apache.wayang.plugin.hackit.core.tagger.wrapper;
+
+import org.apache.wayang.plugin.hackit.core.tagger.HackitTagger;
+import org.apache.wayang.plugin.hackit.core.tagger.wrapper.template.FunctionTemplate;
+import org.apache.wayang.plugin.hackit.core.tuple.HackitTuple;
+
+public class PredicateWrapperHackit<IDType, I> extends HackitTagger implements FunctionTemplate<HackitTuple<IDType, I>, Boolean> {
+
+ private FunctionTemplate<I, Boolean> function;
+
+ public PredicateWrapperHackit(FunctionTemplate<I, Boolean> function) {
+ this.function = function;
+ }
+
+ @Override
+ public Boolean execute(HackitTuple<IDType, I> v1) {
+ this.preTaggingTuple(v1);
+ Boolean result = this.function.execute(v1.getValue());
+ this.postTaggingTuple(v1);
+ return result;
+ }
+}
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FlatMapTemplate.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FlatMapTemplate.java
new file mode 100644
index 0000000..abe6471
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FlatMapTemplate.java
@@ -0,0 +1,25 @@
+/*
+ * 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.
+ */
+package org.apache.wayang.plugin.hackit.core.tagger.wrapper.template;
+
+import java.util.Iterator;
+
+public interface FlatMapTemplate<I, O> {
+
+ public Iterator<O> execute(I input);
+}
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FunctionTemplate.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FunctionTemplate.java
new file mode 100644
index 0000000..9e5cb65
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/tagger/wrapper/template/FunctionTemplate.java
@@ -0,0 +1,23 @@
+/*
+ * 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.
+ */
+package org.apache.wayang.plugin.hackit.core.tagger.wrapper.template;
+
+public interface FunctionTemplate<I, O> {
+
+ public O execute(I input);
+}
[incubator-wayang] 05/06: [WAYANG-28] adding missing headers
Posted by be...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bertty pushed a commit to branch debugger
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit b054d4fc1c78baa7fe695eaa8057d43f4dc31c42
Author: Bertty Contreras-Rojas <be...@scalytics.io>
AuthorDate: Tue Apr 6 15:06:51 2021 -0400
[WAYANG-28] adding missing headers
---
.../hackit/core/iterator/ElementPlusIterator.java | 17 +++++++++++++++++
.../plugin/hackit/core/iterator/OneElementIterator.java | 17 +++++++++++++++++
.../plugin/hackit/core/sniffer/clone/BasicCloner.java | 17 +++++++++++++++++
.../hackit/core/sniffer/inject/EmptyInjector.java | 17 +++++++++++++++++
4 files changed, 68 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/ElementPlusIterator.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/ElementPlusIterator.java
index 73353bc..32e52c9 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/ElementPlusIterator.java
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/ElementPlusIterator.java
@@ -1,3 +1,20 @@
+/*
+ * 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.
+ */
package org.apache.wayang.plugin.hackit.core.iterator;
import java.util.Iterator;
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/OneElementIterator.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/OneElementIterator.java
index 5f5c0dd..1ebf412 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/OneElementIterator.java
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/iterator/OneElementIterator.java
@@ -1,3 +1,20 @@
+/*
+ * 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.
+ */
package org.apache.wayang.plugin.hackit.core.iterator;
import java.util.Iterator;
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/clone/BasicCloner.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/clone/BasicCloner.java
index 47970a6..c644e33 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/clone/BasicCloner.java
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/clone/BasicCloner.java
@@ -1,3 +1,20 @@
+/*
+ * 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.
+ */
package org.apache.wayang.plugin.hackit.core.sniffer.clone;
import org.apache.commons.lang3.SerializationUtils;
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/inject/EmptyInjector.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/inject/EmptyInjector.java
index 689882d..94d265f 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/inject/EmptyInjector.java
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/inject/EmptyInjector.java
@@ -1,3 +1,20 @@
+/*
+ * 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.
+ */
package org.apache.wayang.plugin.hackit.core.sniffer.inject;
import org.apache.wayang.plugin.hackit.core.iterator.ElementPlusIterator;
[incubator-wayang] 02/06: [WAYANG-28] add empty implementation on
Shipper components
Posted by be...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bertty pushed a commit to branch debugger
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 995d6fb0c6823f193f61aa633bb69901cedcdef6
Author: Bertty Contreras-Rojas <be...@scalytics.io>
AuthorDate: Tue Apr 6 13:25:13 2021 -0400
[WAYANG-28] add empty implementation on Shipper components
---
.../sniffer/shipper/receiver/EmptyReceiver.java | 38 ++++++++++++++++++++++
.../core/sniffer/shipper/sender/EmptySender.java | 35 ++++++++++++++++++++
2 files changed, 73 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/receiver/EmptyReceiver.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/receiver/EmptyReceiver.java
new file mode 100644
index 0000000..2bd42a7
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/receiver/EmptyReceiver.java
@@ -0,0 +1,38 @@
+/*
+ * 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.
+ */
+
+package org.apache.wayang.plugin.hackit.core.sniffer.shipper.receiver;
+
+import java.util.Collections;
+import java.util.Iterator;
+
+public class EmptyReceiver<T> extends Receiver<T> {
+
+ @Override
+ public void init() {}
+
+ @Override
+ public Iterator<T> getElements() {
+ return (Iterator<T>) Collections.emptyIterator();
+ }
+
+ @Override
+ public void close() {
+
+ }
+}
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/sender/EmptySender.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/sender/EmptySender.java
new file mode 100644
index 0000000..6ac0817
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/shipper/sender/EmptySender.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.wayang.plugin.hackit.core.sniffer.shipper.sender;
+
+public class EmptySender<T> implements Sender<T> {
+
+ @Override
+ public void init() {
+
+ }
+
+ @Override
+ public void send(T value) {}
+
+ @Override
+ public void close() {
+
+ }
+}
[incubator-wayang] 06/06: [WAYANG-28] adding empty module of
shipper using RabbitMQ
Posted by be...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bertty pushed a commit to branch debugger
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 9b7e6fb25bc5c09c4ed5c6432cb8e03d84053c9e
Author: Bertty Contreras-Rojas <be...@scalytics.io>
AuthorDate: Wed Apr 7 12:10:03 2021 -0400
[WAYANG-28] adding empty module of shipper using RabbitMQ
---
wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml | 4 ++++
.../{ => wayang-hackit-shipper-rabbitmq}/pom.xml | 4 ++--
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml b/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
index cd8c838..6f0c290 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
@@ -28,6 +28,10 @@
<modelVersion>4.0.0</modelVersion>
<artifactId>wayang-hackit-shipper</artifactId>
+ <packaging>pom</packaging>
+ <modules>
+ <module>wayang-hackit-shipper-rabbitmq</module>
+ </modules>
<properties>
<maven.compiler.source>8</maven.compiler.source>
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml b/wayang-plugins/wayang-hackit/wayang-hackit-shipper/wayang-hackit-shipper-rabbitmq/pom.xml
similarity index 92%
copy from wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
copy to wayang-plugins/wayang-hackit/wayang-hackit-shipper/wayang-hackit-shipper-rabbitmq/pom.xml
index cd8c838..36fff1c 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-shipper/pom.xml
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-shipper/wayang-hackit-shipper-rabbitmq/pom.xml
@@ -21,13 +21,13 @@
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">
<parent>
- <artifactId>wayang-hackit</artifactId>
+ <artifactId>wayang-hackit-shipper</artifactId>
<groupId>org.apache.wayang</groupId>
<version>0.6.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>wayang-hackit-shipper</artifactId>
+ <artifactId>wayang-hackit-shipper-rabbitmq</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
[incubator-wayang] 03/06: [WAYANG-28] add basic implementation on
Sniff
Posted by be...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bertty pushed a commit to branch debugger
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit dd4e5af2218ac64fd808cb9d903c60a51a622e6e
Author: Bertty Contreras-Rojas <be...@scalytics.io>
AuthorDate: Tue Apr 6 13:28:37 2021 -0400
[WAYANG-28] add basic implementation on Sniff
---
.../core/sniffer/sniff/CollectionTagsToSniff.java | 46 ++++++++++++++++++++++
.../core/sniffer/sniff/SingleTagToSniff.java | 42 ++++++++++++++++++++
2 files changed, 88 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/CollectionTagsToSniff.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/CollectionTagsToSniff.java
new file mode 100644
index 0000000..a2811b0
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/CollectionTagsToSniff.java
@@ -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.
+ */
+
+package org.apache.wayang.plugin.hackit.core.sniffer.sniff;
+
+import org.apache.wayang.plugin.hackit.core.tags.HackitTag;
+
+import java.util.HashSet;
+import java.util.Set;
+
+public class CollectionTagsToSniff implements Sniff {
+
+ public Set<HackitTag> tags2sniff;
+
+ public CollectionTagsToSniff(){
+ this.tags2sniff = new HashSet<>();
+ }
+
+ public boolean sniff(HackitTag tag){
+ return this.tags2sniff.contains(tag);
+ }
+
+ public void addTag2sniff(HackitTag tag) {
+ this.tags2sniff.add(tag);
+ }
+
+ @Override
+ public boolean sniff(Object input) {
+ return false;
+ }
+}
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/SingleTagToSniff.java b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/SingleTagToSniff.java
new file mode 100644
index 0000000..9ce8ede
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-core/src/main/java/org/apache/wayang/plugin/hackit/core/sniffer/sniff/SingleTagToSniff.java
@@ -0,0 +1,42 @@
+/*
+ * 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.
+ */
+
+package org.apache.wayang.plugin.hackit.core.sniffer.sniff;
+
+import org.apache.wayang.plugin.hackit.core.tags.HackitTag;
+
+public class SingleTagToSniff implements Sniff {
+
+ public HackitTag tags2sniff;
+
+ public boolean sniff(HackitTag tag){
+ return this.tags2sniff.equals(tag);
+ }
+
+ public void addTag2sniff(HackitTag tag) {
+ if(this.tags2sniff != null){
+ throw new RuntimeException("The SingleTagToSniff already got the tag, if you need more of one tag use CollectionTagsToSniff class");
+ }
+ this.tags2sniff = tag;
+ }
+
+ @Override
+ public boolean sniff(Object input) {
+ return false;
+ }
+}