level23 / druid-client

src/Concerns/HasSegmentGranularity.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
      *
      * @return $this
      */
-    public function segmentGranularity(string|Granularity $segmentGranularity): self
+    public function segmentGranularity(string | Granularity $segmentGranularity): self
     {
         $this->segmentGranularity = is_string($segmentGranularity) ? Granularity::from(strtolower($segmentGranularity)) : $segmentGranularity;
 

src/Concerns/HasInterval.php

Spacing +1 added lines, -1 removed lines

@@ -51,7 +51,7 @@
      * @return $this
      * @throws \Exception
      */
-    public function interval(DateTimeInterface|int|string $start, DateTimeInterface|int|string $stop = null): self
+    public function interval(DateTimeInterface | int | string $start, DateTimeInterface | int | string $stop = null): self
     {
         $this->interval = new Interval($start, $stop);
 

src/Concerns/HasIntervals.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
      * @return $this
      * @throws \Exception
      */
-    public function interval(DateTimeInterface|int|string $start, DateTimeInterface|int|string $stop = null): self
+    public function interval(DateTimeInterface | int | string $start, DateTimeInterface | int | string $stop = null): self
     {
         $this->intervals[] = new Interval($start, $stop);
 

src/Aggregations/FirstAggregator.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
      * @param string          $outputName When not given, we will use the same name as the metric.
      * @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/Aggregations/MethodAggregator.php

Spacing +1 added lines, -1 removed lines

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

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/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/Metadata/MetadataBuilder.php

Spacing +7 added lines, -7 removed lines

@@ -84,11 +84,11 @@ 
      * @throws \Exception
      */
     public function timeBoundary(
-        string|DataSourceInterface $dataSource,
-        null|string|TimeBound $bound = TimeBound::BOTH,
+        string | DataSourceInterface $dataSource,
+        null | string | TimeBound $bound = TimeBound::BOTH,
         \Closure $filterBuilder = null,
         ContextInterface $context = null
-    ): DateTime|array {
+    ): DateTime | array {
 
         $query = [
             'queryType'  => 'timeBoundary',
@@ -300,8 +300,8 @@ 
      */
     protected function getColumnsForInterval(
         string $dataSource,
-        DateTimeInterface|int|string $start,
-        DateTimeInterface|int|string $stop = null
+        DateTimeInterface | int | string $start,
+        DateTimeInterface | int | string $stop = null
     ): array {
         $response = $this->client->query($dataSource)
             ->interval($start, $stop)
@@ -342,8 +342,8 @@ 
      */
     public function rowCount(
         string $dataSource,
-        DateTimeInterface|int|string $start,
-        DateTimeInterface|int|string $stop = null
+        DateTimeInterface | int | string $start,
+        DateTimeInterface | int | string $stop = null
     ): int {
         $response = $this->client->query($dataSource)
             ->interval($start, $stop)