b34ec93fc2d51aa57c35c1d0e476ffb51f34fb72 - flink-statefun

commit	b34ec93fc2d51aa57c35c1d0e476ffb51f34fb72	[log] [tgz]
author	Igal Shilman <igalshilman@gmail.com>	Wed Mar 24 11:21:14 2021 +0100
committer	Igal Shilman <igalshilman@gmail.com>	Wed Mar 24 16:31:13 2021 +0100
tree	04426ab27a322260b1fe31d56addabe819ffb745
parent	845216ccbbcd98e29dd731fd892c829ce05a57a4 [diff]

[FLINK-21958] Rename statefun-sdk -> statefun-sdk-embedded

pom.xml[diff]
statefun-e2e-tests/statefun-sanity-e2e/pom.xml[diff]
statefun-e2e-tests/statefun-smoke-e2e/pom.xml[diff]
statefun-flink/statefun-flink-core/pom.xml[diff]
statefun-flink/statefun-flink-datastream/pom.xml[diff]
statefun-flink/statefun-flink-distribution/pom.xml[diff]
statefun-flink/statefun-flink-io-bundle/pom.xml[diff]
statefun-flink/statefun-flink-io/pom.xml[diff]
statefun-flink/statefun-flink-state-processor/pom.xml[diff]
statefun-kafka-io/pom.xml[diff]
statefun-kinesis-io/pom.xml[diff]
statefun-quickstart/src/main/resources/archetype-resources/pom.xml[diff]
statefun-sdk-embedded/pom.xml[Renamed from statefun-sdk/pom.xml - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/Address.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/AsyncOperationResult.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/AsyncOperationResult.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Context.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/Context.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/EgressType.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionTypeNamespaceMatcher.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/FunctionTypeNamespaceMatcher.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/IngressType.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/StatefulFunction.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/StatefulFunction.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/StatefulFunctionProvider.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/StatefulFunctionProvider.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/TypeName.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/TypeName.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/annotations/ForRuntime.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/annotations/ForRuntime.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/annotations/Persisted.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/annotations/Persisted.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressSpec.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/io/EgressSpec.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressSpec.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/io/IngressSpec.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/Router.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/io/Router.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/match/MatchBinder.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/match/MatchBinder.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/match/StatefulMatchFunction.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/match/StatefulMatchFunction.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/spi/StatefulFunctionModule.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/spi/StatefulFunctionModule.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/Accessor.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Accessor.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/AppendingBufferAccessor.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/AppendingBufferAccessor.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBuffer.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBuffer.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedStateRegistry.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/PersistedStateRegistry.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedTable.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/PersistedTable.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedValue.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/PersistedValue.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/RemotePersistedValue.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/RemotePersistedValue.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/StateBinder.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/StateBinder.java - diff]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/TableAccessor.java[Renamed from statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/TableAccessor.java - diff]
statefun-sdk-embedded/src/test/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBufferTest.java[Renamed from statefun-sdk/src/test/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBufferTest.java - diff]
statefun-sdk-embedded/src/test/java/org/apache/flink/statefun/sdk/state/PersistedStateRegistryTest.java[Renamed from statefun-sdk/src/test/java/org/apache/flink/statefun/sdk/state/PersistedStateRegistryTest.java - diff]
statefun-testutil/pom.xml[diff]

46 files changed