from: statefun-kinesis-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/KinesisIOTypes.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-kinesis-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/egress/KinesisEgressSpec.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-kinesis-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/egress/KinesisEgressBuilder.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-kinesis-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressSpec.java"
   contains "import org.apache.flink.statefun.sdk.IngressType;"

from: statefun-kinesis-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressBuilder.java"
   contains "import org.apache.flink.statefun.sdk.core.OptionalProperty;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressSpec.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressSpec.java"
   contains "import org.apache.flink.statefun.sdk.IngressType;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/Constants.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressBuilder.java"
   contains "import org.apache.flink.statefun.sdk.core.OptionalProperty;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressBuilder.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-testutil
to: statefun-sdk-embedded
evidence:
 - file: "statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function/TestContext.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Counter;"

from: statefun-testutil
to: statefun-sdk-embedded
evidence:
 - file: "statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function/FunctionTestHarness.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-testutil
to: statefun-sdk-embedded
evidence:
 - file: "statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/matchers/MessagesSentToAddress.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-testutil
to: statefun-sdk-embedded
evidence:
 - file: "statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/matchers/SentNothingMatcher.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-testutil
to: statefun-sdk-embedded
evidence:
 - file: "statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/matchers/MatchersByAddress.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-testutil
to: statefun-sdk-embedded
evidence:
 - file: "statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/matchers/StatefulFunctionMatchers.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentRequestReplyHandler.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ApiExtension.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ValueSpec.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Type.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.Message;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/Slices.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/ByteStringSlice.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/SliceProtobufUtil.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io/KafkaEgressMessage.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io/KinesisEgressMessage.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageBuilder.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessageBuilder.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-sdk-java
to: statefun-shaded
evidence:
 - file: "statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorage.java"
   contains "import org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ByteString;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/StateFunObjectMapper.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-extensions/src/main/java/org/apache/flink/statefun/extensions/ExtensionModule.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-extensions/src/main/java/org/apache/flink/statefun/extensions/ComponentJsonObject.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-extensions/src/main/java/org/apache/flink/statefun/extensions/ComponentBinder.java"
   contains "import org.apache.flink.statefun.sdk.spi.StatefulFunctionModule;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/StateBootstrapFunctionProvider.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/Context.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/StatefulFunctionsSavepointCreator.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/StateBootstrapFunction.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/BootstrapDataRouterProvider.java"
   contains "import org.apache.flink.statefun.sdk.io.Router;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/BootstrapDatasetUnion.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Metrics;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapData.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapper.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/datastream/SourceFunctionSpec.java"
   contains "import org.apache.flink.statefun.sdk.IngressType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/datastream/SinkFunctionSpec.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/datastream/SourceSinkModule.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/spi/FlinkIoModule.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/spi/SinkProvider.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/spi/SourceProvider.java"
   contains "import org.apache.flink.statefun.sdk.io.IngressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/io/SupplyingIngressSpec.java"
   contains "import org.apache.flink.statefun.sdk.IngressType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/io/ConsumingEgressSpec.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/io/HarnessConstants.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/io/HarnessIoModule.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/Harness.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/KinesisSourceProvider.java"
   contains "import org.apache.flink.statefun.sdk.io.IngressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/KinesisSinkProvider.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressBinderV1.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressSpec.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressSpec.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressBinderV1.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressDeserializer.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/common/json/EgressIdentifierJsonDeserializer.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/common/json/IngressIdentifierJsonDeserializer.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/common/AutoRoutableProtobufRouter.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaSinkProvider.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaSourceProvider.java"
   contains "import org.apache.flink.statefun.sdk.io.IngressSpec;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/egress/v1/GenericKafkaEgressBinderV1.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/egress/v1/GenericKafkaEgressSpec.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressSpec.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressBinderV1.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/SerializableHttpFunctionProvider.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/SerializableStatefulFunctionProvider.java"
   contains "import org.apache.flink.statefun.sdk.StatefulFunctionProvider;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/RequestReplyFunctionBuilder.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilder.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionDataStreamBuilder.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionBuilder.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionEgressStreams.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkMetricUtil.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Counter;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkUserMetrics.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Counter;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkFuncionTypeMetricsFactory.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Metrics;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FunctionTypeMetrics.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Metrics;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkFunctionTypeMetrics.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Metrics;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FunctionTypeMetricsRepository.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FuncionTypeMetricsFactory.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueSerializerSnapshot.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueSerializer.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeMismatchException.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/IngressRouterOperator.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Metrics;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/EmbeddedTranslator.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/StatefulFunctionTranslator.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/FlinkUniverse.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/EgressToSinkTranslator.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/IngressToSourceFunctionTranslator.java"
   contains "import org.apache.flink.statefun.sdk.io.IngressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/DecoratedSink.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/Sinks.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/DecoratedSource.java"
   contains "import org.apache.flink.statefun.sdk.io.IngressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/RouterTranslator.java"
   contains "import org.apache.flink.statefun.sdk.io.IngressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/SideOutputTranslator.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/Sources.java"
   contains "import org.apache.flink.statefun.sdk.io.IngressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/LegacyRemoteModuleV30.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java"
   contains "import org.apache.flink.statefun.sdk.spi.StatefulFunctionModule;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/RemoteModule.java"
   contains "import org.apache.flink.statefun.sdk.spi.StatefulFunctionModule;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverse.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java"
   contains "import org.apache.flink.statefun.sdk.spi.StatefulFunctionModule;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/ToFunctionRequestSummary.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/backpressure/InternalContext.java"
   contains "import org.apache.flink.statefun.sdk.Context;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/backpressure/BackPressureValve.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/backpressure/ThresholdBackPressureValve.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageFactory.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/RoutableMessage.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/SdkMessage.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/RoutableMessageBuilder.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/ProtobufMessage.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkStateBinder.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkState.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/State.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/PersistedStates.java"
   contains "import org.apache.flink.statefun.sdk.annotations.Persisted;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/KeyBy.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/PolyglotUtil.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/ExtensionResolver.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/Modules.java"
   contains "import org.apache.flink.statefun.sdk.spi.StatefulFunctionModule;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/ExtensionResolverAccessor.java"
   contains "import org.apache.flink.statefun.sdk.spi.StatefulFunctionModule;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/ReusableContext.java"
   contains "import org.apache.flink.statefun.sdk.metrics.Metrics;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/PendingAsyncOperations.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/PredefinedFunctionLoader.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/ApplyingContext.java"
   contains "import org.apache.flink.statefun.sdk.Context;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncMessageDecorator.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/StatefulFunction.java"
   contains "import org.apache.flink.statefun.sdk.Context;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/StatefulFunctionInvocationException.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/StatefulFunctionRepository.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionRepository.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/LocalFunctionGroup.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncSink.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Partition.java"
   contains "import org.apache.flink.statefun.sdk.Address;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/LiveFunction.java"
   contains "import org.apache.flink.statefun.sdk.Context;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionLoader.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/SideOutputSink.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupDispatchFactory.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientSpec.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TargetFunctions.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionEndpointSpec.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/UrlPathTemplate.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java"
   contains "import org.apache.flink.statefun.sdk.FunctionType;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v1/HttpEndpointBinderV1.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-sdk-embedded
evidence:
 - file: "statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java"
   contains "import org.apache.flink.statefun.sdk.TypeName;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/KinesisFlinkIOModule.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.KinesisIOTypes;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/CachingPartitionerSerializerDelegate.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.egress.EgressRecord;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/KinesisSinkProvider.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.egress.KinesisEgressSerializer;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/AwsAuthConfigProperties.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.auth.AwsCredentials;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressSerializer.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.egress.EgressRecord;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressSpec.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.egress.KinesisEgressBuilder;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressSpec.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.auth.AwsCredentials;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/AwsRegionJsonDeserializer.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.auth.AwsRegion;"

from: statefun-flink
to: statefun-kinesis-io
evidence:
 - file: "statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/AwsCredentialsJsonDeserializer.java"
   contains "import org.apache.flink.statefun.sdk.kinesis.auth.AwsCredentials;"