flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From StephanEwen <...@git.apache.org>
Subject [GitHub] flink pull request: Out-of-core state backend for JDBC databases
Date Thu, 19 Nov 2015 16:22:10 GMT
Github user StephanEwen commented on a diff in the pull request:

    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java
    @@ -64,33 +64,35 @@
     	 * Closes the state backend, releasing all internal resources, but does not delete any
     	 * checkpoint data.
    -	 * 
    +	 *
     	 * @throws Exception Exceptions can be forwarded and will be logged by the system
     	public abstract void close() throws Exception;
     	// ------------------------------------------------------------------------
     	//  key/value state
     	// ------------------------------------------------------------------------
     	 * Creates a key/value state backed by this state backend.
    -	 * 
    +	 *
    +	 * @param operatorId Unique id for the operator creating the state
    +	 * @param stateName Name of the created state
     	 * @param keySerializer The serializer for the key.
     	 * @param valueSerializer The serializer for the value.
     	 * @param defaultValue The value that is returned when no other value has been associated
with a key, yet.
     	 * @param <K> The type of the key.
     	 * @param <V> The type of the value.
    -	 * 
    +	 *
     	 * @return A new key/value state backed by this backend.
    -	 * 
    +	 *
     	 * @throws Exception Exceptions may occur during initialization of the state and should
be forwarded.
    -	public abstract <K, V> KvState<K, V, Backend> createKvState(
    +	public abstract <K, V> KvState<K, V, Backend> createKvState(int operatorId,
String stateName,
    --- End diff --
    I would like to get rid of this change and simply let the state backend create a UID for
the state name.
    This method is called one per proper creation of a state (so it should not need deterministic
state naming). Recovery happens from the state handle, which can store all required info.

If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message