druid/examples
Gian Merlino 0ce406bdf1
Introduce "transformSpec" at ingest-time. (#4890)
* Introduce "transformSpec" at ingest-time.

It accepts a "filter" (standard query filter object) and "transforms" (a
list of objects with "name" and "expression"). These can be used to do
filtering and single-row transforms without need for a separate data
processing job.

The "expression" fields use the same expression language as other
expression-based feature.

* Remove forbidden api.

* Fix compile error.

* Fix tests.

* Some more changes.

- Add nullable annotation to Firehose.nextRow.
- Add tests for index task, realtime task, kafka task, hadoop mapper,
  and ingestSegment firehose.

* Fix bad merge.

* Adjust imports.

* Adjust whitespace.

* Make Transform into an interface.

* Add missing annotation.

* Switch logger.

* Switch logger.

* Adjust test.

* Adjustment to handling for DatasourceIngestionSpec.

* Fix test.

* CR comments.

* Remove unused method.

* Add javadocs.

* More javadocs, and always decorate.

* Fix bug in TransformingStringInputRowParser.

* Fix bad merge.

* Fix ISFF tests.

* Fix DORC test.
2017-10-30 17:38:52 -07:00
..
bin Append instead of create log file so that it is possible to logrotate. (#4644) 2017-08-03 14:29:15 -07:00
conf Make float default representation for DoubleSum/Min/Max aggregators (#4944) 2017-10-16 17:17:22 -07:00
conf-quickstart Make float default representation for DoubleSum/Min/Max aggregators (#4944) 2017-10-16 17:17:22 -07:00
quickstart Protobuf extension (#4039) 2017-05-30 13:11:58 -07:00
src/main Introduce "transformSpec" at ingest-time. (#4890) 2017-10-30 17:38:52 -07:00
pom.xml Bump versions in master to 0.11.1-SNAPSHOT. (#4878) 2017-09-28 17:09:51 -05:00