This is an automated email from the ASF dual-hosted git repository.
ankitsultana pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 4bfa6ee989 Make Custom Config Optional (#14014)
add c395d09c1f Part-3: Working E2E Quickstart for Time Series Engine
(#14048)
No new revisions were added by this update.
Summary of changes:
pinot-broker/pom.xml | 8 +
.../broker/api/resources/PinotClientRequest.java | 49 ++++++
.../broker/broker/helix/BaseBrokerStarter.java | 22 ++-
.../requesthandler/BrokerRequestHandler.java | 9 ++
.../BrokerRequestHandlerDelegate.java | 21 ++-
.../requesthandler/TimeSeriesRequestHandler.java | 172 +++++++++++++++++++++
.../response/PinotBrokerTimeSeriesResponse.java | 168 ++++++++++++++++++++
.../pinot/common/utils/HumanReadableDuration.java | 74 +++++++++
pinot-common/src/main/proto/worker.proto | 12 ++
.../core/query/executor/QueryExecutorTest.java | 2 +-
pinot-distribution/pinot-assembly.xml | 10 ++
.../pinot-timeseries-m3ql}/pom.xml | 33 +++-
.../org/apache/pinot/tsdb/m3ql/Aggregations.java | 22 +++
.../java/org/apache/pinot/tsdb/m3ql/Constants.java | 30 ++++
.../pinot/tsdb/m3ql/M3TimeSeriesPlanner.java | 158 +++++++++++++++++++
.../apache/pinot/tsdb/m3ql/PlanIdGenerator.java | 30 ++++
.../tsdb/m3ql/operator/KeepLastValueOperator.java | 55 +++++++
.../tsdb/m3ql/operator/TransformNullOperator.java | 53 +++++++
.../apache/pinot/tsdb/m3ql/parser/Tokenizer.java | 87 +++++++++++
.../tsdb/m3ql/plan/KeepLastValuePlanNode.java | 51 ++++++
.../tsdb/m3ql/plan/TransformNullPlanNode.java | 63 ++++++++
.../m3ql/time/QueryTimeBoundaryConstraints.java | 74 +++++++++
.../pinot/tsdb/m3ql/time/TimeBucketComputer.java | 79 ++++++++++
.../pinot-timeseries-lang}/pom.xml | 14 +-
pinot-plugins/pom.xml | 1 +
pinot-query-runtime/pom.xml | 8 +
.../apache/pinot/query/runtime/QueryRunner.java | 88 +++++++++++
.../runtime/timeseries/LeafTimeSeriesOperator.java | 63 ++++++++
.../timeseries/PhysicalTimeSeriesPlanVisitor.java | 107 +++++++++++++
.../timeseries/TimeSeriesExecutionContext.java | 35 +++--
.../timeseries/TimeSeriesPhysicalTableScan.java | 70 +++++++++
.../query/service/dispatch/QueryDispatcher.java | 86 +++++++++++
.../AsyncQueryTimeSeriesDispatchResponse.java | 57 +++++++
.../timeseries/TimeSeriesDispatchClient.java | 53 +++++++
.../timeseries/TimeSeriesDispatchObserver.java | 66 ++++++++
.../pinot/query/service/server/QueryServer.java | 8 +
.../pom.xml | 18 ++-
.../tsdb/planner/TimeSeriesPlanConstants.java | 56 +++++++
.../tsdb/planner/TimeSeriesQueryEnvironment.java | 146 +++++++++++++++++
.../tsdb/planner/physical/TableScanVisitor.java | 99 ++++++++++++
.../physical/TimeSeriesDispatchablePlan.java} | 39 +++--
.../physical/TimeSeriesQueryServerInstance.java | 50 ++++++
pinot-timeseries/pinot-timeseries-spi/pom.xml | 3 +-
.../pinot/tsdb/spi/RangeTimeSeriesRequest.java | 19 ++-
.../spi/series/SimpleTimeSeriesBuilderFactory.java | 4 +-
.../pinot/tsdb/spi/series/TimeSeriesBlock.java | 4 +-
.../series/TimeSeriesBuilderFactoryProvider.java | 3 +-
pinot-timeseries/pom.xml | 1 +
.../pinot/tools/TimeSeriesEngineQuickStart.java | 108 +++++++++++++
pom.xml | 5 +
50 files changed, 2431 insertions(+), 62 deletions(-)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/TimeSeriesRequestHandler.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/response/PinotBrokerTimeSeriesResponse.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/utils/HumanReadableDuration.java
copy {pinot-timeseries/pinot-timeseries-spi =>
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql}/pom.xml (64%)
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/Aggregations.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/Constants.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/M3TimeSeriesPlanner.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/PlanIdGenerator.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/operator/KeepLastValueOperator.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/operator/TransformNullOperator.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/parser/Tokenizer.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/plan/KeepLastValuePlanNode.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/plan/TransformNullPlanNode.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/time/QueryTimeBoundaryConstraints.java
create mode 100644
pinot-plugins/pinot-timeseries-lang/pinot-timeseries-m3ql/src/main/java/org/apache/pinot/tsdb/m3ql/time/TimeBucketComputer.java
copy {pinot-timeseries => pinot-plugins/pinot-timeseries-lang}/pom.xml (81%)
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/timeseries/LeafTimeSeriesOperator.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/timeseries/PhysicalTimeSeriesPlanVisitor.java
copy
pinot-timeseries/pinot-timeseries-spi/src/main/java/org/apache/pinot/tsdb/spi/series/TimeSeriesBlock.java
=>
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/timeseries/TimeSeriesExecutionContext.java
(52%)
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/timeseries/TimeSeriesPhysicalTableScan.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/service/dispatch/timeseries/AsyncQueryTimeSeriesDispatchResponse.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/service/dispatch/timeseries/TimeSeriesDispatchClient.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/service/dispatch/timeseries/TimeSeriesDispatchObserver.java
copy pinot-timeseries/{pinot-timeseries-spi =>
pinot-timeseries-planner}/pom.xml (77%)
create mode 100644
pinot-timeseries/pinot-timeseries-planner/src/main/java/org/apache/pinot/tsdb/planner/TimeSeriesPlanConstants.java
create mode 100644
pinot-timeseries/pinot-timeseries-planner/src/main/java/org/apache/pinot/tsdb/planner/TimeSeriesQueryEnvironment.java
create mode 100644
pinot-timeseries/pinot-timeseries-planner/src/main/java/org/apache/pinot/tsdb/planner/physical/TableScanVisitor.java
copy
pinot-timeseries/{pinot-timeseries-spi/src/main/java/org/apache/pinot/tsdb/spi/series/TimeSeriesBlock.java
=>
pinot-timeseries-planner/src/main/java/org/apache/pinot/tsdb/planner/physical/TimeSeriesDispatchablePlan.java}
(52%)
create mode 100644
pinot-timeseries/pinot-timeseries-planner/src/main/java/org/apache/pinot/tsdb/planner/physical/TimeSeriesQueryServerInstance.java
create mode 100644
pinot-tools/src/main/java/org/apache/pinot/tools/TimeSeriesEngineQuickStart.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
