From c8c8b2e56f80825fe4edce6f0f6d169010d956d1 Mon Sep 17 00:00:00 2001 From: Yuto Kawamura Date: Tue, 8 Jun 2021 13:23:46 +0900 Subject: [PATCH] Correct outdated import paths in docs/example project --- .../main/java/example/CentralDogmaSupplierMain.java | 2 +- .../src/main/java/example/IgnoreKeysMain.java | 9 +++++---- .../main/java/example/JSONUserEventExtractor.java | 4 ++-- .../src/main/java/example/ProcessingRateMain.java | 13 ++++++------- .../src/main/java/example/ProcessorMain.java | 2 +- .../src/main/java/example/ProcessorMain2.java | 8 ++++---- .../src/main/java/example/RetryQueuingMain.java | 2 +- .../src/main/java/example/TaskCompactionMain.java | 10 +++++----- .../main/java/example/UserEventProcessorMain.java | 2 +- 9 files changed, 26 insertions(+), 26 deletions(-) diff --git a/docs/example/src/main/java/example/CentralDogmaSupplierMain.java b/docs/example/src/main/java/example/CentralDogmaSupplierMain.java index 93baee7b..e3eaaabd 100644 --- a/docs/example/src/main/java/example/CentralDogmaSupplierMain.java +++ b/docs/example/src/main/java/example/CentralDogmaSupplierMain.java @@ -24,8 +24,8 @@ import com.linecorp.centraldogma.client.armeria.ArmeriaCentralDogmaBuilder; import com.linecorp.decaton.centraldogma.CentralDogmaPropertySupplier; import com.linecorp.decaton.example.protocol.Mytasks.PrintMessageTask; -import com.linecorp.decaton.processor.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; import com.linecorp.decaton.protobuf.ProtocolBuffersDeserializer; diff --git a/docs/example/src/main/java/example/IgnoreKeysMain.java b/docs/example/src/main/java/example/IgnoreKeysMain.java index bf97e29a..46a861ec 100644 --- a/docs/example/src/main/java/example/IgnoreKeysMain.java +++ b/docs/example/src/main/java/example/IgnoreKeysMain.java @@ -16,7 +16,8 @@ package example; -import static com.linecorp.decaton.processor.ProcessorProperties.CONFIG_IGNORE_KEYS; + +import static com.linecorp.decaton.processor.runtime.ProcessorProperties.CONFIG_IGNORE_KEYS; import java.util.Arrays; import java.util.Properties; @@ -24,10 +25,10 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; import com.linecorp.decaton.example.protocol.Mytasks.PrintMessageTask; -import com.linecorp.decaton.processor.ProcessorsBuilder; -import com.linecorp.decaton.processor.Property; -import com.linecorp.decaton.processor.StaticPropertySupplier; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; +import com.linecorp.decaton.processor.runtime.Property; +import com.linecorp.decaton.processor.runtime.StaticPropertySupplier; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; import com.linecorp.decaton.protobuf.ProtocolBuffersDeserializer; diff --git a/docs/example/src/main/java/example/JSONUserEventExtractor.java b/docs/example/src/main/java/example/JSONUserEventExtractor.java index df4b0286..5209fc67 100644 --- a/docs/example/src/main/java/example/JSONUserEventExtractor.java +++ b/docs/example/src/main/java/example/JSONUserEventExtractor.java @@ -21,10 +21,10 @@ import com.fasterxml.jackson.databind.ObjectMapper; -import com.linecorp.decaton.processor.DecatonTask; -import com.linecorp.decaton.processor.TaskExtractor; import com.linecorp.decaton.processor.TaskMetadata; +import com.linecorp.decaton.processor.runtime.DecatonTask; +import com.linecorp.decaton.processor.runtime.TaskExtractor; import example.models.UserEvent; public class JSONUserEventExtractor implements TaskExtractor { diff --git a/docs/example/src/main/java/example/ProcessingRateMain.java b/docs/example/src/main/java/example/ProcessingRateMain.java index 8e2c1a23..d6eebba8 100644 --- a/docs/example/src/main/java/example/ProcessingRateMain.java +++ b/docs/example/src/main/java/example/ProcessingRateMain.java @@ -16,20 +16,19 @@ package example; -import static com.linecorp.decaton.processor.ProcessorProperties.CONFIG_PROCESSING_RATE; - -import java.util.Properties; +import static com.linecorp.decaton.processor.runtime.ProcessorProperties.CONFIG_PROCESSING_RATE; import org.apache.kafka.clients.consumer.ConsumerConfig; +import java.util.Properties; + import com.linecorp.decaton.example.protocol.Mytasks.PrintMessageTask; -import com.linecorp.decaton.processor.ProcessorsBuilder; -import com.linecorp.decaton.processor.Property; -import com.linecorp.decaton.processor.StaticPropertySupplier; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; +import com.linecorp.decaton.processor.runtime.Property; +import com.linecorp.decaton.processor.runtime.StaticPropertySupplier; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; import com.linecorp.decaton.protobuf.ProtocolBuffersDeserializer; - import example.processors.PrintMessageTaskProcessor; public class ProcessingRateMain { diff --git a/docs/example/src/main/java/example/ProcessorMain.java b/docs/example/src/main/java/example/ProcessorMain.java index 4cd4375d..7e03fd46 100644 --- a/docs/example/src/main/java/example/ProcessorMain.java +++ b/docs/example/src/main/java/example/ProcessorMain.java @@ -21,8 +21,8 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; import com.linecorp.decaton.example.protocol.Mytasks.PrintMessageTask; -import com.linecorp.decaton.processor.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; import com.linecorp.decaton.protobuf.ProtocolBuffersDeserializer; diff --git a/docs/example/src/main/java/example/ProcessorMain2.java b/docs/example/src/main/java/example/ProcessorMain2.java index 8b6d9249..bd77ea58 100644 --- a/docs/example/src/main/java/example/ProcessorMain2.java +++ b/docs/example/src/main/java/example/ProcessorMain2.java @@ -21,11 +21,11 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; import com.linecorp.decaton.example.protocol.Mytasks.PrintMessageTask; -import com.linecorp.decaton.processor.ProcessorProperties; -import com.linecorp.decaton.processor.ProcessorsBuilder; -import com.linecorp.decaton.processor.Property; -import com.linecorp.decaton.processor.StaticPropertySupplier; +import com.linecorp.decaton.processor.runtime.ProcessorProperties; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; +import com.linecorp.decaton.processor.runtime.Property; +import com.linecorp.decaton.processor.runtime.StaticPropertySupplier; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; import com.linecorp.decaton.protobuf.ProtocolBuffersDeserializer; diff --git a/docs/example/src/main/java/example/RetryQueuingMain.java b/docs/example/src/main/java/example/RetryQueuingMain.java index 5a397b91..f1904067 100644 --- a/docs/example/src/main/java/example/RetryQueuingMain.java +++ b/docs/example/src/main/java/example/RetryQueuingMain.java @@ -22,8 +22,8 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; import com.linecorp.decaton.example.protocol.Mytasks.PrintMessageTask; -import com.linecorp.decaton.processor.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.RetryConfig; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; import com.linecorp.decaton.protobuf.ProtocolBuffersDeserializer; diff --git a/docs/example/src/main/java/example/TaskCompactionMain.java b/docs/example/src/main/java/example/TaskCompactionMain.java index 1eb2e386..c4f0499d 100644 --- a/docs/example/src/main/java/example/TaskCompactionMain.java +++ b/docs/example/src/main/java/example/TaskCompactionMain.java @@ -23,16 +23,16 @@ import com.fasterxml.jackson.databind.ObjectMapper; -import com.linecorp.decaton.processor.DecatonTask; -import com.linecorp.decaton.processor.ProcessorsBuilder; -import com.linecorp.decaton.processor.TaskExtractor; import com.linecorp.decaton.processor.TaskMetadata; -import com.linecorp.decaton.processor.runtime.CompactionProcessor; -import com.linecorp.decaton.processor.runtime.CompactionProcessor.CompactChoice; +import com.linecorp.decaton.processor.processors.CompactionProcessor; +import com.linecorp.decaton.processor.processors.CompactionProcessor.CompactChoice; +import com.linecorp.decaton.processor.runtime.DecatonTask; import com.linecorp.decaton.processor.runtime.ProcessorScope; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; +import com.linecorp.decaton.processor.runtime.TaskExtractor; import example.models.LocationEvent; import example.processors.LocationEventProcessor; diff --git a/docs/example/src/main/java/example/UserEventProcessorMain.java b/docs/example/src/main/java/example/UserEventProcessorMain.java index f6a11c2c..3db1d656 100644 --- a/docs/example/src/main/java/example/UserEventProcessorMain.java +++ b/docs/example/src/main/java/example/UserEventProcessorMain.java @@ -20,8 +20,8 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; -import com.linecorp.decaton.processor.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.ProcessorSubscription; +import com.linecorp.decaton.processor.runtime.ProcessorsBuilder; import com.linecorp.decaton.processor.runtime.SubscriptionBuilder; import example.processors.UserEventProcessor;