This is an automated email from the ASF dual-hosted git repository.
markap14 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 91dd59d NIFI-7312: Enable search in variable registry of root process
group
new 5c2bfcf NIFI-7369 Adding decimal support for record handling in order
to avoid missing precision when reading in records
new e0dd6d4 NIFI-7369: Consider DECIMAL type as a numeric type when using
a CHOICE type in QueryRecord
The 2 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:
.../nifi/serialization/record/RecordFieldType.java | 19 ++-
.../serialization/record/ResultSetRecordSet.java | 29 +++-
.../{MapDataType.java => DecimalDataType.java} | 39 ++---
.../serialization/record/util/DataTypeUtils.java | 94 +++++++++++-
.../record/ResultSetRecordSetTest.java | 165 +++++++++++++++++++++
.../serialization/record/TestDataTypeUtils.java | 136 +++++++++++++++++
.../elasticsearch/PutElasticsearchHttpRecord.java | 3 +
.../TestPutElasticsearchHttpRecord.java | 4 +-
.../java/org/apache/nifi/avro/AvroTypeUtil.java | 11 +-
.../schema/access/InferenceSchemaStrategy.java | 4 +
.../org/apache/nifi/avro/TestAvroTypeUtil.java | 42 +++++-
.../schema/access/InferenceSchemaStrategyTest.java | 143 ++++++++++++++++++
.../schema/validation/StandardSchemaValidator.java | 10 +-
.../validation/TestStandardSchemaValidator.java | 13 +-
.../apache/hadoop/hive/ql/io/orc/NiFiOrcUtils.java | 6 +
.../org/apache/nifi/util/orc/TestNiFiOrcUtils.java | 3 +
.../apache/hadoop/hive/ql/io/orc/NiFiOrcUtils.java | 15 ++
.../org/apache/nifi/processors/orc/PutORCTest.java | 15 +-
.../org/apache/nifi/util/orc/TestNiFiOrcUtils.java | 20 +++
.../nifi/controller/kudu/KuduLookupService.java | 6 +-
.../processors/kudu/AbstractKuduProcessor.java | 38 ++++-
.../org/apache/nifi/processors/kudu/PutKudu.java | 9 +-
.../apache/nifi/processors/kudu/MockPutKudu.java | 15 +-
.../apache/nifi/processors/kudu/TestPutKudu.java | 30 +++-
.../reporting/prometheus/PrometheusRecordSink.java | 1 +
.../prometheus/TestPrometheusRecordSink.java | 16 +-
.../nifi/rules/handlers/RecordSinkHandler.java | 5 +
.../nifi/rules/handlers/TestRecordSinkHandler.java | 4 +
.../reporting/AbstractSiteToSiteReportingTask.java | 1 +
.../org/apache/nifi/processors/solr/SolrUtils.java | 5 +-
.../apache/nifi/processors/solr/SolrUtilsTest.java | 62 ++++++++
.../org/apache/nifi/queryrecord/FlowFileTable.java | 4 +
.../nifi-record-serialization-services/pom.xml | 1 +
.../apache/nifi/csv/AbstractCSVRecordReader.java | 1 +
.../org/apache/nifi/csv/CSVSchemaInference.java | 5 +
.../java/org/apache/nifi/csv/WriteCSVResult.java | 1 +
.../org/apache/nifi/json/JsonSchemaInference.java | 8 +
.../apache/nifi/json/JsonTreeRowRecordReader.java | 1 +
.../java/org/apache/nifi/json/WriteJsonResult.java | 3 +
.../java/org/apache/nifi/xml/WriteXMLResult.java | 1 +
.../java/org/apache/nifi/xml/XMLRecordReader.java | 2 +
.../nifi/xml/inference/XmlSchemaInference.java | 5 +
.../avro/TestAvroReaderWithEmbeddedSchema.java | 4 +-
.../org/apache/nifi/avro/TestWriteAvroResult.java | 57 ++++++-
.../org/apache/nifi/csv/TestCSVRecordReader.java | 22 +++
.../org/apache/nifi/csv/TestWriteCSVResult.java | 4 +-
.../apache/nifi/json/TestJsonSchemaInference.java | 2 +-
.../nifi/json/TestJsonTreeRowRecordReader.java | 16 +-
.../org/apache/nifi/json/TestWriteJsonResult.java | 2 +
.../schema/inference/TestFieldTypeInference.java | 20 +++
.../org/apache/nifi/xml/TestWriteXMLResult.java | 5 +-
.../org/apache/nifi/xml/TestXMLRecordReader.java | 17 +++
.../src/test/resources/avro/decimals.avsc | 36 +++++
.../src/test/resources/json/output/dataTypes.json | 1 +
54 files changed, 1098 insertions(+), 83 deletions(-)
copy
nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/type/{MapDataType.java
=> DecimalDataType.java} (61%)
create mode 100644
nifi-commons/nifi-record/src/test/java/org/apache/nifi/serialization/record/ResultSetRecordSetTest.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/test/java/org/apache/nifi/schema/access/InferenceSchemaStrategyTest.java
create mode 100644
nifi-nar-bundles/nifi-solr-bundle/nifi-solr-processors/src/test/java/org/apache/nifi/processors/solr/SolrUtilsTest.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/resources/avro/decimals.avsc
