This is an automated email from the ASF dual-hosted git repository.
hansva pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hop.git
from 14fdbd40a0 Merge pull request #1543 from sramazzina/HOP-3988
new 568fa1a1eb HOP-3985 : Support AWS Kinesis over Beam
new 94478cc5eb HOP-4008 : Web Service: expose POST body content as variable
new 5e1f7bd240 Merge pull request #1544 from mattcasters/master
The 4129 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:
assemblies/plugins/engines/beam/pom.xml | 5 +
.../plugins/engines/beam/src/assembly/assembly.xml | 8 +-
.../images/hop-server/web-service-example.png | Bin 99548 -> 61583 bytes
.../modules/ROOT/pages/hop-server/web-service.adoc | 10 +-
.../pipeline/transforms/beamkinesisconsume.adoc | 103 ++++
.../pipeline/transforms/beamkinesisproduce.adoc | 64 ++
.../java/org/apache/hop/www/WebServiceServlet.java | 19 +
.../org/apache/hop/www/service/WebService.java | 37 +-
plugins/engines/beam/pom.xml | 5 +
.../apache/hop/beam/core/fn/StaticHopRowFn.java | 19 +-
.../BeamKinesisConsume.java} | 13 +-
.../kinesis/BeamKinesisConsumeDialog.java | 649 +++++++++++++++++++++
.../transforms/kinesis/BeamKinesisConsumeMeta.java | 454 ++++++++++++++
.../kinesis/BeamKinesisConsumeTransform.java} | 341 +++++------
.../BeamKinesisProduce.java} | 13 +-
.../kinesis/BeamKinesisProduceDialog.java | 318 ++++++++++
.../BeamKinesisProduceMeta.java} | 175 +++---
.../kinesis/BeamKinesisProduceTransform.java | 227 +++++++
.../kinesis/KinesisConfigOption.java} | 38 +-
.../kinesis/KinesisRecordToHopRowFn.java | 161 +++++
...am-kafka-input.svg => beam-kinesis-consume.svg} | 25 +-
.../src/main/resources/beam-kinesis-produce.svg | 547 +++++++++++++++++
.../kinesis/messages/messages_en_US.properties | 70 +++
.../hop/ui/www/service/WebServiceEditor.java | 31 +-
.../hop/ui/www/service/WebServiceGuiPlugin.java | 3 +-
.../www/service/messages/messages_en_US.properties | 2 +
26 files changed, 2996 insertions(+), 341 deletions(-)
create mode 100644
docs/hop-user-manual/modules/ROOT/pages/pipeline/transforms/beamkinesisconsume.adoc
create mode 100644
docs/hop-user-manual/modules/ROOT/pages/pipeline/transforms/beamkinesisproduce.adoc
copy
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/{kafka/BeamConsume.java
=> kinesis/BeamKinesisConsume.java} (78%)
create mode 100644
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kinesis/BeamKinesisConsumeDialog.java
create mode 100644
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kinesis/BeamKinesisConsumeMeta.java
copy
plugins/engines/beam/src/main/java/org/apache/hop/beam/{core/transform/BeamKafkaInputTransform.java
=> transforms/kinesis/BeamKinesisConsumeTransform.java} (50%)
copy
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/{kafka/BeamProduce.java
=> kinesis/BeamKinesisProduce.java} (79%)
create mode 100644
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kinesis/BeamKinesisProduceDialog.java
copy
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/{kafka/BeamProduceMeta.java
=> kinesis/BeamKinesisProduceMeta.java} (55%)
create mode 100644
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kinesis/BeamKinesisProduceTransform.java
copy
plugins/engines/beam/src/main/java/org/apache/hop/beam/{metadata/JobParameter.java
=> transforms/kinesis/KinesisConfigOption.java} (60%)
create mode 100644
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kinesis/KinesisRecordToHopRowFn.java
copy plugins/engines/beam/src/main/resources/{beam-kafka-input.svg =>
beam-kinesis-consume.svg} (97%)
create mode 100644
plugins/engines/beam/src/main/resources/beam-kinesis-produce.svg
create mode 100644
plugins/engines/beam/src/main/resources/org/apache/hop/beam/transforms/kinesis/messages/messages_en_US.properties
