Skip to content

Commit 434a852

Browse files
committed
Add missing @Inject to PartitionedFileSystemLayout
1 parent e13169d commit 434a852

File tree

2 files changed

+42
-0
lines changed

2 files changed

+42
-0
lines changed

plugin/trino-spooling-filesystem/src/main/java/io/trino/spooling/filesystem/PartitionedFileSystemLayout.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import com.google.common.collect.ImmutableList;
1818
import com.google.common.hash.HashCode;
1919
import com.google.common.hash.Hashing;
20+
import com.google.inject.Inject;
2021
import io.trino.filesystem.Location;
2122

2223
import java.util.List;
@@ -28,6 +29,7 @@ public class PartitionedFileSystemLayout
2829
{
2930
private final int partitions;
3031

32+
@Inject
3133
public PartitionedFileSystemLayout(PartitionedLayoutConfig layoutConfig)
3234
{
3335
this.partitions = requireNonNull(layoutConfig, "layoutConfig is null").getPartitions();
Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
/*
2+
* Licensed under the Apache License, Version 2.0 (the "License");
3+
* you may not use this file except in compliance with the License.
4+
* You may obtain a copy of the License at
5+
*
6+
* http://www.apache.org/licenses/LICENSE-2.0
7+
*
8+
* Unless required by applicable law or agreed to in writing, software
9+
* distributed under the License is distributed on an "AS IS" BASIS,
10+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11+
* See the License for the specific language governing permissions and
12+
* limitations under the License.
13+
*/
14+
package io.trino.server.protocol;
15+
16+
import com.google.common.collect.ImmutableMap;
17+
18+
import java.util.Map;
19+
20+
public class TestJsonSpooledPartitionedLayoutQueries
21+
extends AbstractSpooledQueryDataDistributedQueries
22+
{
23+
@Override
24+
protected String encoding()
25+
{
26+
return "json";
27+
}
28+
29+
@Override
30+
protected Map<String, String> spoolingFileSystemConfig()
31+
{
32+
return ImmutableMap.of("fs.layout", "partitioned");
33+
}
34+
35+
@Override
36+
protected Map<String, String> spoolingConfig()
37+
{
38+
return ImmutableMap.of("protocol.spooling.inlining.enabled", "false");
39+
}
40+
}

0 commit comments

Comments
 (0)