You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by da...@apache.org on 2018/11/06 23:36:25 UTC
[incubator-druid] branch missing-headers updated (2feaa72 ->
7eec894)
This is an automated email from the ASF dual-hosted git repository.
davidlim pushed a change to branch missing-headers
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git.
from 2feaa72 fix modified druid-production.svg
add 7b34662 Period load/drop/broadcast rules should include the future by default (#6414)
add a92c2a1 Move supervisor APIs to api-reference (#6555)
add ddd15a6 correct default value for maxTotalRows (#6566)
add 26d9928 correct default tier name (#6568)
add 23ad3d2 fixup docs to download from Apache mirror, fixup tarball name and path, change references from quickstart/* to quickstart/tutorial/* (#6570)
add a2a1a1c Hide NullDimensionSelector from public (#6480)
add 1224d8b overhaul 'druid-parquet-extensions' module, promoting from 'contrib' to 'core' (#6360)
add bcb754d Use current coordinator leader instead of cached one (#6551) (#6552)
add 54351a5 Fix various bugs; Enable more IntelliJ inspections and update error-prone (#6490)
add 7eec894 Merge branch 'master' into missing-headers
No new revisions were added by this update.
Summary of changes:
.idea/inspectionProfiles/Druid.xml | 46 +-
.../query/timecompare/TimeCompareBenchmark.java | 32 +-
.../druid/data/input/impl/JSONParseSpec.java | 23 +-
.../druid/data/input/impl/NestedDataParseSpec.java | 59 +--
.../druid/java/util/common/guava/Comparators.java | 20 -
.../parsers/NotImplementedMappingProvider.java | 13 +-
.../druid/java/util/emitter/core/Emitters.java | 2 +-
.../http/client/pool/ChannelResourceFactory.java | 2 +-
.../java/org/apache/druid/math/expr/ExprEval.java | 17 +-
.../collections/OrderedMergeIteratorTest.java | 11 +-
.../java/util/common/guava/ComparatorsTest.java | 28 --
.../java/util/common/guava/ConcatSequenceTest.java | 4 +-
.../java/util/common/guava/SequenceTestHelper.java | 4 +-
distribution/pom.xml | 4 +-
.../development/extensions-contrib/parquet.md | 177 --------
.../development/extensions-core/kafka-ingestion.md | 138 ++----
.../content/development/extensions-core/parquet.md | 219 +++++++++
docs/content/development/extensions.md | 2 +-
docs/content/development/router.md | 2 +-
docs/content/ingestion/native_tasks.md | 2 +-
docs/content/operations/api-reference.md | 76 ++++
docs/content/operations/other-hadoop.md | 2 +-
docs/content/operations/rule-configuration.md | 16 +-
docs/content/tutorials/cluster.md | 29 +-
docs/content/tutorials/index.md | 44 +-
docs/content/tutorials/tutorial-batch-hadoop.md | 6 +-
docs/content/tutorials/tutorial-batch.md | 8 +-
docs/content/tutorials/tutorial-delete-data.md | 4 +-
docs/content/tutorials/tutorial-ingestion-spec.md | 2 +-
docs/content/tutorials/tutorial-kafka.md | 4 +-
docs/content/tutorials/tutorial-query.md | 2 +-
docs/content/tutorials/tutorial-retention.md | 2 +-
docs/content/tutorials/tutorial-rollup.md | 2 +-
docs/content/tutorials/tutorial-tranquility.md | 8 +-
.../quickstart/tutorial/compaction-init-index.json | 2 +-
examples/quickstart/tutorial/deletion-index.json | 2 +-
examples/quickstart/tutorial/retention-index.json | 2 +-
examples/quickstart/tutorial/wikipedia-index.json | 2 +-
.../druid/extendedset/intset/BitIterator.java | 2 +-
.../druid/extendedset/intset/ConciseSet.java | 17 +-
.../extendedset/intset/ImmutableConciseSet.java | 2 +-
.../org/apache/druid/firehose/azure/AzureBlob.java | 4 +-
.../cassandra/CassandraDataSegmentPuller.java | 3 +-
.../druid/firehose/cloudfiles/CloudFilesBlob.java | 6 +-
.../cloudfiles/CloudFilesStorageDruidModule.java | 2 +-
.../druid/firehose/kafka/KafkaSimpleConsumer.java | 4 +-
.../MaterializedViewSupervisor.java | 3 +-
.../data/input/orc/OrcIndexGeneratorJobTest.java | 4 +-
extensions-contrib/parquet-extensions/pom.xml | 72 ---
.../data/input/parquet/GenericRecordAsMap.java | 146 ------
.../druid/data/input/avro/AvroFlattenerMaker.java | 38 +-
.../druid/data/input/avro/AvroParseSpec.java | 47 +-
.../data/input/AvroStreamInputRowParserTest.java | 1 +
.../quantiles/DoublesSketchBuildAggregator.java | 3 +-
.../DoublesSketchBuildBufferAggregator.java | 3 +-
.../datasketches/theta/SketchHolder.java | 1 +
.../ArrayOfDoublesSketchAggregatorFactory.java | 5 +-
...ublesSketchToQuantilesSketchPostAggregator.java | 2 +-
.../datasketches/quantiles/GenerateTestData.java | 3 +-
.../DruidKerberosAuthenticationHandler.java | 14 +-
.../security/kerberos/KerberosAuthenticator.java | 2 +-
.../storage/hdfs/HdfsDataSegmentPusherTest.java | 21 +-
.../histogram/ApproximateHistogram.java | 5 +-
.../histogram/ApproximateHistogramTest.java | 2 +
.../indexing/kafka/supervisor/KafkaSupervisor.java | 15 +-
.../druid/indexing/kafka/test/TestBroker.java | 4 +-
.../lookup/namespace/cache/CacheSchedulerTest.java | 2 +-
.../cache/JdbcExtractionNamespaceTest.java | 4 +-
...1476716b-56d5676f53bd6e85_115466471_data.0.parq | Bin
.../example/compat}/impala_hadoop_parquet_job.json | 26 +-
.../example/compat/nested-array-struct.parquet | Bin 0 -> 775 bytes
.../example/compat/nested_array_struct.json | 66 +--
.../example/compat/old-repeated-int.parquet | Bin 0 -> 389 bytes
.../example/compat/old_repeated_int.json | 49 +-
.../example/compat/parquet-1217.parquet | Bin 0 -> 321 bytes
.../compat/parquet-thrift-compat.snappy.parquet | Bin 0 -> 10550 bytes
.../example/compat/parquet_1217.json | 67 +--
.../example/compat/parquet_thrift_compat.json | 68 +--
.../example/compat/proto-struct-with-array.parquet | Bin 0 -> 1576 bytes
.../example/compat/proto_struct_with_array.json | 68 +--
.../example/decimals/dec-in-fixed-len.parquet | Bin 0 -> 460 bytes
.../example/decimals/dec-in-i32.parquet | Bin 0 -> 420 bytes
.../example/decimals/dec-in-i64.parquet | Bin 0 -> 437 bytes
.../example/decimals/dec_in_fix_len.json | 65 +--
.../example/decimals/dec_in_i32.json | 65 +--
.../example/decimals/dec_in_i64.json | 65 +--
.../example/flattening/flat_1.json | 41 +-
.../flattening/flat_1_autodiscover_fields.json | 46 +-
.../example/flattening/flat_1_flatten.json | 76 ++--
.../example/flattening/flat_1_list_index.json | 72 +--
.../example/flattening/nested_1.json | 38 +-
.../flattening/nested_1_autodiscover_fields.json | 46 +-
.../example/flattening/nested_1_flatten.json | 109 +++++
.../example/flattening/nested_1_list_index.json | 78 ++--
.../example/flattening/test_flat_1.parquet | Bin 0 -> 1123 bytes
.../example/flattening/test_nested_1.parquet | Bin 0 -> 1339 bytes
.../timestamps}/date_test_data_job_date.json | 26 +-
.../timestamps}/date_test_data_job_string.json | 26 +-
.../example/timestamps/int96_timestamp.json | 41 +-
.../example/timestamps/int96_timestamp.parquet | Bin 0 -> 374 bytes
.../timestamps}/test_date_data.snappy.parquet | Bin
.../example/timestamps/timemillis-in-i64.parquet | Bin 0 -> 517 bytes
.../example/timestamps/timemillis_in_i64.json | 41 +-
.../parquet-extensions/example/wiki/wiki.json | 44 +-
.../parquet-extensions/example/wiki/wiki.parquet | Bin
extensions-core/parquet-extensions/pom.xml | 127 ++++++
.../input/parquet/ParquetExtensionsModule.java | 15 +-
.../parquet/avro/DruidParquetAvroInputFormat.java | 10 +-
.../avro/ParquetAvroHadoopInputRowParser.java | 59 ++-
.../parquet/simple}/DruidParquetInputFormat.java | 8 +-
.../parquet/simple}/DruidParquetReadSupport.java | 53 +--
.../parquet/simple/ParquetGroupConverter.java | 497 +++++++++++++++++++++
.../parquet/simple/ParquetGroupFlattenerMaker.java | 110 +++++
.../parquet/simple/ParquetGroupJsonProvider.java | 192 ++++++++
.../simple/ParquetHadoopInputRowParser.java | 78 ++++
.../input/parquet/simple/ParquetParseSpec.java} | 63 +--
.../parquet/avro/DruidParquetAvroReadSupport.java | 22 +-
.../org.apache.druid.initialization.DruidModule | 0
.../data/input/parquet/BaseParquetInputTest.java | 114 +++--
.../data/input/parquet/CompatParquetInputTest.java | 257 +++++++++++
.../input/parquet/DecimalParquetInputTest.java | 111 +++++
.../input/parquet/FlattenSpecParquetInputTest.java | 230 ++++++++++
.../input/parquet/TimestampsParquetInputTest.java | 114 +++++
.../data/input/parquet/WikiParquetInputTest.java | 76 ++++
.../input/protobuf/ProtobufInputRowParser.java | 4 +-
.../variance/VarianceGroupByQueryTest.java | 20 +-
.../variance/VarianceTimeseriesQueryTest.java | 17 +-
.../org/apache/druid/hll/HyperLogLogCollector.java | 6 +-
.../druid/hll/HyperLogLogCollectorBenchmark.java | 1 +
.../druid/indexer/IndexGeneratorJobTest.java | 4 +-
.../indexing/common/task/HadoopIndexTask.java | 2 +-
.../overlord/hrtr/HttpRemoteTaskRunner.java | 2 +-
.../overlord/supervisor/SupervisorManager.java | 2 +-
.../druid/indexing/worker/WorkerTaskManager.java | 2 +-
.../firehose/IngestSegmentFirehoseFactoryTest.java | 5 +-
.../druid/indexing/test/TestDataSegmentKiller.java | 7 +-
.../druid/indexing/test/TestDataSegmentPusher.java | 5 -
.../clients/CoordinatorResourceTestClient.java | 10 +-
.../druid/tests/hadoop/ITHadoopIndexTest.java | 2 +-
.../indexer/AbstractITRealtimeIndexTaskTest.java | 2 +-
.../ITAppenderatorDriverRealtimeIndexTaskTest.java | 2 +-
.../apache/druid/tests/indexer/ITKafkaTest.java | 7 +-
.../tests/indexer/ITRealtimeIndexTaskTest.java | 2 +-
pom.xml | 15 +-
.../apache/druid/query/groupby/GroupByQuery.java | 43 +-
.../groupby/epinephelinae/BufferArrayGrouper.java | 2 +-
.../groupby/epinephelinae/BufferHashGrouper.java | 1 +
.../epinephelinae/LimitedBufferHashGrouper.java | 1 +
.../groupby/epinephelinae/SpillingGrouper.java | 2 +-
.../druid/query/ordering/StringComparators.java | 4 +-
.../query/scan/ScanQueryLimitRowIterator.java | 2 +-
.../query/search/SearchQueryQueryToolChest.java | 12 +-
.../druid/query/search/SearchQueryRunner.java | 3 +-
.../query/select/SelectResultValueBuilder.java | 3 +-
.../topn/AggregateTopNMetricFirstAlgorithm.java | 2 +-
.../druid/query/topn/InvertedTopNMetricSpec.java | 19 +-
.../druid/segment/ConstantDimensionSelector.java | 4 +-
.../apache/druid/segment/DimensionSelector.java | 140 ++++++
.../druid/segment/DimensionSelectorUtils.java | 30 --
.../java/org/apache/druid/segment/IndexIO.java | 9 -
.../druid/segment/NullDimensionSelector.java | 128 ------
.../QueryableIndexColumnSelectorFactory.java | 4 +-
.../data/BlockLayoutColumnarLongsSerializer.java | 2 +-
.../org/apache/druid/segment/filter/Filters.java | 2 +-
.../apache/druid/segment/filter/LikeFilter.java | 2 +-
.../IncrementalIndexColumnSelectorFactory.java | 5 +-
.../druid/segment/virtual/ExpressionSelectors.java | 6 +-
.../aggregation/JavaScriptAggregatorTest.java | 2 +-
.../druid/query/select/SelectBinaryFnTest.java | 3 -
.../timeboundary/TimeBoundaryQueryRunnerTest.java | 8 -
.../segment/ConstantDimensionSelectorTest.java | 8 +-
.../druid/segment/SchemalessTestSimpleTest.java | 2 +
.../org/apache/druid/client/DirectDruidClient.java | 2 +-
.../apache/druid/client/JsonParserIterator.java | 15 +-
.../client/cache/BytesBoundedLinkedQueue.java | 23 +-
.../apache/druid/discovery/DruidLeaderClient.java | 14 +-
.../druid/metadata/SQLMetadataConnector.java | 2 +-
.../firehose/EventReceiverFirehoseFactory.java | 2 +-
.../server/coordinator/ReplicationThrottler.java | 2 +-
.../server/coordinator/SegmentReplicantLookup.java | 4 +-
.../rules/PeriodBroadcastDistributionRule.java | 16 +-
.../server/coordinator/rules/PeriodDropRule.java | 19 +-
.../server/coordinator/rules/PeriodLoadRule.java | 12 +-
.../druid/server/coordinator/rules/Rules.java | 8 +-
.../druid/server/http/DatasourcesResource.java | 6 +-
.../druid/server/http/IntervalsResource.java | 16 +-
.../server/http/LookupCoordinatorResource.java | 2 +-
.../initialization/jetty/JettyServerInitUtils.java | 2 +-
.../PreResponseAuthorizationCheckFilter.java | 7 +-
.../server/security/SecuritySanityCheckFilter.java | 3 +-
.../resources/static/old-console/js/rules-0.0.2.js | 6 +-
.../druid/client/CachingClusteredClientTest.java | 3 +
.../client/cache/BytesBoundedLinkedQueueTest.java | 5 +-
.../apache/druid/client/cache/HybridCacheTest.java | 4 +-
.../client/cache/MemcachedCacheBenchmark.java | 2 +-
.../appenderator/AppenderatorPlumberTest.java | 27 +-
.../coordinator/CuratorDruidCoordinatorTest.java | 3 +-
.../DruidCoordinatorBalancerProfiler.java | 2 +-
.../rules/BroadcastDistributionRuleSerdeTest.java | 6 +-
.../coordinator/rules/PeriodDropRuleTest.java | 33 +-
.../coordinator/rules/PeriodLoadRuleTest.java | 48 +-
...JavaScriptTieredBrokerSelectorStrategyTest.java | 1 -
.../cli/CoordinatorJettyServerInitializer.java | 3 +-
.../org/apache/druid/cli/PullDependencies.java | 1 +
.../druid/cli/QueryJettyServerInitializer.java | 3 +-
.../apache/druid/sql/avatica/DruidConnection.java | 14 +-
.../druid/sql/calcite/schema/SystemSchema.java | 18 +-
.../druid/sql/calcite/schema/SystemSchemaTest.java | 8 +-
208 files changed, 3855 insertions(+), 1867 deletions(-)
copy extensions-contrib/azure-extensions/src/main/java/org/apache/druid/firehose/azure/AzureBlob.java => core/src/main/java/org/apache/druid/data/input/impl/NestedDataParseSpec.java (55%)
rename extensions-core/avro-extensions/src/main/java/org/apache/druid/data/input/avro/GenericAvroMappingProvider.java => core/src/main/java/org/apache/druid/java/util/common/parsers/NotImplementedMappingProvider.java (73%)
delete mode 100644 docs/content/development/extensions-contrib/parquet.md
create mode 100644 docs/content/development/extensions-core/parquet.md
delete mode 100644 extensions-contrib/parquet-extensions/pom.xml
delete mode 100644 extensions-contrib/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/GenericRecordAsMap.java
rename {extensions-contrib/parquet-extensions/example => extensions-core/parquet-extensions/example/compat}/284a0e001476716b-56d5676f53bd6e85_115466471_data.0.parq (100%)
copy {extensions-contrib/parquet-extensions/example => extensions-core/parquet-extensions/example/compat}/impala_hadoop_parquet_job.json (78%)
create mode 100644 extensions-core/parquet-extensions/example/compat/nested-array-struct.parquet
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/compat/nested_array_struct.json (56%)
mode change 100755 => 100644
create mode 100644 extensions-core/parquet-extensions/example/compat/old-repeated-int.parquet
copy extensions-contrib/parquet-extensions/example/impala_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/compat/old_repeated_int.json (62%)
create mode 100644 extensions-core/parquet-extensions/example/compat/parquet-1217.parquet
create mode 100644 extensions-core/parquet-extensions/example/compat/parquet-thrift-compat.snappy.parquet
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/compat/parquet_1217.json (57%)
mode change 100755 => 100644
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/compat/parquet_thrift_compat.json (54%)
mode change 100755 => 100644
create mode 100644 extensions-core/parquet-extensions/example/compat/proto-struct-with-array.parquet
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/compat/proto_struct_with_array.json (54%)
mode change 100755 => 100644
create mode 100644 extensions-core/parquet-extensions/example/decimals/dec-in-fixed-len.parquet
create mode 100755 extensions-core/parquet-extensions/example/decimals/dec-in-i32.parquet
create mode 100755 extensions-core/parquet-extensions/example/decimals/dec-in-i64.parquet
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/decimals/dec_in_fix_len.json (57%)
mode change 100755 => 100644
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/decimals/dec_in_i32.json (58%)
mode change 100755 => 100644
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/decimals/dec_in_i64.json (58%)
mode change 100755 => 100644
copy extensions-contrib/parquet-extensions/example/impala_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/flattening/flat_1.json (69%)
copy extensions-contrib/parquet-extensions/example/impala_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/flattening/flat_1_autodiscover_fields.json (65%)
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/flattening/flat_1_flatten.json (53%)
mode change 100755 => 100644
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/flattening/flat_1_list_index.json (55%)
mode change 100755 => 100644
copy extensions-contrib/parquet-extensions/example/impala_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/flattening/nested_1.json (71%)
copy extensions-contrib/parquet-extensions/example/impala_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/flattening/nested_1_autodiscover_fields.json (65%)
create mode 100644 extensions-core/parquet-extensions/example/flattening/nested_1_flatten.json
copy extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/flattening/nested_1_list_index.json (51%)
mode change 100755 => 100644
create mode 100644 extensions-core/parquet-extensions/example/flattening/test_flat_1.parquet
create mode 100644 extensions-core/parquet-extensions/example/flattening/test_nested_1.parquet
copy {extensions-contrib/parquet-extensions/example => extensions-core/parquet-extensions/example/timestamps}/date_test_data_job_date.json (78%)
rename {extensions-contrib/parquet-extensions/example => extensions-core/parquet-extensions/example/timestamps}/date_test_data_job_string.json (79%)
rename extensions-contrib/parquet-extensions/example/date_test_data_job_date.json => extensions-core/parquet-extensions/example/timestamps/int96_timestamp.json (67%)
mode change 100755 => 100644
create mode 100644 extensions-core/parquet-extensions/example/timestamps/int96_timestamp.parquet
rename {extensions-contrib/parquet-extensions/example => extensions-core/parquet-extensions/example/timestamps}/test_date_data.snappy.parquet (100%)
create mode 100644 extensions-core/parquet-extensions/example/timestamps/timemillis-in-i64.parquet
rename extensions-contrib/parquet-extensions/example/impala_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/timestamps/timemillis_in_i64.json (69%)
rename extensions-contrib/parquet-extensions/example/wikipedia_hadoop_parquet_job.json => extensions-core/parquet-extensions/example/wiki/wiki.json (73%)
rename extensions-contrib/parquet-extensions/example/wikipedia_list.parquet => extensions-core/parquet-extensions/example/wiki/wiki.parquet (100%)
create mode 100644 extensions-core/parquet-extensions/pom.xml
rename {extensions-contrib => extensions-core}/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/ParquetExtensionsModule.java (67%)
copy extensions-contrib/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/DruidParquetInputFormat.java => extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/avro/DruidParquetAvroInputFormat.java (76%)
rename extensions-contrib/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/ParquetHadoopInputRowParser.java => extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/avro/ParquetAvroHadoopInputRowParser.java (61%)
rename {extensions-contrib/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet => extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/simple}/DruidParquetInputFormat.java (86%)
mode change 100755 => 100644
copy {extensions-contrib/parquet-extensions/src/main/java/org/apache/parquet/avro => extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/simple}/DruidParquetReadSupport.java (65%)
mode change 100755 => 100644
create mode 100644 extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/simple/ParquetGroupConverter.java
create mode 100644 extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/simple/ParquetGroupFlattenerMaker.java
create mode 100644 extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/simple/ParquetGroupJsonProvider.java
create mode 100644 extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/simple/ParquetHadoopInputRowParser.java
copy extensions-core/{avro-extensions/src/main/java/org/apache/druid/data/input/avro/AvroParseSpec.java => parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/simple/ParquetParseSpec.java} (52%)
rename extensions-contrib/parquet-extensions/src/main/java/org/apache/parquet/avro/DruidParquetReadSupport.java => extensions-core/parquet-extensions/src/main/java/org/apache/parquet/avro/DruidParquetAvroReadSupport.java (82%)
rename {extensions-contrib => extensions-core}/parquet-extensions/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule (100%)
rename extensions-contrib/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/DruidParquetInputTest.java => extensions-core/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/BaseParquetInputTest.java (51%)
create mode 100644 extensions-core/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/CompatParquetInputTest.java
create mode 100644 extensions-core/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/DecimalParquetInputTest.java
create mode 100644 extensions-core/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/FlattenSpecParquetInputTest.java
create mode 100644 extensions-core/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/TimestampsParquetInputTest.java
create mode 100644 extensions-core/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/WikiParquetInputTest.java
delete mode 100644 processing/src/main/java/org/apache/druid/segment/NullDimensionSelector.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org