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 2021/03/25 18:13:59 UTC
[incubator-hop] branch master updated (ca94896 -> 838ae7a)
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/incubator-hop.git.
from ca94896 Merge pull request #699 from sramazzina/HOP-2330
add 838ae7a HOP-2217,HOP-2651,HOP-2656
No new revisions were added by this update.
Summary of changes:
assemblies/plugins/dist/pom.xml | 13 +
assemblies/plugins/tech/cassandra/pom.xml | 101 +++
.../tech/cassandra/src/assembly/assembly.xml | 119 +++
.../cassandra}/src/main/resources/version.xml | 0
assemblies/plugins/tech/pom.xml | 1 +
.../main/java/org/apache/hop/core/Condition.java | 27 -
core/src/main/java/org/apache/hop/core/Const.java | 32 +-
.../org/apache/hop/core/database/Database.java | 6 +-
.../hop/core/database/DatabaseMetaInformation.java | 2 +-
.../apache/hop/core/database/SqlScriptParser.java | 2 -
.../core/database/util/ILogExceptionBehaviour.java | 2 +-
.../apache/hop/core/logging/LoggingRegistry.java | 2 +-
.../java/org/apache/hop/core/logging/package.html | 2 +-
.../core/parameters/DuplicateParamException.java | 2 +-
.../hop/core/parameters/NamedParamsException.java | 2 +-
.../hop/core/parameters/UnknownParamException.java | 2 +-
.../java/org/apache/hop/core/row/IValueMeta.java | 6 +-
.../org/apache/hop/core/row/ValueDataUtil.java | 13 +-
.../apache/hop/core/row/value/ValueMetaBase.java | 22 +-
...erDistance.java => HopJaroWinklerDistance.java} | 2 +-
.../org/apache/hop/core/util/StringEvaluator.java | 2 +-
.../main/java/org/apache/hop/server/HttpUtil.java | 2 +-
.../database/messages/messages_fr_FR.properties | 8 +-
.../logging/messages/messages_en_US.properties | 20 +-
.../logging/messages/messages_fr_FR.properties | 12 +-
.../logging/messages/messages_ko_KR.properties | 4 +-
.../hop/core/messages/messages_fr_FR.properties | 6 +-
.../hop/i18n/messages/messages_pt_PT.properties | 2 +-
.../test/java/org/apache/hop/core/RowSetTest.java | 111 ++-
.../org/apache/hop/core/database/DatabaseTest.java | 2 +-
.../hop/core/database/SqlScriptParserTest.java | 18 +-
.../org/apache/hop/core/row/ValueMetaTest.java | 36 +-
.../hop/core/row/value/ValueMetaBaseTest.java | 38 +-
.../hop/core/row/value/ValueMetaTimestampTest.java | 2 +-
.../org/apache/hop/core/util/StringUtilTest.java | 2 +-
.../apache/hop/core/variables/VariablesTest.java | 2 +-
.../java/org/apache/hop/server/HttpUtilTest.java | 2 +-
.../timestamp/messages/testdates_de_DE.properties | 28 +-
.../timestamp/messages/testdates_ja.properties | 28 +-
.../timestamp/messages/testdates_zh.properties | 28 +-
docker/integration-tests/docker-compose-ci.yaml | 7 +
.../hop/core/auth/kerberos/KerberosUtil.java | 12 +-
.../java/org/apache/hop/core/gui/BasePainter.java | 2 +-
.../main/java/org/apache/hop/core/gui/SvgGc.java | 2 +-
.../java/org/apache/hop/pipeline/IPartitioner.java | 4 +-
.../java/org/apache/hop/pipeline/PipelineMeta.java | 5 +-
.../hop/pipeline/transform/BaseTransform.java | 4 +-
.../hop/pipeline/transform/BaseTransformMeta.java | 2 +-
.../hop/pipeline/transform/ITransformMeta.java | 16 +-
.../hop/pipeline/transforms/groupby/GroupBy.java | 10 +-
.../pipelineexecutor/PipelineExecutor.java | 4 +-
.../workflowexecutor/WorkflowExecutor.java | 4 +-
.../org/apache/hop/workflow/action/ActionMeta.java | 2 +-
.../org/apache/hop/workflow/action/IAction.java | 8 +-
.../workflow/actions/workflow/ActionWorkflow.java | 1 -
.../apache/hop/www/HopServerPipelineStatus.java | 1 -
.../apache/hop/www/HopServerWorkflowStatus.java | 1 -
.../pipeline/messages/messages_fr_FR.properties | 46 +-
.../transform/messages/messages_en_US.properties | 10 +-
.../transform/messages/messages_fr_FR.properties | 20 +-
.../transform/messages/messages_ja_JP.properties | 4 +-
.../messages/messages_en_US.properties | 24 +-
.../messages/messages_fr_FR.properties | 8 +-
.../messages/messages_ja_JP.properties | 10 +-
.../tableinput/messages/messages_fr_FR.properties | 2 +-
.../resource/messages/messages_fr_FR.properties | 2 +-
.../hop/server/messages/messages_fr_FR.properties | 4 +-
.../hop/shared/messages/messages_fr_FR.properties | 2 +-
.../action/messages/messages_en_US.properties | 2 +-
.../pipeline/messages/messages_fr_FR.properties | 4 +-
.../pipeline/messages/messages_ko_KR.properties | 2 +-
.../workflow/messages/messages_fr_FR.properties | 2 +-
.../workflow/messages/messages_fr_FR.properties | 16 +-
.../workflow/messages/messages_it_IT.properties | 2 +-
.../hop/www/messages/messages_fr_FR.properties | 6 +-
.../apache/hop/core/gui/WorkflowTrackerTest.java | 2 +-
.../java/org/apache/hop/pipeline/PipelineTest.java | 7 +-
.../transform/BaseTransformMetaCloningTest.java | 2 +-
.../java/org/apache/hop/server/HopServerTest.java | 4 +-
.../java/org/apache/hop/workflow/WorkflowTest.java | 2 -
.../hop/www/HopServerPipelineStatusTest.java | 2 -
.../{neo4j => cassandra}/datasets/customers.csv | 0
integration-tests/cassandra/dev-env-config.json | 19 +
.../{neo4j => cassandra}/hop-config.json | 0
.../metadata/cassandra-connection/local.json | 13 +
.../metadata/dataset/customers.json | 0
.../metadata/pipeline-run-configuration/local.json | 0
.../unit-test/cassandra-input-validation.json | 64 ++
.../metadata/workflow-run-configuration/local.json | 0
.../cassandra}/project-config.json | 0
.../cassandra-input-validation.hpl | 73 ++
.../cassandra-output-to-table.hpl | 231 +++++
.../main-cassandra-input-output.hwf} | 54 +-
.../tests/shared/validate-tests-in-folder.hpl | 532 +++++++++++
.../mongo/tests/mongo-insert/main-mongo-insert.hwf | 14 -
.../mongo/tests/mongo-update/main-mongo-update.hwf | 14 -
.../main-neo4j-cypher-returns.hwf | 14 -
.../main-neo4j-cypher-unwind.hwf | 14 -
.../neo4j/tests/neo4j-cypher/main-neo4j-cypher.hwf | 14 -
.../neo4j-graph-output/main-neo4j-graph-output.hwf | 14 -
...main-neo4j-output-create-nodes-relationship.hwf | 14 -
.../main-neo4j-output-create-nodes.hwf | 14 -
.../main-neo4j-output-dynamic-labels.hwf | 14 -
.../main-neo4j-output-merge-nodes.hwf | 14 -
.../neo4j/tests/shared/cleanup-database.hwf | 14 -
.../transforms/main-0003-field-splitter.hwf | 103 +--
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_fr_FR.properties | 74 +-
.../actions/columnsexist/ActionColumnsExist.java | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../actions/copyfiles/ActionCopyFiles.java | 2 +-
.../copyfiles/messages/messages_de_DE.properties | 10 +-
.../copyfiles/messages/messages_en_US.properties | 4 +-
.../copyfiles/messages/messages_es_AR.properties | 8 +-
.../copyfiles/messages/messages_fr_FR.properties | 8 +-
.../copyfiles/messages/messages_it_IT.properties | 8 +-
.../copyfiles/messages/messages_ja_JP.properties | 2 +-
.../copyfiles/messages/messages_ko_KR.properties | 8 +-
.../copyfiles/messages/messages_pt_BR.properties | 2 +-
.../copyfiles/messages/messages_zh_CN.properties | 6 +-
.../messages/messages_en_US.properties | 6 +-
.../messages/messages_es_AR.properties | 4 +-
.../messages/messages_fr_FR.properties | 6 +-
.../messages/messages_it_IT.properties | 6 +-
.../messages/messages_ko_KR.properties | 4 +-
.../actions/deletefiles/ActionDeleteFiles.java | 2 +-
.../deletefiles/messages/messages_fr_FR.properties | 8 +-
.../messages/messages_en_US.properties | 2 +-
.../dostounix/messages/messages_en_US.properties | 2 +-
.../dostounix/messages/messages_fr_FR.properties | 114 +--
.../dostounix/messages/messages_it_IT.properties | 2 +-
.../dostounix/messages/messages_ja_JP.properties | 2 +-
.../eval/messages/messages_fr_FR.properties | 2 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_es_AR.properties | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_it_IT.properties | 2 +-
.../ActionEvalTableContent.java | 1 -
.../messages/messages_fr_FR.properties | 4 +-
.../WorkflowActionEvalTableContentTest.java | 3 +-
.../actions/filesexist/ActionFilesExist.java | 1 -
.../filesexist/WorkflowActionFilesExistTest.java | 3 +-
.../actions/folderisempty/ActionFolderIsEmpty.java | 1 -
.../messages/messages_fr_FR.properties | 6 +-
.../apache/hop/workflow/actions/ftp/ActionFtp.java | 4 +-
.../hop/workflow/actions/ftpput/ActionFtpPut.java | 2 +-
.../ftpdelete/messages/messages_fr_FR.properties | 2 +-
.../ftpput/messages/messages_fr_FR.properties | 6 +-
.../sftp/messages/messages_en_US.properties | 2 +-
.../sftp/messages/messages_es_AR.properties | 2 +-
.../sftp/messages/messages_fr_FR.properties | 2 +-
.../sftp/messages/messages_it_IT.properties | 2 +-
.../sftp/messages/messages_ko_KR.properties | 2 +-
.../sftpput/messages/messages_en_US.properties | 4 +-
.../sftpput/messages/messages_es_AR.properties | 2 +-
.../sftpput/messages/messages_fr_FR.properties | 6 +-
.../sftpput/messages/messages_it_IT.properties | 4 +-
.../hop/workflow/actions/getpop/ActionGetPOP.java | 2 +-
.../actions/getpop/ActionGetPOPDialog.java | 4 +-
.../actions/getpop/MailConnectionTest.java | 8 +-
.../actions/getpop/WorkflowEntryGetPOPTest.java | 14 +-
.../messages/messages_en_US.properties | 6 +-
.../messages/messages_es_AR.properties | 6 +-
.../messages/messages_fr_FR.properties | 40 +-
.../messages/messages_it_IT.properties | 6 +-
.../messages/messages_ja_JP.properties | 2 +-
.../messages/messages_ko_KR.properties | 6 +-
.../actions/movefiles/ActionMoveFiles.java | 2 +-
.../movefiles/messages/messages_en_US.properties | 8 +-
.../movefiles/messages/messages_es_AR.properties | 8 +-
.../movefiles/messages/messages_fr_FR.properties | 14 +-
.../movefiles/messages/messages_it_IT.properties | 8 +-
.../movefiles/messages/messages_ja_JP.properties | 2 +-
.../movefiles/messages/messages_ko_KR.properties | 8 +-
.../messages/messages_fr_FR.properties | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../pgpdecryptfiles/ActionPGPDecryptFiles.java | 2 +-
.../pgpencryptfiles/ActionPGPEncryptFiles.java | 2 +-
.../messages/messages_en_US.properties | 8 +-
.../messages/messages_fr_FR.properties | 214 ++---
.../messages/messages_it_IT.properties | 4 +-
.../messages/messages_ja_JP.properties | 6 +-
.../messages/messages_zh_CN.properties | 2 +-
.../messages/messages_en_US.properties | 8 +-
.../messages/messages_fr_FR.properties | 256 +++---
.../messages/messages_it_IT.properties | 2 +-
.../messages/messages_ja_JP.properties | 6 +-
.../messages/messages_zh_CN.properties | 2 +-
.../actions/setvariables/ActionSetVariables.java | 2 +-
.../hop/workflow/actions/shell/ActionShell.java | 2 +-
.../actions/shell/WorkflowActionShellTest.java | 2 +-
.../actions/simpleeval/ActionSimpleEval.java | 2 +-
.../tableexists/messages/messages_fr_FR.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../hop/workflow/actions/unzip/ActionUnZip.java | 2 +-
.../unzip/messages/messages_fr_FR.properties | 4 +-
.../actions/waitforsql/ActionWaitForSql.java | 2 +-
.../waitforsql/messages/messages_fr_FR.properties | 4 +-
.../writetolog/messages/messages_fr_FR.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../messages/messages_it_IT.properties | 2 +-
.../messages/messages_en_US.properties | 4 +-
.../messages/messages_es_AR.properties | 2 +-
.../messages/messages_fr_FR.properties | 6 +-
.../messages/messages_it_IT.properties | 6 +-
.../messages/messages_ja_JP.properties | 2 +-
.../messages/messages_ko_KR.properties | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_it_IT.properties | 2 +-
.../xml/xslt/messages/messages_de_DE.properties | 6 +-
.../xml/xslt/messages/messages_en_US.properties | 14 +-
.../xml/xslt/messages/messages_fr_FR.properties | 8 +-
.../xml/xslt/messages/messages_it_IT.properties | 6 +-
.../xml/xslt/messages/messages_ja_JP.properties | 2 +-
.../xml/xslt/messages/messages_ko_KR.properties | 6 +-
.../zipfile/messages/messages_en_US.properties | 2 +-
.../zipfile/messages/messages_es_AR.properties | 2 +-
.../zipfile/messages/messages_fr_FR.properties | 2 +-
.../zipfile/messages/messages_it_IT.properties | 2 +-
.../zipfile/messages/messages_ko_KR.properties | 2 +-
.../greenplum/GreenplumValueMetaBaseTest.java | 4 +-
.../hypersonic/HypersonicDatabaseMetaTest.java | 6 +-
.../databases/mysql/MySqlValueMetaBaseTest.java | 1 -
.../core/row/value/NettezaValueMetaBaseTest.java | 2 +-
.../hop/databases/sqlbase/GuptaDatabaseMeta.java | 1 -
.../teradata/TeradataValueMetaBaseTest.java | 2 +-
.../vertica/Vertica5DatabaseMetaTest.java | 1 -
.../main/samples/beam/pipelines/switch-case.hpl | 47 -
.../apache/hop/projects/config/ProjectsConfig.java | 20 +
.../config/ProjectsConfigOptionPlugin.java | 40 +
.../apache/hop/projects/gui/ProjectsGuiPlugin.java | 10 +-
.../project/ManageProjectsOptionPlugin.java | 373 ++++----
.../org/apache/hop/projects/project/Project.java | 12 +-
.../apache/hop/projects/project/ProjectConfig.java | 3 -
.../xp/HopImportCreateProjectIfNotExists.java | 46 +-
.../eventhubs/listen/AzureListenerMeta.java | 2 +-
.../eventhubs/write/AzureWriterMeta.java | 2 +-
plugins/tech/cassandra/pom.xml | 126 +++
.../src/main/doc/cassandra-connection.adoc | 64 ++
.../cassandra/src/main/doc/cassandra-exec-cql.adoc | 41 +
.../cassandra/src/main/doc/cassandra-input.adoc | 45 +
.../cassandra/src/main/doc/cassandra-output.adoc | 75 ++
.../hop/databases/cassandra/ConnectionFactory.java | 45 +
.../cassandra/datastax/DriverConnection.java | 243 +++++
.../cassandra/datastax/DriverCqlRowHandler.java | 293 ++++++
.../cassandra/datastax/DriverKeyspace.java | 167 ++++
.../cassandra/datastax/TableMetaData.java | 168 ++++
.../cassandra/metadata/CassandraConnection.java | 337 +++++++
.../metadata/CassandraConnectionEditor.java | 226 +++++
.../hop/databases/cassandra/spi/Connection.java | 113 +++
.../hop/databases/cassandra/spi/CqlRowHandler.java | 98 ++
.../databases/cassandra/spi/ITableMetaData.java | 128 +++
.../hop/databases/cassandra/spi/Keyspace.java | 160 ++++
.../cassandra/util/CFMetaDataElements.java | 58 ++
.../databases/cassandra/util/CassandraUtils.java | 858 ++++++++++++++++++
.../hop/databases/cassandra/util/Compression.java | 33 +
.../hop/databases/cassandra/util/CqlFunctions.java | 76 ++
.../hop/databases/cassandra/util/CqlUtils.java | 296 +++++++
.../hop/databases/cassandra/util/Partitioners.java | 60 ++
.../hop/databases/cassandra/util/Selector.java | 145 +++
.../transforms/cassandrainput/CassandraInput.java | 294 ++++++
.../cassandrainput/CassandraInputData.java | 37 +
.../cassandrainput/CassandraInputDialog.java | 527 +++++++++++
.../cassandrainput/CassandraInputMeta.java | 503 +++++++++++
.../cassandraoutput/CassandraOutput.java | 589 +++++++++++++
.../cassandraoutput/CassandraOutputData.java | 36 +
.../cassandraoutput/CassandraOutputDialog.java | 981 +++++++++++++++++++++
.../cassandraoutput/CassandraOutputMeta.java | 506 +++++++++++
.../cassandrasstableoutput/SSTableOutput.java | 268 ++++++
.../cassandrasstableoutput/SSTableOutputData.java | 47 +
.../SSTableOutputDialog.java | 524 +++++++++++
.../cassandrasstableoutput/SSTableOutputMeta.java | 303 +++++++
.../writer/AbstractSSTableWriter.java | 110 +++
.../writer/Cql3SSTableWriter.java | 112 +++
.../writer/SSTableWriterBuilder.java | 122 +++
.../hop/workflow/actions/execcql/ExecCql.java | 249 ++++++
.../workflow/actions/execcql/ExecCqlDialog.java | 235 +++++
.../cassandra/src/main/resources/Cassandra.svg | 55 ++
.../src/main/resources/Cassandra_logo.svg | 269 ++++++
.../cassandra/src/main/resources/Cassandrain.svg | 48 +
.../cassandra/src/main/resources/Cassandraout.svg | 53 ++
.../messages/messages_en_US.properties | 88 ++
.../messages/messages_en_US.properties | 133 +++
.../messages/messages_en_US.properties | 53 ++
.../writer/messages/messages_en_US.properties | 7 +-
.../execcql}/messages/messages_en_US.properties | 20 +-
.../cassandra/datastax/DriverConnectionTest.java | 144 +++
.../datastax/DriverCqlRowHandlerTest.java | 294 ++++++
.../cassandra/util/CassandraUtilsTest.java | 187 ++++
.../database/cassandra/util/CqlFunctionsTest.java | 69 ++
.../hop/database/cassandra/util/CqlUtilsTest.java | 465 ++++++++++
.../database/cassandra/util/PartitionersTest.java | 92 ++
.../hop/database/cassandra/util/SelectorTest.java | 112 +++
.../CassandraInputMetaInjectionTest.java | 38 +
.../CassandraOutputMetaInjectionTest.java | 52 ++
.../cassandraoutput/CassandraOutputMetaTest.java | 68 ++
.../cassandraoutput/CassandraOutputTest.java | 176 ++++
.../SSTableOutputMetaInjectionTest.java | 40 +
.../SSTableOutputMetaTest.java | 125 +++
.../cassandrasstableoutput/SSTableOutputTest.java | 75 ++
.../writer/AbstractSSTableWriterTest.java | 76 ++
.../writer/Cql3SsTableWriterTest.java | 163 ++++
.../writer/SSTableWriterBuilderTest.java | 116 +++
.../transforms/mock/TransformMockHelper.java | 144 +++
.../messages/messages_en_US.properties | 2 +-
.../neo4j/transforms/loginfo/GetLoggingInfo.java | 22 -
.../transforms/loginfo/GetLoggingInfoData.java | 22 -
.../transforms/loginfo/GetLoggingInfoDialog.java | 22 -
.../transforms/loginfo/GetLoggingInfoMeta.java | 22 -
.../GetLoggingInfoMetaInjectionTypeConverter.java | 22 -
.../transforms/loginfo/GetLoggingInfoTypes.java | 22 -
.../hop/neo4j/transforms/loginfo/Management.java | 22 -
.../hop/neo4j/transforms/output/Neo4JOutput.java | 2 -
.../neo4j/transforms/output/Neo4JOutputDialog.java | 26 +-
.../cypher/messages/messages_en_US.properties | 2 +-
plugins/tech/pom.xml | 1 +
.../addsequence/messages/messages_fr_FR.properties | 2 +-
.../append/messages/messages_fr_FR.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../calculator/messages/messages_fr_FR.properties | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../transforms/coalesce/CoalesceDialog.java | 2 +-
.../pipeline/transforms/coalesce/CoalesceMeta.java | 2 +-
.../transforms/coalesce/CoalesceTransform.java | 6 +-
.../messages/messages_fr_FR.properties | 4 +-
.../combinationlookup/CombinationLookupDialog.java | 1 -
.../messages/messages_fr_FR.properties | 6 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../cubeoutput/messages/messages_en_US.properties | 2 +-
.../cubeoutput/messages/messages_es_AR.properties | 2 +-
.../cubeoutput/messages/messages_it_IT.properties | 2 +-
.../cubeoutput/messages/messages_ko_KR.properties | 2 +-
.../transforms/databasejoin/DatabaseJoin.java | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../databaselookup/DatabaseLookupMeta.java | 2 +-
.../messages/messages_fr_FR.properties | 6 +-
.../databaselookup/DatabaseLookupUTest.java | 3 +-
.../dbproc/messages/messages_fr_FR.properties | 8 +-
.../hop/pipeline/transforms/delay/DelayMeta.java | 6 +-
.../delay/messages/messages_fr_FR.properties | 4 +-
.../delete/messages/messages_fr_FR.properties | 8 +-
.../transforms/denormaliser/Denormaliser.java | 6 +-
.../denormaliser/DenormaliserAggregationsTest.java | 11 +-
.../messages/messages_fr_FR.properties | 6 +-
.../dimensionlookup/DimensionLookup.java | 8 +-
.../messages/messages_es_AR.properties | 2 +-
.../messages/messages_fr_FR.properties | 16 +-
.../dimensionlookup/DimensionCacheTest.java | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../pipeline/transforms/excelinput/ExcelInput.java | 2 +-
.../transforms/excelinput/poi/PoiWorkbook.java | 2 +-
.../excelwriter/ExcelWriterTransform.java | 2 +-
.../excelwriter/messages/messages_en_US.properties | 4 +-
.../excelwriter/messages/messages_fr_FR.properties | 4 +-
.../excelwriter/messages/messages_it_IT.properties | 2 +-
.../excelwriter/messages/messages_ja_JP.properties | 2 +-
.../execsqlrow/messages/messages_fr_FR.properties | 2 +-
.../fieldsplitter/FieldSplitterMetaTest.java | 2 +-
.../fileexists/messages/messages_fr_FR.properties | 4 +-
.../filelocked/messages/messages_fr_FR.properties | 4 +-
.../pipeline/transforms/filterrows/FilterRows.java | 1 -
.../filterrows/messages/messages_es_AR.properties | 2 +-
.../filterrows/messages/messages_es_ES.properties | 2 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_fr_FR.properties | 6 +-
.../messages/messages_it_IT.properties | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_fr_FR.properties | 4 +-
.../http/messages/messages_fr_FR.properties | 10 +-
.../hop/pipeline/transforms/httppost/HttpPost.java | 1 -
.../httppost/messages/messages_fr_FR.properties | 12 +-
.../ifnull/messages/messages_fr_FR.properties | 2 +-
.../transforms/insertupdate/InsertUpdateMeta.java | 1 -
.../messages/messages_fr_FR.properties | 8 +-
.../insertupdate/InsertUpdateMetaTest.java | 1 -
.../transforms/insertupdate/PDI3499Test.java | 2 -
.../UserDefinedJavaClassMetaTest.java | 2 +-
.../javascript/ScriptValuesAddedFunctions.java | 2 +-
.../javascript/messages/messages_en_US.properties | 2 +-
.../javascript/messages/messages_fr_FR.properties | 6 +-
.../javascript/messages/messages_it_IT.properties | 2 +-
.../javascript/messages/messages_ko_KR.properties | 2 +-
.../pipeline/transforms/jsoninput/JsonInput.java | 4 +-
.../transforms/jsoninput/JsonInputMeta.java | 2 +-
.../transforms/jsonoutput/JsonOutputMeta.java | 2 +-
.../jsonoutputenhanced/BaseFileOutputMeta.java | 6 +-
.../jsoninput/messages/messages_en_US.properties | 6 +-
.../jsoninput/messages/messages_es_AR.properties | 2 +-
.../jsoninput/messages/messages_fr_FR.properties | 2 +-
.../jsoninput/messages/messages_it_IT.properties | 4 +-
.../jsonoutput/messages/messages_en_US.properties | 6 +-
.../jsonoutput/messages/messages_es_AR.properties | 2 +-
.../jsonoutput/messages/messages_fr_FR.properties | 4 +-
.../jsonoutput/messages/messages_it_IT.properties | 4 +-
.../jsonoutput/messages/messages_ja_JP.properties | 4 +-
.../jsonoutput/messages/messages_zh_CN.properties | 6 +-
.../messages/messages_en_US.properties | 16 +-
.../messages/messages_it_IT.properties | 4 +-
.../transforms/jsoninput/JsonInputMetaTest.java | 2 +-
.../transforms/jsoninput/JsonInputTest.java | 6 +-
.../transforms/jsonoutput/JsonOutputTest.java | 1 -
.../kafka/consumer/KafkaConsumerInput.java | 2 +-
.../consumer/messages/messages_en_US.properties | 6 +-
.../ldapinput/messages/messages_fr_FR.properties | 6 +-
.../messages/messages_fr_FR.properties | 2 +-
.../apache/hop/pipeline/transforms/mail/Mail.java | 2 +-
.../mail/messages/messages_fr_FR.properties | 2 +-
.../pipeline/transforms/mailinput/MailInput.java | 2 +-
.../transforms/mailinput/MailInputDialog.java | 6 +-
.../transforms/mailinput/MailInputTest.java | 6 +-
.../transforms/mailinput/ParseMailInputTest.java | 5 +-
.../messages/messages_en_US.properties | 6 +-
.../messages/messages_es_AR.properties | 6 +-
.../messages/messages_fr_FR.properties | 8 +-
.../messages/messages_it_IT.properties | 6 +-
.../messages/messages_zh_CN.properties | 4 +-
.../input/messages/messages_fr_FR.properties | 2 +-
.../mapping/messages/messages_en_US.properties | 2 +-
.../mapping/messages/messages_fr_FR.properties | 82 +-
.../mapping/messages/messages_ja_JP.properties | 4 +-
.../mapping/messages/messages_zh_CN.properties | 2 +-
.../output/messages/messages_fr_FR.properties | 8 +-
.../transforms/memgroupby/MemoryGroupBy.java | 4 +-
.../MemoryGroupByAggregationNullsTest.java | 3 +-
.../mergejoin/messages/messages_fr_FR.properties | 4 +-
.../pipeline/transforms/mergerows/MergeRows.java | 6 +-
.../transforms/mergerows/MergeRowsDialog.java | 1 -
.../mergerows/messages/messages_fr_FR.properties | 4 +-
.../pipeline/transforms/metainject/MetaInject.java | 3 +-
.../metainject/messages/messages_fr_FR.properties | 32 +-
.../metainject/messages/messages_ja_JP.properties | 4 +-
.../metainject/messages/messages_zh_CN.properties | 28 +-
.../messages/messages_en_US.properties | 6 +-
.../messages/messages_ja_JP.properties | 6 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_it_IT.properties | 2 +-
.../mongodb/src/main/doc/mongodbinput.adoc | 6 +-
.../messages/messages_en_US.properties | 2 +-
.../apache/hop/mongo/wrapper/MongoFieldTest.java | 1 -
.../transforms/mqtt/key/PrivateKeyReader.java | 6 +-
.../transforms/mqtt/publisher/MQTTPublisher.java | 4 +-
.../mqtt/publisher/MQTTPublisherDialog.java | 22 +-
.../mqtt/publisher/MQTTPublisherMeta.java | 4 +-
.../mqtt/subscriber/MQTTSubscriberDialog.java | 22 +-
.../mqtt/subscriber/MQTTSubscriberMeta.java | 4 +-
.../publisher/messages/messages_en_US.properties | 12 +-
.../subscriber/messages/messages_en_US.properties | 12 +-
.../messages/messages_fr_FR.properties | 16 +-
.../transforms/pgbulkloader/PGBulkLoaderTest.java | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_fr_FR.properties | 4 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_es_AR.properties | 2 +-
.../messages/messages_fr_FR.properties | 6 +-
.../messages/messages_it_IT.properties | 2 +-
.../messages/messages_ko_KR.properties | 2 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_es_AR.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../messages/messages_it_IT.properties | 2 +-
.../messages/messages_ko_KR.properties | 2 +-
.../regexeval/messages/messages_fr_FR.properties | 4 +-
.../replacestring/ReplaceStringMeta.java | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../replacestring/ReplaceStringTest.java | 1 -
.../rest/messages/messages_fr_FR.properties | 12 +-
.../transforms/salesforce/SalesforceTransform.java | 2 +-
.../salesforceupsert/SalesforceUpsert.java | 4 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_fr_FR.properties | 12 +-
.../messages/messages_it_IT.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../salesforceinsert/SalesforceInsertTest.java | 2 +-
.../salesforceupsert/SalesforceUpsertTest.java | 2 +-
.../samplerows/messages/messages_fr_FR.properties | 4 +-
.../sasinput/messages/messages_en_US.properties | 20 +-
.../sasinput/messages/messages_ja_JP.properties | 10 +-
.../transforms/selectvalues/SelectValuesMeta.java | 2 +-
.../SelectValuesMetaInjectionTest.java | 2 +-
.../transforms/selectvalues/SelectValuesTest.java | 2 -
.../messages/messages_fr_FR.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../setvariable/messages/messages_en_US.properties | 4 +-
.../setvariable/messages/messages_it_IT.properties | 4 +-
.../setvariable/messages/messages_ko_KR.properties | 2 +-
.../hop/pipeline/transforms/sort/SortRowsMeta.java | 2 +-
.../transforms/sortedmerge/SortedMerge.java | 1 -
.../splitfieldtorows/SplitFieldToRows.java | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../sql/messages/messages_fr_FR.properties | 2 +-
.../messages/messages_en_US.properties | 4 +-
.../messages/messages_fr_FR.properties | 8 +-
.../messages/messages_it_IT.properties | 2 +-
.../messages/messages_ja_JP.properties | 2 +-
.../messages/messages_ko_KR.properties | 2 +-
.../streamlookup/StreamLookupDialog.java | 4 +-
.../transforms/streamlookup/StreamLookupMeta.java | 1 -
.../streamlookup/StreamLookupMetaTest.java | 1 -
.../streamschemamerge/StreamSchemaMeta.java | 6 +-
.../streamschemamerge/TestUtilities.java | 2 +-
.../stringcut/messages/messages_fr_FR.properties | 4 +-
.../messages/messages_fr_FR.properties | 4 +-
.../transforms/switchcase/SwitchCaseMeta.java | 1 -
.../switchcase/messages/messages_es_AR.properties | 2 +-
.../switchcase/messages/messages_es_ES.properties | 2 +-
.../transforms/switchcase/SwitchCaseTest.java | 4 +-
.../SynchronizeAfterMerge.java | 4 +-
.../messages/messages_en_US.properties | 2 +-
.../messages/messages_fr_FR.properties | 8 +-
.../messages/messages_it_IT.properties | 2 +-
.../systemdata/messages/messages_fr_FR.properties | 10 +-
.../tableexists/messages/messages_fr_FR.properties | 4 +-
.../transforms/tableoutput/TableOutput.java | 6 +-
.../transforms/tableoutput/TableOutputDialog.java | 2 +-
.../tableoutput/messages/messages_fr_FR.properties | 12 +-
.../hop/pipeline/transforms/csvinput/CsvInput.java | 8 +-
.../transforms/fileinput/TextFileInput.java | 2 +-
.../transforms/fileinput/TextFileInputDialog.java | 3 -
.../fileinput/text/TextFileInputDialog.java | 3 -
.../fileinput/text/TextFileInputReader.java | 2 +-
.../transforms/textfileoutput/TextFileOutput.java | 2 +-
.../csvinput/messages/messages_fr_FR.properties | 2 +-
.../fileinput/messages/messages_fr_FR.properties | 12 +-
.../text/messages/messages_fr_FR.properties | 12 +-
.../messages/messages_en_US.properties | 4 +-
.../messages/messages_fr_FR.properties | 2 +-
.../messages/messages_it_IT.properties | 118 ++-
.../messages/messages_ko_KR.properties | 2 +-
.../pipeline/transforms/csvinput/CsvInputTest.java | 1 -
.../transforms/fileinput/text/PDI_2875_Test.java | 4 +-
.../transforms/textfileinput/PDI_2875_Test.java | 4 +-
.../textfileinput/TextFileInputTest.java | 2 -
.../textfileoutput/TextFileOutputTest.java | 5 -
.../tokenreplacement/TokenReplacement.java | 2 +-
.../messages/messages_en_US.properties | 6 +-
.../pipeline/transforms/update/UpdateDialog.java | 2 +-
.../pipeline/transforms/update/PDI_11152_Test.java | 2 +-
.../messages/messages_fr_FR.properties | 4 +-
.../transforms/webservices/WebService.java | 3 +-
.../webservices/messages/messages_fr_FR.properties | 2 +-
.../transforms/xml/getxmldata/GetXmlData.java | 2 +-
.../xml/getxmldata/GetXmlDataDialog.java | 2 +-
.../transforms/xml/xmloutput/XmlField.java | 2 +-
.../transforms/xml/xmloutput/XmlOutput.java | 2 +-
.../transforms/xml/xmloutput/XmlOutputDialog.java | 2 +-
.../transforms/xml/xmloutput/XmlOutputMeta.java | 2 +-
.../xml/xsdvalidator/XsdValidatorMeta.java | 2 +-
.../getxmldata/messages/messages_en_US.properties | 4 +-
.../getxmldata/messages/messages_es_AR.properties | 4 +-
.../getxmldata/messages/messages_fr_FR.properties | 10 +-
.../getxmldata/messages/messages_it_IT.properties | 2 +-
.../getxmldata/messages/messages_ko_KR.properties | 2 +-
.../xmloutput/messages/messages_en_US.properties | 2 +-
.../xmloutput/messages/messages_fr_FR.properties | 2 +-
.../xmloutput/messages/messages_it_IT.properties | 2 +-
.../xmloutput/messages/messages_ko_KR.properties | 2 +-
.../messages/messages_fr_FR.properties | 2 +-
.../xml/xslt/messages/messages_en_US.properties | 6 +-
.../xml/xslt/messages/messages_fr_FR.properties | 8 +-
.../xml/xslt/messages/messages_ko_KR.properties | 2 +-
.../transforms/xml/xmloutput/XmlOutputTest.java | 2 +-
.../hop/pipeline/transforms/xml/xmloutput/one.txt | 2 +-
.../hop/pipeline/transforms/xml/xmloutput/two.txt | 2 +-
.../yamlinput/messages/messages_en_US.properties | 2 +-
.../yamlinput/messages/messages_fr_FR.properties | 6 +-
.../yamlinput/messages/messages_it_IT.properties | 2 +-
plugins/vfs/s3/pom.xml | 2 +-
.../org/apache/hop/vfs/s3/s3/vfs/S3FileName.java | 2 +-
.../s3/s3common/messages/messages_en_US.properties | 2 +-
.../apache/hop/vfs/s3/vfs/S3FileObjectTest.java | 2 +-
.../resources/org/apache/hop/ui/hopgui/canvas.js | 5 +-
.../main/java/org/apache/hop/ui/core/PropsUi.java | 2 +-
.../apache/hop/ui/core/widget/ConditionEditor.java | 2 +-
.../hop/ui/core/widget/ControlSpaceKeyAdapter.java | 2 +-
.../org/apache/hop/ui/core/widget/TableView.java | 6 +-
.../hopgui/file/pipeline/HopGuiPipelineGraph.java | 4 +-
.../hop/ui/pipeline/dialog/PipelineDialog.java | 2 +-
.../dialog/messages/messages_fr_FR.properties | 12 +-
.../core/widget/messages/messages_fr_FR.properties | 2 +-
.../dialog/messages/messages_fr_FR.properties | 18 +-
.../workflow/messages/messages_en_US.properties | 4 +-
.../workflow/messages/messages_fr_FR.properties | 90 +-
.../workflow/messages/messages_ko_KR.properties | 4 +-
.../workflow/messages/messages_pt_BR.properties | 26 +-
.../workflow/messages/messages_pt_PT.properties | 26 +-
.../ui/hopgui/messages/messages_en_US.properties | 4 +-
.../ui/hopgui/messages/messages_fr_FR.properties | 92 +-
.../ui/hopgui/messages/messages_ko_KR.properties | 4 +-
.../ui/hopgui/messages/messages_pt_BR.properties | 26 +-
.../ui/hopgui/messages/messages_pt_PT.properties | 26 +-
.../partition/messages/messages_fr_FR.properties | 2 +-
.../dialog/messages/messages_fr_FR.properties | 22 +-
.../pipeline/messages/messages_fr_FR.properties | 4 +-
.../pipeline/messages/messages_ko_KR.properties | 2 +-
.../dialog/messages/messages_fr_FR.properties | 8 +-
599 files changed, 15729 insertions(+), 2523 deletions(-)
create mode 100644 assemblies/plugins/tech/cassandra/pom.xml
create mode 100644 assemblies/plugins/tech/cassandra/src/assembly/assembly.xml
copy assemblies/plugins/{vfs/s3 => tech/cassandra}/src/main/resources/version.xml (100%)
rename core/src/main/java/org/apache/hop/core/util/{PentahoJaroWinklerDistance.java => HopJaroWinklerDistance.java} (99%)
copy integration-tests/{neo4j => cassandra}/datasets/customers.csv (100%)
create mode 100644 integration-tests/cassandra/dev-env-config.json
copy integration-tests/{neo4j => cassandra}/hop-config.json (100%)
create mode 100644 integration-tests/cassandra/metadata/cassandra-connection/local.json
copy integration-tests/{neo4j => cassandra}/metadata/dataset/customers.json (100%)
copy integration-tests/{xml => cassandra}/metadata/pipeline-run-configuration/local.json (100%)
create mode 100644 integration-tests/cassandra/metadata/unit-test/cassandra-input-validation.json
copy {plugins/transforms/mapping/src/main/resources/it => integration-tests/cassandra}/metadata/workflow-run-configuration/local.json (100%)
copy {plugins/engines/beam/src/main/samples => integration-tests/cassandra}/project-config.json (100%)
create mode 100644 integration-tests/cassandra/tests/cassandra-input-output/cassandra-input-validation.hpl
create mode 100644 integration-tests/cassandra/tests/cassandra-input-output/cassandra-output-to-table.hpl
copy integration-tests/{mongo/tests/mongo-insert/main-mongo-insert.hwf => cassandra/tests/cassandra-input-output/main-cassandra-input-output.hwf} (69%)
create mode 100644 integration-tests/cassandra/tests/shared/validate-tests-in-folder.hpl
create mode 100644 plugins/tech/cassandra/pom.xml
create mode 100644 plugins/tech/cassandra/src/main/doc/cassandra-connection.adoc
create mode 100644 plugins/tech/cassandra/src/main/doc/cassandra-exec-cql.adoc
create mode 100644 plugins/tech/cassandra/src/main/doc/cassandra-input.adoc
create mode 100644 plugins/tech/cassandra/src/main/doc/cassandra-output.adoc
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/ConnectionFactory.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/datastax/DriverConnection.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/datastax/DriverCqlRowHandler.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/datastax/DriverKeyspace.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/datastax/TableMetaData.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/metadata/CassandraConnection.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/metadata/CassandraConnectionEditor.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/spi/Connection.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/spi/CqlRowHandler.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/spi/ITableMetaData.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/spi/Keyspace.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/util/CFMetaDataElements.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/util/CassandraUtils.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/util/Compression.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/util/CqlFunctions.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/util/CqlUtils.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/util/Partitioners.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/util/Selector.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrainput/CassandraInput.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrainput/CassandraInputData.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrainput/CassandraInputDialog.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrainput/CassandraInputMeta.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandraoutput/CassandraOutput.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandraoutput/CassandraOutputData.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandraoutput/CassandraOutputDialog.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandraoutput/CassandraOutputMeta.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/SSTableOutput.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/SSTableOutputData.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/SSTableOutputDialog.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/SSTableOutputMeta.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/writer/AbstractSSTableWriter.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/writer/Cql3SSTableWriter.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/writer/SSTableWriterBuilder.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/workflow/actions/execcql/ExecCql.java
create mode 100644 plugins/tech/cassandra/src/main/java/org/apache/hop/workflow/actions/execcql/ExecCqlDialog.java
create mode 100644 plugins/tech/cassandra/src/main/resources/Cassandra.svg
create mode 100644 plugins/tech/cassandra/src/main/resources/Cassandra_logo.svg
create mode 100644 plugins/tech/cassandra/src/main/resources/Cassandrain.svg
create mode 100644 plugins/tech/cassandra/src/main/resources/Cassandraout.svg
create mode 100644 plugins/tech/cassandra/src/main/resources/org/apache/hop/pipeline/transforms/cassandrainput/messages/messages_en_US.properties
create mode 100644 plugins/tech/cassandra/src/main/resources/org/apache/hop/pipeline/transforms/cassandraoutput/messages/messages_en_US.properties
create mode 100644 plugins/tech/cassandra/src/main/resources/org/apache/hop/pipeline/transforms/cassandrasstableoutput/messages/messages_en_US.properties
copy engine/src/main/resources/org/apache/hop/shared/messages/messages_fr_FR.properties => plugins/tech/cassandra/src/main/resources/org/apache/hop/pipeline/transforms/cassandrasstableoutput/writer/messages/messages_en_US.properties (75%)
copy plugins/{vfs/s3/src/main/resources/org/apache/hop/vfs/s3/s3common => tech/cassandra/src/main/resources/org/apache/hop/workflow/actions/execcql}/messages/messages_en_US.properties (58%)
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/database/cassandra/datastax/DriverConnectionTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/database/cassandra/datastax/DriverCqlRowHandlerTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/database/cassandra/util/CassandraUtilsTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/database/cassandra/util/CqlFunctionsTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/database/cassandra/util/CqlUtilsTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/database/cassandra/util/PartitionersTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/database/cassandra/util/SelectorTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandrainput/CassandraInputMetaInjectionTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandraoutput/CassandraOutputMetaInjectionTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandraoutput/CassandraOutputMetaTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandraoutput/CassandraOutputTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/SSTableOutputMetaInjectionTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/SSTableOutputMetaTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/SSTableOutputTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/writer/AbstractSSTableWriterTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/writer/Cql3SsTableWriterTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/cassandrasstableoutput/writer/SSTableWriterBuilderTest.java
create mode 100644 plugins/tech/cassandra/src/test/java/org/apache/hop/pipeline/transforms/mock/TransformMockHelper.java