ASF Git Repos - hop.git/commit

author	Matt Casters <mattcasters@gmail.com>
	Fri, 4 Jun 2021 19:34:30 +0000 (21:34 +0200)
committer	Matt Casters <mattcasters@gmail.com>
	Fri, 4 Jun 2021 19:35:37 +0000 (21:35 +0200)
commit	ef114f00a93781abf3b9052ce5cf179a4adec23d
tree	bd28fda758a4f8c4cd36cad8c3ffe69a1a69fbbc	tree \| snapshot
parent	7878935dc120a258db041a8f9f843f837eddfab1	commit \| diff

HOP-2932 : Add Big Table support to the Beam engines
HOP-2939 : Update Apache Beam API to 2.29.0 + jar version alignments

52 files changed:

assemblies/plugins/databases/googlebigquery-assemblies/pom.xml		diff \| blob \| history
assemblies/plugins/engines/beam/pom.xml		diff \| blob \| history
assemblies/plugins/engines/beam/src/assembly/assembly.xml		diff \| blob \| history
assemblies/plugins/tech/google/pom.xml		diff \| blob \| history
plugins/engines/beam/pom.xml		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/core/fn/HopToStringFn.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/HopPipelineMetaToBeamPipelineConverter.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/IBeamPipelineTransformHandler.java	[moved from plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/IBeamTransformHandler.java with 56% similarity]	diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamBaseTransformHandler.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamBigQueryInputTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamBigQueryOutputTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamGenericTransformHandler.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamGroupByTransformHandler.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamInputTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamKafkaInputTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamKafkaOutputTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamMergeJoinTransformHandler.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamOutputTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamPublisherTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamRowGeneratorTransformHandler.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamSubscriberTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamTimestampTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/pipeline/handler/BeamWindowTransformHandler.java	[deleted file]	blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bigtable/BeamBigtableInputDialog.java	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bigtable/BeamBigtableInputMeta.java	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bigtable/BeamBigtableOutputDialog.java	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bigtable/BeamBigtableOutputMeta.java	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bigtable/BigtableColumn.java	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bigtable/HopToBigtableFn.java	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bq/BQField.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bq/BeamBQInputMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/bq/BeamBQOutputMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/io/BeamInputMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/io/BeamOutputMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kafka/BeamConsumeMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kafka/BeamProduceMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/kafka/ConfigOption.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/pubsub/BeamPublishMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/pubsub/BeamSubscribeMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/window/BeamTimestampMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/java/org/apache/hop/beam/transforms/window/BeamWindowMeta.java		diff \| blob \| history
plugins/engines/beam/src/main/resources/beam-gcp-bigtable-input.svg	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/resources/beam-gcp-bigtable-output.svg	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/resources/beam-gcp-bigtable.svg	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/resources/org/apache/hop/beam/transforms/bigtable/messages/messages_en_US.properties	[new file with mode: 0644]	blob
plugins/engines/beam/src/main/samples/beam/pipelines/input-process-output.hpl		diff \| blob \| history
plugins/engines/beam/src/main/samples/metadata/pipeline-run-configuration/DataFlow.json		diff \| blob \| history
plugins/engines/beam/src/test/java/org/apache/hop/beam/util/BeamPipelineMetaUtil.java		diff \| blob \| history
plugins/misc/testing/src/main/java/org/apache/hop/testing/xp/LocationMouseDoubleClickExtensionPoint.java		diff \| blob \| history
plugins/misc/testing/src/main/java/org/apache/hop/ui/testing/PipelineUnitTestSetLocationDialog.java		diff \| blob \| history
plugins/tech/google/pom.xml		diff \| blob \| history
pom.xml		diff \| blob \| history

Hop Orchestration Platform

RSS Atom