Skip to content

Commit a2e351e

Browse files
authored
GEOMESA-3581 Parallelize spill-to-disk during sort operations (#3548)
1 parent ef351e4 commit a2e351e

5 files changed

Lines changed: 206 additions & 94 deletions

File tree

geomesa-fs/geomesa-fs-storage/geomesa-fs-storage-core/src/main/scala/org/locationtech/geomesa/fs/storage/core/package.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ package object core {
130130
/**
131131
* Json serializer for partitions
132132
*/
133-
private[core] object PartitionSerializer extends JsonSerializer[Partition] with JsonDeserializer[Partition] {
133+
object PartitionSerializer extends JsonSerializer[Partition] with JsonDeserializer[Partition] {
134134

135135
override def serialize(src: Partition, typeOfSrc: Type, context: JsonSerializationContext): JsonElement = {
136136
val array = new JsonArray(src.values.size)
@@ -180,7 +180,7 @@ package object core {
180180
/**
181181
* Json serializer for partition keys
182182
*/
183-
private[core] object PartitionKeySerializer extends JsonSerializer[PartitionKey] with JsonDeserializer[PartitionKey] {
183+
object PartitionKeySerializer extends JsonSerializer[PartitionKey] with JsonDeserializer[PartitionKey] {
184184

185185
override def serialize(src: PartitionKey, typeOfSrc: Type, context: JsonSerializationContext): JsonElement = {
186186
val obj = new JsonObject()

geomesa-fs/geomesa-fs-tools/src/main/scala/org/locationtech/geomesa/fs/tools/ingest/FsGeneratePartitionFiltersCommand.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ class FsGeneratePartitionFiltersCommand extends FsDataStoreCommand {
2828

2929
override def execute(): Unit = withDataStore { ds =>
3030
if (params.cqlFilter == null && params.partitions.isEmpty) {
31-
throw new ParameterException("At least one of --partitions or --cql must be specified")
31+
throw new ParameterException("At least one of --partition or --cql must be specified")
3232
}
3333

3434
val metadata = ds.storage(params.featureName).metadata

0 commit comments

Comments
 (0)