You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hop.apache.org by ha...@apache.org on 2022/09/28 07:19:08 UTC
[hop] branch master updated (fd6f2b021f -> 5a6770a500)
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 fd6f2b021f Merge pull request #1706 from tanquetav/fix_context_window_position
new 9d5ef6988d HOP-4243 : Row generator dialog doesn't remember previous row field
new 6fae7c8082 HOP-4243 : Row generator dialog doesn't remember previous row field (code hardening)
new 7c55b39c97 HOP-4024 : Create a new execution information platform (Neo4j, Beam, bug fixes) HOP-4244 : Metadata perspective editors should not create dialogs (+UI fixes)
new 5a6770a500 Merge pull request #1707 from mattcasters/master
The 4538 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:
core/src/main/java/org/apache/hop/core/Const.java | 8 +
.../java/org/apache/hop/core/row}/JsonRowMeta.java | 57 +-
.../java/org/apache/hop/execution/Execution.java | 21 +
.../org/apache/hop/execution/ExecutionBuilder.java | 75 +-
.../apache/hop/execution/ExecutionDataBuilder.java | 14 +-
.../org/apache/hop/execution/ExecutionState.java | 26 +-
.../hop/execution/ExecutionStateBuilder.java | 51 +-
.../hop/execution/IExecutionInfoLocation.java | 86 +-
.../apache/hop/execution/IExecutionMatcher.java | 9 +-
.../execution/local/FileExecutionInfoLocation.java | 44 +-
.../remote/RemoteExecutionInfoLocation.java | 47 +-
.../dataprof/BasicDataProfilingDataSampler.java | 2 +-
.../java/org/apache/hop/pipeline/Pipeline.java | 12 +-
.../engines/local/LocalPipelineEngine.java | 97 +-
.../java/org/apache/hop/workflow/Workflow.java | 5 +
.../engines/local/LocalWorkflowEngine.java | 56 +-
.../apache/hop/www/GetExecutionInfoServlet.java | 239 ++--
.../apache/hop/execution/ExecutionDataTest.java | 2 +-
.../hop/beam/core/fn/BQSchemaAndRecordToHopFn.java | 3 +-
.../org/apache/hop/beam/core/fn/GroupByFn.java | 2 +-
.../org/apache/hop/beam/core/fn/HopKeyValueFn.java | 3 +-
.../hop/beam/core/fn/HopRowToKVStringStringFn.java | 2 +-
.../apache/hop/beam/core/fn/HopToBQTableRowFn.java | 2 +-
.../org/apache/hop/beam/core/fn/HopToStringFn.java | 2 +-
.../hop/beam/core/fn/KVLongStringToHopRowFn.java | 3 +-
.../hop/beam/core/fn/MergeJoinAssemblerFn.java | 3 +-
.../apache/hop/beam/core/fn/PublishMessagesFn.java | 2 +-
.../apache/hop/beam/core/fn/PublishStringsFn.java | 2 +-
.../hop/beam/core/fn/PubsubMessageToHopRowFn.java | 3 +-
.../apache/hop/beam/core/fn/StaticHopRowFn.java | 2 +-
.../org/apache/hop/beam/core/fn/StringToHopFn.java | 3 +-
.../apache/hop/beam/core/fn/StringToHopRowFn.java | 3 +-
.../org/apache/hop/beam/core/fn/TimestampFn.java | 2 +-
.../org/apache/hop/beam/core/fn/WindowInfoFn.java | 2 +-
.../beam/core/transform/BeamBQOutputTransform.java | 3 +-
.../core/transform/BeamKafkaInputTransform.java | 3 +-
.../core/transform/BeamKafkaOutputTransform.java | 2 +-
.../beam/core/transform/BeamOutputTransform.java | 2 +-
.../beam/core/transform/BeamPublishTransform.java | 2 +-
.../core/transform/BeamSubscribeTransform.java | 2 +-
.../hop/beam/core/transform/GroupByTransform.java | 2 +-
.../hop/beam/core/transform/TransformBaseFn.java | 146 ++-
.../core/transform/TransformBatchTransform.java | 24 +-
.../hop/beam/core/transform/TransformFn.java | 25 +-
.../hop/beam/engines/BeamPipelineEngine.java | 26 +-
.../handler/BeamGenericTransformHandler.java | 2 +-
.../handler/BeamGroupByTransformHandler.java | 2 +-
.../handler/BeamMergeJoinTransformHandler.java | 3 +-
.../handler/BeamRowGeneratorTransformHandler.java | 2 +-
.../transforms/bigtable/BeamBigtableInputMeta.java | 7 +-
.../bigtable/BeamBigtableOutputMeta.java | 2 +-
.../transforms/bigtable/BigtableRowToHopRowFn.java | 5 +-
.../beam/transforms/bigtable/HopToBigtableFn.java | 2 +-
.../hop/beam/transforms/bq/BeamBQInputMeta.java | 2 +-
.../hop/beam/transforms/bq/BeamBQOutputMeta.java | 2 +-
.../hop/beam/transforms/io/BeamInputMeta.java | 2 +-
.../hop/beam/transforms/io/BeamOutputMeta.java | 2 +-
.../hop/beam/transforms/kafka/BeamConsumeMeta.java | 2 +-
.../hop/beam/transforms/kafka/BeamProduceMeta.java | 2 +-
.../transforms/kinesis/BeamKinesisConsumeMeta.java | 2 +-
.../kinesis/BeamKinesisConsumeTransform.java | 3 +-
.../transforms/kinesis/BeamKinesisProduceMeta.java | 7 +-
.../kinesis/BeamKinesisProduceTransform.java | 2 +-
.../kinesis/KinesisRecordToHopRowFn.java | 3 +-
.../beam/transforms/pubsub/BeamPublishMeta.java | 2 +-
.../beam/transforms/pubsub/BeamSubscribeMeta.java | 2 +-
.../beam/transforms/window/BeamTimestampMeta.java | 2 +-
.../hop/beam/transforms/window/BeamWindowMeta.java | 2 +-
.../neo4j/execution/NeoExecutionInfoLocation.java | 1343 ++++++++++++++++++++
.../neo4j/execution/builder/BaseCypherBuilder.java | 62 +
.../execution/builder/CypherCreateBuilder.java | 75 ++
.../execution/builder/CypherDeleteBuilder.java | 89 ++
.../execution/builder/CypherMatchBuilder.java | 149 +++
.../execution/builder/CypherMergeBuilder.java | 83 ++
.../execution/builder/CypherQueryBuilder.java | 153 +++
.../builder/CypherRelationshipBuilder.java | 99 ++
.../neo4j/execution/builder/ICypherBuilder.java | 12 +-
.../apache/hop/neo4j/model/GraphModelEditor.java | 2 +-
.../org/apache/hop/neo4j/shared/NeoConnection.java | 11 +-
.../hop/neo4j/shared/NeoConnectionEditor.java | 74 +-
.../neo4j/shared/NeoConnectionTypeMetadata.java | 6 +-
.../execution}/messages/messages_en_US.properties | 4 +-
.../rowgenerator/RowGeneratorDialog.java | 23 +-
.../transforms/rowgenerator/RowGeneratorMeta.java | 3 +
.../pipeline/transforms/systemdata/SystemData.java | 74 +-
.../transforms/systemdata/SystemDataMeta.java | 4 +-
.../transforms/systemdata/SystemDataTypes.java | 4 +-
pom.xml | 2 +-
.../main/java/org/apache/hop/ui/core/PropsUi.java | 28 +-
.../org/apache/hop/ui/core/dialog/BaseDialog.java | 38 +-
.../org/apache/hop/ui/core/gui/GuiResource.java | 307 +++--
.../hop/ui/core/metadata/MetadataManager.java | 66 +-
.../ui/execution/ExecutionInfoLocationEditor.java | 20 -
.../main/java/org/apache/hop/ui/hopgui/HopGui.java | 8 +
.../hopgui/file/pipeline/HopGuiPipelineGraph.java | 5 +-
.../hopgui/file/workflow/HopGuiWorkflowGraph.java | 118 +-
.../perspective/execution/BaseExecutionViewer.java | 45 +-
.../execution/ExecutionPerspective.java | 78 +-
.../execution/PipelineExecutionViewer.java | 205 ++-
.../execution/WorkflowExecutionViewer.java | 113 +-
.../config/PipelineRunConfigurationEditor.java | 8 +-
.../config/WorkflowRunConfigurationEditor.java | 2 +-
.../workflow/messages/messages_en_US.properties | 2 +
.../ui/hopgui/messages/messages_en_US.properties | 2 +-
104 files changed, 3689 insertions(+), 817 deletions(-)
rename {plugins/engines/beam/src/main/java/org/apache/hop/beam/core/util => core/src/main/java/org/apache/hop/core/row}/JsonRowMeta.java (52%)
copy core/src/main/java/org/apache/hop/core/gui/IScrollBar.java => engine/src/main/java/org/apache/hop/execution/IExecutionMatcher.java (87%)
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/NeoExecutionInfoLocation.java
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/BaseCypherBuilder.java
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/CypherCreateBuilder.java
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/CypherDeleteBuilder.java
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/CypherMatchBuilder.java
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/CypherMergeBuilder.java
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/CypherQueryBuilder.java
create mode 100644 plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/CypherRelationshipBuilder.java
copy core/src/main/java/org/apache/hop/core/gui/IGuiSize.java => plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/builder/ICypherBuilder.java (83%)
copy engine/src/main/java/org/apache/hop/workflow/engines/remote/HopServerTypeMetadata.java => plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/shared/NeoConnectionTypeMetadata.java (88%)
copy {engine/src/main/resources/org/apache/hop/execution/local => plugins/tech/neo4j/src/main/resources/org/apache/hop/neo4j/execution}/messages/messages_en_US.properties (82%)