level23 / druid-client

examples/TimeBoundary.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
     // Enable this to see some more data
     $client->setLogger(new ConsoleLogger());
 
-    $response = $client->metadata()->timeBoundary('wikipedia', TimeBound::MAX_TIME, function(FilterBuilder $builder) {
+    $response = $client->metadata()->timeBoundary('wikipedia', TimeBound::MAX_TIME, function (FilterBuilder $builder) {
         $builder->where('channel', '!=', '#vi.wikipedia');
     });
 

src/Queries/QueryBuilder.php

Spacing +22 added lines, -22 removed lines

@@ -101,7 +101,7 @@ 
      * @param string                     $dataSource
      * @param string|Granularity                     $granularity
      */
-    public function __construct(DruidClient $client, string $dataSource = '', string|Granularity $granularity = Granularity::ALL)
+    public function __construct(DruidClient $client, string $dataSource = '', string | Granularity $granularity = Granularity::ALL)
     {
         $this->client      = $client;
         $this->query       = $this;
@@ -124,7 +124,7 @@ 
      * @return $this
      * @see https://druid.apache.org/docs/latest/misc/math-expr.html
      */
-    public function selectVirtual(string $expression, string $as, string|DataType $outputType = DataType::STRING): self
+    public function selectVirtual(string $expression, string $as, string | DataType $outputType = DataType::STRING): self
     {
         $this->virtualColumn($expression, $as, $outputType);
         $this->select($as, $as, null, $outputType);
@@ -141,7 +141,7 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
-    public function execute(array|QueryContext $context = []): QueryResponse
+    public function execute(array | QueryContext $context = []): QueryResponse
     {
         $query = $this->getQuery($context);
 
@@ -157,7 +157,7 @@ 
      *
      * @return $this
      */
-    public function granularity(string|Granularity $granularity): QueryBuilder
+    public function granularity(string | Granularity $granularity): QueryBuilder
     {
         $this->granularity = is_string($granularity) ? Granularity::from(strtolower($granularity)) : $granularity;
 
@@ -248,7 +248,7 @@ 
      * @return string
      * @throws \InvalidArgumentException if the JSON cannot be encoded.
      */
-    public function toJson(array|QueryContext $context = []): string
+    public function toJson(array | QueryContext $context = []): string
     {
         $query = $this->getQuery($context);
 
@@ -269,7 +269,7 @@ 
      *
      * @return array<string,array<mixed>|string|int>
      */
-    public function toArray(array|QueryContext $context = []): array
+    public function toArray(array | QueryContext $context = []): array
     {
         return $this->getQuery($context)->toArray();
     }
@@ -283,7 +283,7 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
-    public function timeseries(array|TimeSeriesQueryContext $context = []): TimeSeriesQueryResponse
+    public function timeseries(array | TimeSeriesQueryContext $context = []): TimeSeriesQueryResponse
     {
         $query = $this->buildTimeSeriesQuery($context);
 
@@ -312,10 +312,10 @@ 
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
     public function scan(
-        array|ScanQueryContext $context = [],
+        array | ScanQueryContext $context = [],
         ?int $rowBatchSize = null,
         bool $legacy = false,
-        string|ScanQueryResultFormat $resultFormat = ScanQueryResultFormat::NORMAL_LIST
+        string | ScanQueryResultFormat $resultFormat = ScanQueryResultFormat::NORMAL_LIST
     ): ScanQueryResponse {
         $query = $this->buildScanQuery($context, $rowBatchSize, $legacy, $resultFormat);
 
@@ -333,7 +333,7 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
-    public function selectQuery(array|QueryContext $context = []): SelectQueryResponse
+    public function selectQuery(array | QueryContext $context = []): SelectQueryResponse
     {
         $query = $this->buildSelectQuery($context);
 
@@ -351,7 +351,7 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
-    public function topN(array|TopNQueryContext $context = []): TopNQueryResponse
+    public function topN(array | TopNQueryContext $context = []): TopNQueryResponse
     {
         $query = $this->buildTopNQuery($context);
 
@@ -369,7 +369,7 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
-    public function groupBy(array|GroupByV1QueryContext|GroupByV2QueryContext $context = []): GroupByQueryResponse
+    public function groupBy(array | GroupByV1QueryContext | GroupByV2QueryContext $context = []): GroupByQueryResponse
     {
         $query = $this->buildGroupByQuery($context);
 
@@ -387,7 +387,7 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
-    public function groupByV1(array|GroupByV1QueryContext|GroupByV2QueryContext $context = []): GroupByQueryResponse
+    public function groupByV1(array | GroupByV1QueryContext | GroupByV2QueryContext $context = []): GroupByQueryResponse
     {
         $query = $this->buildGroupByQuery($context, 'v1');
 
@@ -406,7 +406,7 @@ 
      * @throws \GuzzleHttp\Exception\GuzzleException
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      */
-    public function search(array|QueryContext $context = [], string|SortingOrder $sortingOrder = SortingOrder::LEXICOGRAPHIC): SearchQueryResponse
+    public function search(array | QueryContext $context = [], string | SortingOrder $sortingOrder = SortingOrder::LEXICOGRAPHIC): SearchQueryResponse
     {
         $query = $this->buildSearchQuery($context, $sortingOrder);
 
@@ -452,7 +452,7 @@ 
      *
      * @return \Level23\Druid\Queries\SearchQuery
      */
-    protected function buildSearchQuery(array|QueryContext $context = [], string|SortingOrder $sortingOrder = SortingOrder::LEXICOGRAPHIC): SearchQuery
+    protected function buildSearchQuery(array | QueryContext $context = [], string | SortingOrder $sortingOrder = SortingOrder::LEXICOGRAPHIC): SearchQuery
     {
         if (count($this->intervals) == 0) {
             throw new InvalidArgumentException('You have to specify at least one interval');
@@ -501,7 +501,7 @@ 
      *
      * @return \Level23\Druid\Queries\SelectQuery
      */
-    protected function buildSelectQuery(array|QueryContext $context = []): SelectQuery
+    protected function buildSelectQuery(array | QueryContext $context = []): SelectQuery
     {
         if (count($this->intervals) == 0) {
             throw new InvalidArgumentException('You have to specify at least one interval');
@@ -553,10 +553,10 @@ 
      * @return \Level23\Druid\Queries\ScanQuery
      */
     protected function buildScanQuery(
-        array|QueryContext $context = [],
+        array | QueryContext $context = [],
         ?int $rowBatchSize = null,
         bool $legacy = false,
-        string|ScanQueryResultFormat $resultFormat = ScanQueryResultFormat::NORMAL_LIST
+        string | ScanQueryResultFormat $resultFormat = ScanQueryResultFormat::NORMAL_LIST
     ): ScanQuery {
         if (count($this->intervals) == 0) {
             throw new InvalidArgumentException('You have to specify at least one interval');
@@ -634,7 +634,7 @@ 
      *
      * @return TimeSeriesQuery
      */
-    protected function buildTimeSeriesQuery(array|QueryContext $context = []): TimeSeriesQuery
+    protected function buildTimeSeriesQuery(array | QueryContext $context = []): TimeSeriesQuery
     {
         if (count($this->intervals) == 0) {
             throw new InvalidArgumentException('You have to specify at least one interval');
@@ -702,7 +702,7 @@ 
      *
      * @return TopNQuery
      */
-    protected function buildTopNQuery(array|QueryContext $context = []): TopNQuery
+    protected function buildTopNQuery(array | QueryContext $context = []): TopNQuery
     {
         if (count($this->intervals) == 0) {
             throw new InvalidArgumentException('You have to specify at least one interval');
@@ -775,7 +775,7 @@ 
      *
      * @return GroupByQuery
      */
-    protected function buildGroupByQuery(array|QueryContext $context = [], string $type = 'v2'): GroupByQuery
+    protected function buildGroupByQuery(array | QueryContext $context = [], string $type = 'v2'): GroupByQuery
     {
         if (count($this->intervals) == 0) {
             throw new InvalidArgumentException('You have to specify at least one interval');
@@ -838,7 +838,7 @@ 
      *
      * @return \Level23\Druid\Queries\QueryInterface
      */
-    public function getQuery(array|QueryContext $context = []): QueryInterface
+    public function getQuery(array | QueryContext $context = []): QueryInterface
     {
         // Check if this is a scan query. This is the preferred way to query when there are
         // no aggregations done.

src/Queries/SelectQuery.php

Spacing +1 added lines, -1 removed lines

@@ -142,7 +142,7 @@
      *
      * @throws InvalidArgumentException
      */
-    public function setGranularity(string|Granularity $granularity): void
+    public function setGranularity(string | Granularity $granularity): void
     {
         $this->granularity = is_string($granularity) ? Granularity::from(strtolower($granularity)) : $granularity;
     }

src/Queries/TopNQuery.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
         DimensionInterface $dimension,
         int $threshold,
         string $metric,
-        string|Granularity $granularity = Granularity::ALL
+        string | Granularity $granularity = Granularity::ALL
     ) {
         $this->dataSource  = $dataSource;
         $this->intervals   = $intervals;

src/Queries/TimeSeriesQuery.php

Spacing +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
     public function __construct(
         DataSourceInterface $dataSource,
         IntervalCollection $intervals,
-        string|Granularity $granularity = Granularity::ALL
+        string | Granularity $granularity = Granularity::ALL
     ) {
         $this->dataSource  = $dataSource;
         $this->intervals   = $intervals;

src/Queries/ScanQuery.php

Spacing +2 added lines, -2 removed lines

@@ -150,7 +150,7 @@ 
      *
      * @param string|ScanQueryResultFormat $resultFormat
      */
-    public function setResultFormat(string|ScanQueryResultFormat $resultFormat): void
+    public function setResultFormat(string | ScanQueryResultFormat $resultFormat): void
     {
         $this->resultFormat = is_string($resultFormat) ? ScanQueryResultFormat::from(strtolower($resultFormat)) : $resultFormat;
     }
@@ -229,7 +229,7 @@ 
      *
      * @param string|OrderByDirection $order
      */
-    public function setOrder(string|OrderByDirection $order): void
+    public function setOrder(string | OrderByDirection $order): void
     {
         $this->order = is_string($order) ? OrderByDirection::make($order) : $order;
     }

src/Queries/GroupByQuery.php

Spacing +5 added lines, -5 removed lines

@@ -61,8 +61,8 @@ 
         DataSourceInterface $dataSource,
         DimensionCollection $dimensions,
         IntervalCollection $intervals,
-        array|AggregationCollection $aggregations = null,
-        string|Granularity $granularity = 'all'
+        array | AggregationCollection $aggregations = null,
+        string | Granularity $granularity = 'all'
     ) {
         $this->dataSource  = $dataSource;
         $this->dimensions  = $dimensions;
@@ -135,7 +135,7 @@ 
     /**
      * @param \Level23\Druid\Collections\AggregationCollection|array<AggregatorInterface> $aggregations
      */
-    public function setAggregations(array|AggregationCollection $aggregations): void
+    public function setAggregations(array | AggregationCollection $aggregations): void
     {
         if (is_array($aggregations)) {
             $aggregations = new AggregationCollection(...$aggregations);
@@ -147,7 +147,7 @@ 
     /**
      * @param \Level23\Druid\Collections\PostAggregationCollection|array<PostAggregatorInterface> $postAggregations
      */
-    public function setPostAggregations(PostAggregationCollection|array $postAggregations): void
+    public function setPostAggregations(PostAggregationCollection | array $postAggregations): void
     {
         if (is_array($postAggregations)) {
             $postAggregations = new PostAggregationCollection(...$postAggregations);
@@ -175,7 +175,7 @@ 
     /**
      * @param \Level23\Druid\Limits\Limit|int $limit
      */
-    public function setLimit(Limit|int $limit): void
+    public function setLimit(Limit | int $limit): void
     {
         if ($limit instanceof LimitInterface) {
             $this->limit = $limit;

src/Queries/SearchQuery.php

Spacing +2 added lines, -2 removed lines

@@ -39,7 +39,7 @@ 
 
     public function __construct(
         DataSourceInterface $dataSource,
-        string|Granularity $granularity,
+        string | Granularity $granularity,
         IntervalCollection $intervals,
         SearchFilterInterface $searchFilter
     ) {
@@ -123,7 +123,7 @@ 
     /**
      * @param string|SortingOrder $sort
      */
-    public function setSort(string|SortingOrder $sort): void
+    public function setSort(string | SortingOrder $sort): void
     {
         $this->sort = is_string($sort) ? SortingOrder::from(strtolower($sort)) : $sort;
     }

src/OrderBy/OrderBy.php

Spacing +2 added lines, -2 removed lines

@@ -23,8 +23,8 @@
      */
     public function __construct(
         string $dimension,
-        string|OrderByDirection $direction = OrderByDirection::ASC,
-        string|SortingOrder $dimensionOrder = SortingOrder::LEXICOGRAPHIC
+        string | OrderByDirection $direction = OrderByDirection::ASC,
+        string | SortingOrder $dimensionOrder = SortingOrder::LEXICOGRAPHIC
     ) {
         $this->dimension      = $dimension;
         $this->direction      = is_string($direction) ? OrderByDirection::make($direction) : $direction;