level23 / druid-client

src/Queries/QueryBuilder.php

Spacing +23 added lines, -23 removed lines

@@ -101,7 +101,7 @@ 
     public function __construct(
         DruidClient $client,
         string $dataSource = '',
-        string|Granularity $granularity = Granularity::ALL
+        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, $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);
 
@@ -262,7 +262,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();
     }
@@ -276,7 +276,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);
 
@@ -305,10 +305,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);
 
@@ -326,7 +326,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);
 
@@ -344,7 +344,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);
 
@@ -362,7 +362,7 @@ 
      * @throws \Level23\Druid\Exceptions\QueryResponseException
      * @throws \GuzzleHttp\Exception\GuzzleException
      */
-    public function groupBy(array|GroupByQueryContext $context = []): GroupByQueryResponse
+    public function groupBy(array | GroupByQueryContext $context = []): GroupByQueryResponse
     {
         $query = $this->buildGroupByQuery($context);
 
@@ -382,8 +382,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);
 
@@ -438,8 +438,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');
@@ -488,7 +488,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');
@@ -540,10 +540,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');
@@ -621,7 +621,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');
@@ -689,7 +689,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');
@@ -761,7 +761,7 @@ 
      *
      * @return GroupByQuery
      */
-    protected function buildGroupByQuery(array|QueryContext $context = []): GroupByQuery
+    protected function buildGroupByQuery(array | QueryContext $context = []): GroupByQuery
     {
         if (count($this->intervals) == 0) {
             throw new InvalidArgumentException('You have to specify at least one interval');
@@ -815,7 +815,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/Dimensions/Dimension.php

Spacing +3 added lines, -3 removed lines

@@ -24,12 +24,12 @@ 
     public function __construct(
         string $dimension,
         string $outputName = null,
-        string|DataType $outputType = DataType::STRING
+        string | DataType $outputType = DataType::STRING
     ) {
         $this->dimension  = $dimension;
         $this->outputName = $outputName ?: $dimension;
 
-        if( empty($outputType)) {
+        if (empty($outputType)) {
             $outputType = DataType::STRING;
         } else {
             $outputType = is_string($outputType) ? DataType::from(strtolower($outputType)) : $outputType;
@@ -41,7 +41,7 @@ 
             );
         }
 
-        $this->outputType         = $outputType;
+        $this->outputType = $outputType;
     }
 
     /**

src/Concerns/HasFilter.php

Spacing +15 added lines, -15 removed lines

@@ -60,9 +60,9 @@ 
      * @return $this
      */
     public function where(
-        Closure|string|FilterInterface $filterOrDimensionOrClosure,
-        int|string|float|bool|null $operator = null,
-        array|int|string|float|bool $value = null,
+        Closure | string | FilterInterface $filterOrDimensionOrClosure,
+        int | string | float | bool | null $operator = null,
+        array | int | string | float | bool $value = null,
         string $boolean = 'and'
     ): self {
 
@@ -243,7 +243,7 @@ 
      * @see https://druid.apache.org/docs/latest/querying/filters/#array-contains-element-filter
      *
      */
-    public function whereArrayContains(string $column, int|float|string|null $value, string $boolean = 'and'): self
+    public function whereArrayContains(string $column, int | float | string | null $value, string $boolean = 'and'): self
     {
         $filter = new ArrayContainsFilter($column, $value);
 
@@ -259,7 +259,7 @@ 
      *
      * @return $this
      */
-    public function orWhereArrayContains(string $column, int|float|string|null $value): self
+    public function orWhereArrayContains(string $column, int | float | string | null $value): self
     {
         return $this->whereArrayContains($column, $value, 'or');
     }
@@ -315,9 +315,9 @@ 
      * @see \Level23\Druid\Concerns\HasFilter::where()
      */
     public function orWhere(
-        string|FilterInterface $filterOrDimension,
-        string|int|float|bool $operator = null,
-        array|int|float|string|bool $value = null
+        string | FilterInterface $filterOrDimension,
+        string | int | float | bool $operator = null,
+        array | int | float | string | bool $value = null
     ): self {
         return $this->where($filterOrDimension, $operator, $value, 'or');
     }
@@ -439,7 +439,7 @@ 
      *
      * @return $this
      */
-    public function whereColumn(Closure|string $dimensionA, Closure|string $dimensionB, string $boolean = 'and'): self
+    public function whereColumn(Closure | string $dimensionA, Closure | string $dimensionB, string $boolean = 'and'): self
     {
         $filter = new ColumnComparisonFilter(
             $this->columnCompareDimension($dimensionA),
@@ -468,7 +468,7 @@ 
      *
      * @return $this
      */
-    public function orWhereColumn(Closure|string $dimensionA, Closure|string $dimensionB): self
+    public function orWhereColumn(Closure | string $dimensionA, Closure | string $dimensionB): self
     {
         return $this->whereColumn($dimensionA, $dimensionB, 'or');
     }
@@ -499,8 +499,8 @@ 
      */
     public function whereBetween(
         string $dimension,
-        int|float|string $minValue,
-        int|float|string $maxValue,
+        int | float | string $minValue,
+        int | float | string $maxValue,
         ?DataType $valueType = null,
         string $boolean = 'and'
     ): self {
@@ -534,8 +534,8 @@ 
      */
     public function orWhereBetween(
         string $dimension,
-        int|float|string $minValue,
-        int|float|string $maxValue,
+        int | float | string $minValue,
+        int | float | string $maxValue,
         ?DataType $valueType = null
     ): self {
         return $this->whereBetween($dimension, $minValue, $maxValue, $valueType, 'or');
@@ -785,7 +785,7 @@ 
      * @return \Level23\Druid\Dimensions\DimensionInterface
      * @throws InvalidArgumentException
      */
-    protected function columnCompareDimension(Closure|string $dimension): DimensionInterface
+    protected function columnCompareDimension(Closure | string $dimension): DimensionInterface
     {
         if ($dimension instanceof Closure) {
             $builder = new DimensionBuilder();

src/Concerns/HasDimensions.php

Spacing +8 added lines, -8 removed lines

@@ -47,9 +47,9 @@ 
      * @return self
      */
     public function select(
-        array|ArrayObject|string|DimensionInterface $dimension,
+        array | ArrayObject | string | DimensionInterface $dimension,
         string $as = '',
-        string|DataType $outputType = DataType::STRING
+        string | DataType $outputType = DataType::STRING
     ): self {
         if (is_string($dimension)) {
             $this->addDimension(new Dimension(
@@ -82,7 +82,7 @@ 
         string $lookupFunction,
         string $dimension,
         string $as = '',
-        bool|string $keepMissingValue = false
+        bool | string $keepMissingValue = false
     ): self {
         $this->addDimension(new LookupDimension(
             $dimension,
@@ -116,7 +116,7 @@ 
         array $map,
         string $dimension,
         string $as = '',
-        bool|string $keepMissingValue = false,
+        bool | string $keepMissingValue = false,
         bool $isOneToOne = false
     ): self {
         $this->addDimension(new LookupDimension(
@@ -149,7 +149,7 @@ 
         string $dimension,
         array $values,
         string $as = '',
-        string|DataType $outputType = DataType::STRING,
+        string | DataType $outputType = DataType::STRING,
         bool $isWhitelist = true
     ): self {
         $this->addDimension(new ListFilteredDimension(
@@ -184,7 +184,7 @@ 
         string $dimension,
         string $regex,
         string $as = '',
-        string|DataType $outputType = DataType::STRING
+        string | DataType $outputType = DataType::STRING
     ): self {
         $this->addDimension(new RegexFilteredDimension(
             new Dimension(
@@ -215,7 +215,7 @@ 
         string $dimension,
         string $prefix,
         string $as = '',
-        string|DataType $outputType = DataType::STRING
+        string | DataType $outputType = DataType::STRING
     ): self {
         $this->addDimension(new PrefixFilteredDimension(
             new Dimension(
@@ -234,7 +234,7 @@ 
      *
      * @param ArrayObject<int|string,string>|string|DimensionInterface|array<int,string> $dimension
      */
-    protected function addDimension(array|ArrayObject|string|DimensionInterface $dimension): void
+    protected function addDimension(array | ArrayObject | string | DimensionInterface $dimension): void
     {
         if ($dimension instanceof DimensionInterface) {
             $this->dimensions[] = $dimension;

src/Filters/RangeFilter.php

Spacing +3 added lines, -3 removed lines

@@ -22,7 +22,7 @@ 
 
     protected BoundOperator $operator;
 
-    protected string|int|float $value;
+    protected string | int | float $value;
 
     protected SortingOrder $ordering;
 
@@ -44,8 +44,8 @@ 
      */
     public function __construct(
         string $column,
-        string|BoundOperator $operator,
-        string|int|float $value,
+        string | BoundOperator $operator,
+        string | int | float $value,
         DataType $valueType = null
     ) {
         $this->column   = $column;

src/Filters/BetweenFilter.php

Spacing +4 added lines, -4 removed lines

@@ -22,9 +22,9 @@ 
 {
     protected string $column;
 
-    protected int|string|float $minValue;
+    protected int | string | float $minValue;
 
-    protected int|string|float $maxValue;
+    protected int | string | float $maxValue;
 
     protected DataType $valueType;
 
@@ -41,8 +41,8 @@ 
      */
     public function __construct(
         string $column,
-        int|float|string $minValue,
-        int|float|string $maxValue,
+        int | float | string $minValue,
+        int | float | string $maxValue,
         DataType $valueType = null
     ) {
         if (is_null($valueType)) {

src/Filters/EqualityFilter.php

Spacing +2 added lines, -2 removed lines

@@ -9,7 +9,7 @@ 
 {
     protected string $column;
 
-    protected string|int|float $value;
+    protected string | int | float $value;
 
     /**
      * @var \Level23\Druid\Types\DataType
@@ -26,7 +26,7 @@ 
      */
     public function __construct(
         string $column,
-        string|int|float $value,
+        string | int | float $value,
         DataType $matchValueType = null
     ) {
         if (is_null($matchValueType)) {

src/Filters/ArrayContainsFilter.php

Spacing +2 added lines, -2 removed lines

@@ -9,7 +9,7 @@ 
 {
     protected string $column;
 
-    protected string|int|float|null $value;
+    protected string | int | float | null $value;
 
     /**
      * @var \Level23\Druid\Types\DataType
@@ -26,7 +26,7 @@ 
      */
     public function __construct(
         string $column,
-        string|int|float|null $value,
+        string | int | float | null $value,
         DataType $matchValueType = null
     ) {
         if (is_null($matchValueType)) {

src/Filters/BoundFilter.php

Spacing +3 added lines, -3 removed lines

@@ -37,11 +37,11 @@
      */
     public function __construct(
         string $dimension,
-        string|BoundOperator $operator,
+        string | BoundOperator $operator,
         string $value,
-        string|SortingOrder $ordering = null
+        string | SortingOrder $ordering = null
     ) {
-        if(is_string($ordering)) {
+        if (is_string($ordering)) {
             $ordering = SortingOrder::from(strtolower($ordering));
         }