level23 / druid-client

src/Aggregations/AnyAggregator.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
     public function __construct(
         string $metricName,
         string $outputName = '',
-        string|DataType $type = DataType::LONG,
+        string | DataType $type = DataType::LONG,
         int $maxStringBytes = null
     ) {
         if (is_string($type)) {

src/Aggregations/LastAggregator.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
      * @param string|DataType $type       The type of field. This can either be "long", "float", "double" or "string"
      *
      */
-    public function __construct(string $metricName, string $outputName = '', string|DataType $type = DataType::LONG)
+    public function __construct(string $metricName, string $outputName = '', string | DataType $type = DataType::LONG)
     {
         $this->type       = is_string($type) ? DataType::from(strtolower($type)) : $type;
         $this->metricName = $metricName;

src/Queries/QueryBuilder.php

Spacing +24 added lines, -24 removed lines

@@ -102,7 +102,7 @@ 
     public function __construct(
         DruidClient $client,
         string $dataSource = '',
-        string|Granularity $granularity = Granularity::ALL
+        string | Granularity $granularity = Granularity::ALL
     ) {
         $this->client      = $client;
         $this->query       = $this;
@@ -125,7 +125,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);
@@ -142,7 +142,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);
 
@@ -158,7 +158,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;
 
@@ -249,7 +249,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);
 
@@ -263,7 +263,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();
     }
@@ -277,7 +277,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);
 
@@ -306,10 +306,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);
 
@@ -327,7 +327,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);
 
@@ -345,7 +345,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);
 
@@ -363,7 +363,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);
 
@@ -381,7 +381,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');
 
@@ -401,8 +401,8 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      */
     public function search(
-        array|QueryContext $context = [],
-        string|SortingOrder $sortingOrder = SortingOrder::LEXICOGRAPHIC
+        array | QueryContext $context = [],
+        string | SortingOrder $sortingOrder = SortingOrder::LEXICOGRAPHIC
     ): SearchQueryResponse {
         $query = $this->buildSearchQuery($context, $sortingOrder);
 
@@ -449,8 +449,8 @@ 
      * @return \Level23\Druid\Queries\SearchQuery
      */
     protected function buildSearchQuery(
-        array|QueryContext $context = [],
-        string|SortingOrder $sortingOrder = SortingOrder::LEXICOGRAPHIC
+        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');
@@ -499,7 +499,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');
@@ -551,10 +551,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');
@@ -632,7 +632,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');
@@ -700,7 +700,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');
@@ -773,7 +773,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');
@@ -836,7 +836,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/Concerns/HasDataSource.php

Spacing +8 added lines, -8 removed lines

@@ -29,7 +29,7 @@ 
      *
      * @return self
      */
-    public function from(DataSourceInterface|string $dataSource): self
+    public function from(DataSourceInterface | string $dataSource): self
     {
         return $this->dataSource($dataSource);
     }
@@ -41,7 +41,7 @@ 
      *
      * @return self
      */
-    public function dataSource(DataSourceInterface|string $dataSource): self
+    public function dataSource(DataSourceInterface | string $dataSource): self
     {
         if (is_string($dataSource)) {
             $this->dataSource = new TableDataSource($dataSource);
@@ -60,7 +60,7 @@ 
      *
      * @return self
      */
-    public function join(DataSourceInterface|Closure|string $dataSourceOrClosure, string $as, string $condition, string|JoinType $joinType = JoinType::INNER): self
+    public function join(DataSourceInterface | Closure | string $dataSourceOrClosure, string $as, string $condition, string | JoinType $joinType = JoinType::INNER): self
     {
         if ($this->dataSource instanceof TableDataSource && $this->dataSource->dataSourceName == '') {
             throw new InvalidArgumentException('You first have to define your "from" dataSource before you can join!');
@@ -98,7 +98,7 @@ 
         string $lookupName,
         string $as,
         string $condition,
-        string|JoinType $joinType = JoinType::INNER
+        string | JoinType $joinType = JoinType::INNER
     ): self {
         $lookupDataSource = new LookupDataSource($lookupName);
 
@@ -112,7 +112,7 @@ 
      *
      * @return self
      */
-    public function leftJoin(DataSourceInterface|Closure|string $dataSourceOrClosure, string $as, string $condition): self
+    public function leftJoin(DataSourceInterface | Closure | string $dataSourceOrClosure, string $as, string $condition): self
     {
         return $this->join($dataSourceOrClosure, $as, $condition, JoinType::LEFT);
     }
@@ -124,7 +124,7 @@ 
      *
      * @return self
      */
-    public function innerJoin(DataSourceInterface|Closure|string $dataSourceOrClosure, string $as, string $condition): self
+    public function innerJoin(DataSourceInterface | Closure | string $dataSourceOrClosure, string $as, string $condition): self
     {
         return $this->join($dataSourceOrClosure, $as, $condition);
     }
@@ -160,7 +160,7 @@ 
      * @return $this
      * @see https://druid.apache.org/docs/latest/querying/datasource.html#union
      */
-    public function union(array|string $dataSources, bool $append = true): self
+    public function union(array | string $dataSources, bool $append = true): self
     {
         $dataSources = (array)$dataSources;
 
@@ -183,7 +183,7 @@ 
      * @return DataSourceInterface
      * @throws InvalidArgumentException
      */
-    protected function getDataSource(DataSourceInterface|Closure|string $dataSourceOrClosure): DataSourceInterface
+    protected function getDataSource(DataSourceInterface | Closure | string $dataSourceOrClosure): DataSourceInterface
     {
         if ($dataSourceOrClosure instanceof DataSourceInterface) {
             return $dataSourceOrClosure;

src/Types/MultiValueHandling.php

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -12,5 +12,5 @@
 {
     case SORTED_ARRAY = 'SORTED_ARRAY';
     case SORTED_SET   = 'SORTED_SET';
-    case ARRAY        = 'ARRAY';
+    case array        = 'ARRAY';
 }
\ No newline at end of file